subprocess

Documentation

Index

• func New(ctx context.Context, eventDefinitionBuilder event.IDefinitionInstanceBuilder, ...) activity.Constructor
• type ProcessLandMarkTrace
  • func (i ProcessLandMarkTrace) TraceInterface()
• type SubProcess
  • func (p *SubProcess) Cancel() <-chan bool
  • func (p *SubProcess) ConsumeEvent(ev event.IEvent) (result event.ConsumptionResult, err error)
  • func (p *SubProcess) Element() schema.FlowNodeInterface
  • func (p *SubProcess) NextAction(flow_interface.T) chan flow_node.IAction
  • func (p *SubProcess) RegisterEventConsumer(ev event.IConsumer) (err error)
  • func (p *SubProcess) Type() activity.Type

Functions

func New

func New(ctx context.Context,
	eventDefinitionBuilder event.IDefinitionInstanceBuilder,
	idGenerator id.IGenerator,
	tracer tracing.ITracer,
	subProcess *schema.SubProcess) activity.Constructor

Types

type ProcessLandMarkTrace

type ProcessLandMarkTrace struct {
	Node schema.FlowNodeInterface
}

ProcessLandMarkTrace denotes instantiation of a given sub process

func (ProcessLandMarkTrace) TraceInterface

func (i ProcessLandMarkTrace) TraceInterface()

type SubProcess

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

func (*SubProcess) Cancel

func (p *SubProcess) Cancel() <-chan bool

func (*SubProcess) ConsumeEvent

func (p *SubProcess) ConsumeEvent(ev event.IEvent) (result event.ConsumptionResult, err error)

func (*SubProcess) Element

func (p *SubProcess) Element() schema.FlowNodeInterface

func (*SubProcess) NextAction

func (p *SubProcess) NextAction(flow_interface.T) chan flow_node.IAction

func (*SubProcess) RegisterEventConsumer

func (p *SubProcess) RegisterEventConsumer(ev event.IConsumer) (err error)

func (*SubProcess) Type

func (p *SubProcess) Type() activity.Type