Documentation ¶
Index ¶
Constants ¶
View Source
const ( MetaTaskRetry = "anemos/meta:anemos:task:retry" MetaEventTimestamp = "anemos/meta:anemos:event:timestamp" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Executor ¶
type Executor interface {
Execute(*api.TaskInstance)
}
type Node ¶
type Node interface { Provider() string Operation() string Name() string Attributes() map[string]string //Name() (string) AddUpstream(name string, node Node) AddDownstream(name string, node Node) Upstream() map[string]Node Downstream() map[string]Node Status() NodeInstanceStatus EndStateReached() bool AssignSession(session Session) OnEvent(event *api.Event) OnStart(event *api.Event) OnProgress(event *api.Event) OnFinish(event *api.Event) OnCancel(event *api.Event) OnSkip(event *api.Event) }
type NodeInstanceStatus ¶
type NodeInstanceStatus int
const ( Unknown NodeInstanceStatus = iota Retry Initialized Queue Start Success Skip Fail )
type Router ¶
type Router interface { StartTask(node Node, instance *api.TaskInstance) StartVirtual(node Node, instance *api.TaskInstance) Fail(node Node, instance *api.TaskInstance) SignalDownstream(node Node) RegisterSession(session Session) }
Directories ¶
Path | Synopsis |
---|---|
grpc
|
|
anemos/v1alpha1
Package grpc_anemos_v1alpha1 is a generated protocol buffer package.
|
Package grpc_anemos_v1alpha1 is a generated protocol buffer package. |
pkg
|
|
provider
|
|
Click to show internal directories.
Click to hide internal directories.