state

Jul 13, 2020

Changes in this version

type TaskState

+ Times TaskTimes

+ type TaskTimes struct

+ Finished time.Time

+ Started time.Time

Mar 13, 2020

Changes in this version

+ const EngineStatusFailed

+ const EngineStatusSuccess

type EventMetadata

+ Task string

type State

+ Events func() []Event

type UpdateStateMetadataRequest

+ Status string

Feb 28, 2020

Changes in this version

+ const EventTaskElected

+ const TaskStateElected

Feb 15, 2020

Changes in this version

+ type AddRealtedTaskToEventReuqest struct

+ EventID string

+ Task string

+ type ElectTasksRequest struct

+ Tasks []string

type Event

+ RelatedTasks []string

type Options

+ StateUpdateRequest chan StateUpdateRequest

+ WG *sync.WaitGroup

type State

+ EventBytes func() ([]byte, error)

+ StartProcess func()

+ StateBytes func() ([]byte, error)

+ type StateUpdateRequest struct

+ AddRealtedTaskToEventReuqest *AddRealtedTaskToEventReuqest

+ ElectTasksRequest *ElectTasksRequest

+ Metadata StateUpdateRequestMetadata

+ UpdateStateMetadataRequest *UpdateStateMetadataRequest

+ UpdateTaskStateRequest *UpdateTaskStateRequest

+ type StateUpdateRequestMetadata struct

+ CreatedAt time.Time

+ type UpdateStateMetadataRequest struct

+ State string

+ type UpdateTaskStateRequest struct

+ State TaskState

Feb 13, 2020

Changes in this version

+ const CmdFinishEngine

+ const CmdFinishTask

+ const CmdStartEngine

+ const CmdStartTask

+ const EngineStateFinished

+ const EngineStateInProgress

+ const EventEngineFinished

+ const EventEngineStarted

+ const EventTaskFinished

+ const EventTaskStarted

+ const TaskStateFinished

+ const TaskStateInProgress

+ const TaskStatusFailed

+ const TaskStatusSuccess

+ type Change struct

+ Cause string

+ PipelineChange PipelineChange

+ TaskChanges TaskChanges

+ type Event struct

+ Metadata EventMetadata

+ Payload map[string]interface{}

+ type EventMetadata struct

+ CreatedAt time.Time

+ ID string

+ Name string

+ type Options struct

+ CommandsChan chan string

+ EventChan chan *Event

+ Logger logger.Logger

+ Name string

+ type PipelineChange struct

+ States string

+ type ServiceState struct

+ type State interface

+ Bytes func() ([]byte, error)

+ Copy func() (State, error)

+ Send func(cmd string, wg *sync.WaitGroup) chan Change

+ Services func() []ServiceState

+ Tasks func() []TaskState

+ func New(opt *Options) State

+ type TaskChanges struct

+ Arguments string

+ Error string

+ EventID string

+ ID string

+ LoggerID string

+ Name string

+ Output string

+ State string

+ Status string

+ type TaskState struct

+ Arguments string

+ Error string

+ EventID string

+ ID string

+ Logger string

+ Output string

+ State string

+ Status string

+ Task string