XtrEvent.h

Go to the documentation of this file.

#include "XtrMetadata.h"
#include "XtrReporter.h"
#include <string>
#include <sstream>
#include <vector>
#include <map>

using namespace std;


#ifndef _XTR_EVENT_CTX_H
#define _XTR_EVENT_CTX_H

namespace xtr {
    
class EventEdge 
{
public:
    enum EdgeDir {
        NEXT = 0,
        UP,
        DOWN,
    };

    EventEdge() : opId(), dir(NEXT), chainId(0) {};
    EventEdge(OpId _opId, EdgeDir _dir, u_int16_t _chainId = 0)
                 : opId(_opId), dir(_dir), chainId(_chainId) {};

    static const char* DirName(EdgeDir dir) {
        switch(dir) {
        case NEXT: return "next";
        case UP  : return "up";
        case DOWN: return "down";
        default: return "";
        }
    }

    OpId opId;
    EdgeDir dir;
    u_int16_t chainId;
};

class Event   
{
public:
    Event();

    Event(const Metadata& xtr);
  
    Event(const Event& model);

    xtr_result setTaskId(const TaskId& taskId);

    xtr_result setRandomOpId(size_t opIdLen = 4);

    xtr_result setSeverity(u_int8_t severity);

    u_int8_t getSeverity();

    xtr_result addEdge(const Metadata& xtr, EventEdge::EdgeDir dir = EventEdge::NEXT);

    xtr_result addInfo(const char* key, const char* value); 

    void addTimestamp(const char* label);


    size_t fork();

    const Metadata& getMetadata();

    const Metadata& getMetadata(size_t index);
    
    string getReport();

    xtr_result sendReport();
    
    //XtrReport getReport()        
private:
    void setTimestamp();

    Metadata my_xtr;                 //this event's taskId, optionId, options
    u_int8_t severity;               //this event's severity level    
    
    vector<u_int16_t> out_chain_ids; //this event's outgoing chainIds
    size_t chain_id_index;
    
    vector<EventEdge> in_edges;      //incoming edges
    string info;                     //append-only string for holding key-value pairs

    struct timeval timestamp;
    bool timeset;
};

}; //namespace xtr

#if 0
edge opId, chain, type
end-chain
fork (?)
timestamp: time, value

This is a multiset...
class XtrReport()
{
    put(key, value)
    get(key) 
    del(key)
    returns a fully formatted X-Trace report
    toString
    X-Trace Report 1.0
    Key: Value
    Key: Value
    Key: Value
}

/* Talks to the local daemon */
class Reporter()
{
    Reporter();
    virtual send(XtrReport& r);
}
#endif

#endif