flow_node

type ActionTransformer func(sequenceFlowId *schema.IdRef, action IAction) IAction

type CancellationTrace struct {
	Node schema.FlowNodeInterface
}

type CompleteAction struct{}

type ErrHandleMode int

type ErrHandler struct {
	Model   ErrHandleMode
	Retries int32
}

type FlowAction struct {
	Response *FlowActionResponse

	SequenceFlows []*sequence_flow.SequenceFlow
	// Index of sequence flows that should flow without
	// conditionExpression being evaluated
	UnconditionalFlows []int
	// The actions produced by the targets should be processed by
	// this function
	ActionTransformer ActionTransformer
	// If supplied channel sends a function that returns true, the flow action
	// is to be terminated if it wasn't already
	Terminate Terminate
}

type FlowActionResponse struct {
	DataObjects map[string]data.IItem
	Variables   map[string]data.IItem
	Err         error
	Handler     *ErrHandler
}

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

type IAction interface {
	// contains filtered or unexported methods
}

type IFlowNode interface {
	IOutgoing
	Element() schema.FlowNodeInterface
}

type IOutgoing interface {
	NextAction(flow flow_interface.T) chan IAction
}

type NewFlowNodeTrace struct {
	Node schema.FlowNodeInterface
}

type NoAction struct{}

type ProbeAction struct {
	SequenceFlows []*sequence_flow.SequenceFlow
	// ProbeReport is a function that needs to be called
	// wth sequence flow indices that have successful
	// condition expressions (or none)
	ProbeReport func([]int)
}

type Terminate func(sequenceFlowId *schema.IdRef) chan bool

type Wiring struct {
	ProcessInstanceId              id.Id
	FlowNodeId                     schema.Id
	Definitions                    *schema.Definitions
	Incoming                       []sequence_flow.SequenceFlow
	Outgoing                       []sequence_flow.SequenceFlow
	EventIngress                   event.IConsumer
	EventEgress                    event.ISource
	Tracer                         tracing.ITracer
	Process                        schema.Element
	FlowNodeMapping                *FlowNodeMapping
	FlowWaitGroup                  *sync.WaitGroup
	EventDefinitionInstanceBuilder event.IDefinitionInstanceBuilder
	Locator                        data.IFlowDataLocator
}