Documentation ¶
Index ¶
- type Aggregator
- type Definitor
- type ExecResult
- type ExecutionOptions
- type Executor
- type Flow
- func (f *Flow) Edge(src, dst string) error
- func (f *Flow) GetResult(sessID string) (map[string]*ExecResult, error)
- func (f *Flow) Node(name string, fn NodeFunc, opts ...Option) error
- func (f *Flow) Register(mux *asynq.ServeMux)
- func (f *Flow) Submit(body []byte) (string, error)
- func (f *Flow) SwitchNode(name string, condFn SwitchCondFunc, cases map[string]NodeFunc, opts ...Option) error
- type ForEach
- type Forwarder
- type FuncErrorHandler
- type NodeFunc
- type Option
- type SwitchCondFunc
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Aggregator ¶
Aggregator definition for the data aggregator of nodes
type ExecResult ¶
type ExecutionOptions ¶
type ExecutionOptions struct {
// contains filtered or unexported fields
}
type Executor ¶
type FuncErrorHandler ¶
type Option ¶
type Option func(*ExecutionOptions)
func WithAggregator ¶
func WithAggregator(agg Aggregator) Option
func WithFailureHandler ¶
func WithFailureHandler(fn FuncErrorHandler) Option
type SwitchCondFunc ¶
Click to show internal directories.
Click to hide internal directories.