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
- type Argument
- type Engine
- type EngineKubernetesOptions
- type EngineOptions
- type EventReaction
- type Pipeline
- type PipelineMetadata
- type PipelineSpec
- type Service
- type Task
- type TaskMetadata
- type TaskSpec
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConditionEngineStarted ¶
ConditionEngineStarted returns true once the engine emits started event
Types ¶
type Argument ¶
type Argument struct { Key string Value interface{} // Func returns a dynamic Value instead of Argument.Values Func func() interface{} }
Argument is key value struct that should be passed in a service call
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 }
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
type Task ¶
type Task struct { Metadata TaskMetadata Spec TaskSpec }
Task is a task a pipeline should execute
type TaskMetadata ¶
type TaskMetadata struct {
Name string
}
TaskMetadata holds all the metadata of a pipeline
Source Files ¶
Click to show internal directories.
Click to hide internal directories.