pipelineevent.h

Go to the documentation of this file.

 
#pragma once
 
 
#include <promeki/config.h>
#if PROMEKI_ENABLE_PROAV
#include <promeki/namespace.h>
#include <promeki/error.h>
#include <promeki/json.h>
#include <promeki/list.h>
#include <promeki/metadata.h>
#include <promeki/sharedptr.h>
#include <promeki/string.h>
#include <promeki/timestamp.h>
#include <promeki/variant.h>
 
PROMEKI_NAMESPACE_BEGIN
 
class PipelineEvent {
                PROMEKI_SHARED_FINAL(PipelineEvent)
        public:
                using Ptr = SharedPtr<PipelineEvent>;
 
                using List = ::promeki::List<PipelineEvent>;
 
                using PtrList = ::promeki::List<Ptr>;
 
                enum class Kind {
                        StateChanged,          
                        StageState,            
                        StageError,            
                        StatsUpdated,          
                        PlanResolved,          
                        Log,                   
                        TransportStateChanged  
                };
 
                PipelineEvent() = default;
 
                // ------------------------------------------------------------
                // Field accessors
                // ------------------------------------------------------------
 
                Kind kind() const { return _kind; }
 
                const String &stageName() const { return _stageName; }
 
                const Variant &payload() const { return _payload; }
 
                const JsonObject &jsonPayload() const { return _jsonPayload; }
 
                const Metadata &metadata() const { return _metadata; }
 
                const TimeStamp &timestamp() const { return _ts; }
 
                // ------------------------------------------------------------
                // Field mutators
                // ------------------------------------------------------------
 
                void setKind(Kind k) { _kind = k; }
 
                void setStageName(const String &s) { _stageName = s; }
 
                void setPayload(const Variant &v) { _payload = v; }
 
                void setJsonPayload(const JsonObject &j) { _jsonPayload = j; }
 
                void setMetadata(const Metadata &m) { _metadata = m; }
 
                void setTimestamp(const TimeStamp &t) { _ts = t; }
 
                // ------------------------------------------------------------
                // Serialization
                // ------------------------------------------------------------
 
                JsonObject toJson() const;
 
                static PipelineEvent fromJson(const JsonObject &obj, Error *err = nullptr);
 
                static String kindToString(Kind k);
 
                static Kind kindFromString(const String &s, bool *ok = nullptr);
 
        private:
                Kind       _kind = Kind::StateChanged;
                String     _stageName;
                Variant    _payload;
                JsonObject _jsonPayload;
                Metadata   _metadata;
                TimeStamp  _ts;
};
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_PROAV