core

Jul 13, 2020

Changes in this version

+ func NewFunctionTask(name string, fn func(context.Context, task.RunOptions) ([]byte, error)) task.Task

+ func NewSerivceTask(name string, service string, endpoint string, arg ...task.Argument) task.Task

+ func NewTickerTask(name string, tickInterval time.Duration, totalTime time.Duration) task.Task

Jun 29, 2020

Changes in this version

+ func ConditionTaskEventReported(name string) condition.Condition

Mar 13, 2020

Changes in this version

+ func ConditionCombined(conditions ...condition.Condition) condition.Condition

Feb 29, 2020

Changes in this version

type EngineKubernetesOptions

+ LogsVolumeClaimName string

+ LogsVolumeName string

Feb 28, 2020

Changes in this version

type EngineKubernetesOptions

+ B64Crt string

+ Host string

+ Token string

Feb 28, 2020

Changes in this version

+ func ConditionTaskFinished(task string) func(ev state.Event, s state.State) bool

Feb 23, 2020

Changes in this version

+ func HandleEngineError(err error)

Feb 11, 2020

Changes in this version

type Engine

+ Modem func() modem.Modem

Feb 5, 2020

Changes in this version

type EngineOptions

+ LogsDirectory string

Feb 4, 2020

Changes in this version

type TaskState

+ Arguments string

+ Logger string

Feb 3, 2020

Changes in this version

+ type EventReaction struct

+ Condition func(ev Event, state State) bool

+ Reaction func(ev Event, state State) []Task

type PipelineSpec

+ Reactions []EventReaction

Jan 20, 2020

Changes in this version

+ type EngineKubernetesOptions struct

+ Context string

+ InCluster bool

+ Namespace string

+ Path string

Jan 5, 2020

Changes in this version

type EngineOptions

+ Kubeconfig ...

Dec 30, 2019

Changes in this version

+ const EngineStateFinished

+ const EngineStateInProgress

+ const EventEngineFinished

+ const EventEngineStarted

+ const EventTaskFinished

+ const EventTaskStarted

+ const TaskStateFinished

+ const TaskStateInProgress

+ const TaskStatusFailed

+ const TaskStatusSuccess

+ func ConditionEngineStarted(ev *Event, state *State) bool

+ func ConditionTaskFinishedWithStatus(task string, status string) func(ev *Event, state *State) bool

+ type Argument struct

+ Func func() interface{}

+ Key string

+ Value interface{}

+ func (a *Argument) GetKey() string

+ func (a *Argument) GetValue() interface{}

+ type Condition struct

+ Func func(*Event, *State) bool

+ Name string

+ type Engine interface

+ Run func() error

+ func NewEngine(opt *EngineOptions) Engine

+ type EngineOptions struct

+ EventChan chan *Event

+ Logger logger.Logger

+ Pipeline Pipeline

+ State *State

+ type Event struct

+ Metadata EventMetadata

+ Payload map[string]interface{}

+ type EventMetadata struct

+ CreatedAt time.Time

+ ID ID

+ Name string

+ type ID string

+ type Pipeline struct

+ Metadata PipelineMetadata

+ Spec PipelineSpec

+ type PipelineMetadata struct

+ Architecture string

+ Name string

+ OS string

+ type PipelineSpec struct

+ Services []Service

+ Tasks []Task

+ type Service struct

+ As string

+ Name string

+ Path string

+ Version string

+ type State struct

+ History []historyElem

+ Metadata StateMetadata

+ Tasks map[ID]TaskState

+ func NewState(opt *StateOptions) *State

+ type StateMetadata struct

+ State string

+ type StateOptions struct

+ EventCn chan *Event

+ EventHistoryFile string

+ Logger logger.Logger

+ StateFile string

+ type Task struct

+ Condition *Condition

+ Metadata TaskMetadata

+ Spec TaskSpec

+ SpecFunc func(*State) (*TaskSpec, error)

+ type TaskMetadata struct

+ Name string

+ Reusable bool

+ type TaskSpec struct

+ Arguments []Argument

+ Endpoint string

+ Service string

+ type TaskState struct

+ Error string

+ EventID ID

+ Output string

+ State string

+ Status string

+ Task string