activity

package
v0.2.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 21, 2023 License: Apache-2.0 Imports: 13 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ApplyTaskDataOutput added in v0.2.0

func ApplyTaskDataOutput(element schema.BaseElementInterface, dataOutputs map[string]any) map[string]data.IItem

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

type ActiveTaskTrace interface {
	tracing.ITrace
	Execute()
}

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 Constructor

type Constructor = func(*flow_node.Wiring) (node Activity, err error)

type Harness

type Harness struct {
	*flow_node.Wiring
	// contains filtered or unexported fields
}

func NewHarness

func NewHarness(ctx context.Context,
	wiring *flow_node.Wiring,
	element *schema.FlowNode,
	idGenerator id.IGenerator,
	constructor Constructor,
) (node *Harness, err error)

func (*Harness) Activity

func (node *Harness) Activity() Activity

func (*Harness) ConsumeEvent

func (node *Harness) ConsumeEvent(ev event.IEvent) (result event.ConsumptionResult, err error)

func (*Harness) Element

func (node *Harness) Element() schema.FlowNodeInterface

func (*Harness) NextAction

func (node *Harness) NextAction(flow flow_interface.T) chan flow_node.IAction

func (*Harness) RegisterEventConsumer

func (node *Harness) RegisterEventConsumer(consumer event.IConsumer) (err error)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL