activity

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
  • func (b ActiveBoundaryTrace) TraceInterface()
• type Activity
• type Constructor
• type DoOption
  • func WithErr(err error) DoOption
  • func WithErrHandle(err error, ch <-chan flow_node.ErrHandler) DoOption
  • func WithObjects(dataObjects map[string]any) DoOption
  • func WithProperties(properties map[string]any) DoOption
  • func WithValue(key, value any) DoOption
• type DoResponse
• type Harness
  • func NewHarness(ctx context.Context, wiring *flow_node.Wiring, element *schema.FlowNode, ...) (node *Harness, err error)
  • 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)
• type Trace
  • func (t *Trace) Context() context.Context
  • func (t *Trace) Do(options ...DoOption)
  • func (t *Trace) GetActivity() Activity
  • func (t *Trace) GetDataObjects() map[string]any
  • func (t *Trace) GetHeaders() map[string]any
  • func (t *Trace) GetProperties() map[string]any
  • func (t *Trace) TraceInterface()
• type TraceBuilder
  • func NewTraceBuilder() *TraceBuilder
  • func (b *TraceBuilder) Activity(activity Activity) *TraceBuilder
  • func (b *TraceBuilder) Build() *Trace
  • func (b *TraceBuilder) Context(ctx context.Context) *TraceBuilder
  • func (b *TraceBuilder) DataObjects(dataObjects map[string]any) *TraceBuilder
  • func (b *TraceBuilder) Headers(headers map[string]any) *TraceBuilder
  • func (b *TraceBuilder) Properties(properties map[string]any) *TraceBuilder
  • func (b *TraceBuilder) Response(ch chan DoResponse) *TraceBuilder
  • func (b *TraceBuilder) Value(key, value any) *TraceBuilder
• type Type

Functions

func ApplyTaskDataOutput

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

func FetchTaskDataInput

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 Activity

type Activity interface {
	flow_node.IFlowNode
	Type() Type
	// 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 DoOption

type DoOption func(*DoResponse)

func WithErr

func WithErr(err error) DoOption

func WithErrHandle

func WithErrHandle(err error, ch <-chan flow_node.ErrHandler) DoOption

func WithObjects

func WithObjects(dataObjects map[string]any) DoOption

func WithProperties

func WithProperties(properties map[string]any) DoOption

func WithValue

func WithValue(key, value any) DoOption

type DoResponse

type DoResponse struct {
	Context     context.Context
	DataObjects map[string]any
	Properties  map[string]any
	Err         error
	HandlerCh   <-chan flow_node.ErrHandler
}

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)

type Trace

type Trace struct {
	// contains filtered or unexported fields
}

Trace describes common channel handler for all tasks

func (*Trace) Context

func (t *Trace) Context() context.Context

func (*Trace) Do

func (t *Trace) Do(options ...DoOption)

func (*Trace) GetActivity

func (t *Trace) GetActivity() Activity

func (*Trace) GetDataObjects

func (t *Trace) GetDataObjects() map[string]any

func (*Trace) GetHeaders

func (t *Trace) GetHeaders() map[string]any

func (*Trace) GetProperties

func (t *Trace) GetProperties() map[string]any

func (*Trace) TraceInterface

func (t *Trace) TraceInterface()

type TraceBuilder

type TraceBuilder struct {
	// contains filtered or unexported fields
}

func NewTraceBuilder

func NewTraceBuilder() *TraceBuilder

func (*TraceBuilder) Activity

func (b *TraceBuilder) Activity(activity Activity) *TraceBuilder

func (*TraceBuilder) Build

func (b *TraceBuilder) Build() *Trace

func (*TraceBuilder) Context

func (b *TraceBuilder) Context(ctx context.Context) *TraceBuilder

func (*TraceBuilder) DataObjects

func (b *TraceBuilder) DataObjects(dataObjects map[string]any) *TraceBuilder

func (*TraceBuilder) Headers

func (b *TraceBuilder) Headers(headers map[string]any) *TraceBuilder

func (*TraceBuilder) Properties

func (b *TraceBuilder) Properties(properties map[string]any) *TraceBuilder

func (*TraceBuilder) Response

func (b *TraceBuilder) Response(ch chan DoResponse) *TraceBuilder

func (*TraceBuilder) Value

func (b *TraceBuilder) Value(key, value any) *TraceBuilder

type Type

type Type string

const (
	TaskType         Type = "Task"
	ServiceType      Type = "ServiceTask"
	ScriptType       Type = "ScriptTask"
	UserType         Type = "UserTask"
	CallType         Type = "CallActivity"
	BusinessRuleType Type = "BusinessRuleTask"
	SendType         Type = "SendTask"
	ReceiveType      Type = "ReceiveTask"
	SubprocessType   Type = "Subprocess"
)