Documentation
¶
Index ¶
- func ApplyTaskDataOutput(element schema.BaseElementInterface, dataOutputs map[string]any) map[string]data.IItem
- func FetchTaskDataInput(locator data.IFlowDataLocator, element schema.BaseElementInterface) (headers, dataSets, dataObjects map[string]any)
- type ActiveBoundaryTrace
- type ActiveTaskTrace
- type Activity
- type Constructor
- type Harness
- func (node *Harness) Activity() Activity
- func (node *Harness) ConsumeEvent(ev event.IEvent) (result event.ConsumptionResult, err error)
- func (node *Harness) Element() schema.FlowNodeInterface
- func (node *Harness) NextAction(flow flow_interface.T) chan flow_node.IAction
- func (node *Harness) RegisterEventConsumer(consumer event.IConsumer) (err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ApplyTaskDataOutput ¶ added in v0.2.0
func FetchTaskDataInput ¶ added in v0.2.0
func FetchTaskDataInput(locator data.IFlowDataLocator, element schema.BaseElementInterface) (headers, dataSets, dataObjects map[string]any)
Types ¶
type ActiveBoundaryTrace ¶
type ActiveBoundaryTrace struct { Start bool Node schema.FlowNodeInterface }
func (ActiveBoundaryTrace) TraceInterface ¶
func (b ActiveBoundaryTrace) TraceInterface()
type ActiveTaskTrace ¶
ActiveTaskTrace describes common channel handler for all tasks
type Activity ¶
type Activity interface { flow_node.IFlowNode // Cancel initiates a cancellation of activity and returns a channel // that will signal a boolean (`true` if cancellation was successful, // `false` otherwise) Cancel() <-chan bool }
Activity is a generic interface to flow nodes that are activities
type Harness ¶
func NewHarness ¶
func (*Harness) ConsumeEvent ¶
func (*Harness) Element ¶
func (node *Harness) Element() schema.FlowNodeInterface
func (*Harness) NextAction ¶
func (node *Harness) NextAction(flow flow_interface.T) chan flow_node.IAction
Click to show internal directories.
Click to hide internal directories.