Documentation ¶
Index ¶
- func New(ctx context.Context, eventDefinitionBuilder event.IDefinitionInstanceBuilder, ...) activity.Constructor
- type ProcessLandMarkTrace
- 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 ¶
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)
Click to show internal directories.
Click to hide internal directories.