Documentation
¶
Index ¶
- Variables
- func WithResources(resources resource.Resources) func(context.Context, Node) error
- type BtfNode
- type BuiltinNode
- type ForNode
- type Node
- type RunQueue
- type Task
- type TaskNode
- func (n *TaskNode) Driver() functiondriver.Driver
- func (n *TaskNode) Exec(ctx context.Context) error
- func (n *TaskNode) FormatString() string
- func (n *TaskNode) IgnoreFailure() bool
- func (n *TaskNode) Init(ctx context.Context, with ...func(context.Context, Node) error) error
- func (n *TaskNode) Name() string
- func (n *TaskNode) RetryOnFailure() int
- func (n *TaskNode) Seq() int
- func (n *TaskNode) Step() int
- type Trigger
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrExitWithSuccess error = errors.New("exit with success") ErrFunctionNotLoaded error = errors.New("function not loaded") ErrLoadedFunctionDuplicated error = errors.New("loaded function duplicated") ErrConfigedFunctionDuplicated error = errors.New("configured function duplicated") ErrDriverNotFound error = errors.New("driver not found") ErrNameConflict error = errors.New("name conflict") ErrConditionIsFalse error = errors.New("condition is false") ErrNodeReused error = errors.New("node reused") ErrBuiltinDirectiveNotFound error = errors.New("builtin directive not found") )
Functions ¶
Types ¶
type BtfNode ¶
type BtfNode struct {
// contains filtered or unexported fields
}
btf is an abbreviation for 'back to for' BtfNode back to the starting of 'for' statement, start a new cycle
func (*BtfNode) FormatString ¶
type BuiltinNode ¶
type BuiltinNode struct {
// contains filtered or unexported fields
}
BuiltinNode be used to execute some builtin functions, e.g. exit, sleep, println...
func (*BuiltinNode) FormatString ¶
func (n *BuiltinNode) FormatString() string
func (*BuiltinNode) Name ¶
func (n *BuiltinNode) Name() string
type ForNode ¶
type ForNode struct {
// contains filtered or unexported fields
}
ForNode stands for the starting of 'for' loop statement
func (*ForNode) FormatString ¶
type Node ¶
type Node interface { FormatString() string Name() string Init(context.Context, ...func(context.Context, Node) error) error Exec(context.Context) error }
Node
type RunQueue ¶
type RunQueue struct {
// contains filtered or unexported fields
}
RunQueue
func (*RunQueue) GetTriggers ¶
GetTriggers returns all event triggers
func (*RunQueue) WalkAndExec ¶
WalkAndExec is the entry and main program for executing the run queue
type TaskNode ¶
type TaskNode struct {
// contains filtered or unexported fields
}
TaskNode is the unit of a flow, be used to connect driver and execute the function through the driver
func (*TaskNode) Driver ¶
func (n *TaskNode) Driver() functiondriver.Driver
func (*TaskNode) FormatString ¶
func (*TaskNode) IgnoreFailure ¶
func (*TaskNode) RetryOnFailure ¶
Click to show internal directories.
Click to hide internal directories.