Documentation ¶
Index ¶
- func ConditionEngineStarted(ev state.Event, s state.State) bool
- func ConditionTaskFinishedWithStatus(task string, status string) func(ev state.Event, s state.State) bool
- func HandleEngineError(err error)
- type Engine
- type EngineKubernetesOptions
- type EngineOptions
- type EventReaction
- type Pipeline
- type PipelineMetadata
- type PipelineSpec
- type Service
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConditionEngineStarted ¶
ConditionEngineStarted returns true once the engine emits started event
func ConditionTaskFinishedWithStatus ¶
func ConditionTaskFinishedWithStatus(task string, status string) func(ev state.Event, s state.State) bool
ConditionTaskFinishedWithStatus returns true once a task is finished with given status
func HandleEngineError ¶ added in v0.41.0
func HandleEngineError(err error)
HandleEngineError prints the error in case the engine.Run was failed and exit
Types ¶
type EngineKubernetesOptions ¶ added in v0.24.0
EngineKubernetesOptions when running service on kubernetes cluster
type EngineOptions ¶
type EngineOptions struct { Pipeline Pipeline // LogsDirectory path where to store logs LogsDirectory string Kubeconfig *EngineKubernetesOptions Logger logger.Logger }
EngineOptions to create new engine
type EventReaction ¶ added in v0.31.0
type EventReaction struct { Condition func(ev state.Event, state state.State) bool Reaction func(ev state.Event, state state.State) []task.Task }
EventReaction is a binding of an event to a function that builds tasks
type Pipeline ¶
type Pipeline struct { Metadata PipelineMetadata Spec PipelineSpec }
Pipeline is the pipeline representation
type PipelineMetadata ¶
PipelineMetadata holds all the metadata of a pipeline
type PipelineSpec ¶
type PipelineSpec struct { Reactions []EventReaction Services []Service }
PipelineSpec is the spec of a pipeline
type Service ¶
type Service struct { // Name is official service which is part of the service catalog (https://github.com/open-integration/core-services/releases) Name string // Version of the service, empty string will use the latest version from catalog Version string // Path a location of the local fs the service can be found, Path cannot be set with Name together Path string // As alias name to refer the service as part of the task implementation As string }
Service is a Service a pipeline should execute
Click to show internal directories.
Click to hide internal directories.