catch

Documentation

Index

• type ActiveListeningTrace
  • func (t ActiveListeningTrace) TraceInterface()
• type EventObservedTrace
  • func (t EventObservedTrace) TraceInterface()
• type Node
  • func New(ctx context.Context, wiring *flow_node.Wiring, catchEvent *schema.CatchEvent) (node *Node, err error)
  • func (node *Node) ConsumeEvent(ev event.IEvent) (result event.ConsumptionResult, err error)
  • func (node *Node) Element() schema.FlowNodeInterface
  • func (node *Node) NextAction(flow_interface.T) chan flow_node.IAction

Types

type ActiveListeningTrace

type ActiveListeningTrace struct {
	Node *schema.CatchEvent
}

func (ActiveListeningTrace) TraceInterface

func (t ActiveListeningTrace) TraceInterface()

type EventObservedTrace

type EventObservedTrace struct {
	Node  *schema.CatchEvent
	Event event.IEvent
}

EventObservedTrace signals the fact that a particular event has been in fact observed by the node

func (EventObservedTrace) TraceInterface

func (t EventObservedTrace) TraceInterface()

type Node

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

func New

func New(ctx context.Context, wiring *flow_node.Wiring, catchEvent *schema.CatchEvent) (node *Node, err error)

func (*Node) ConsumeEvent

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

func (*Node) Element

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

func (*Node) NextAction

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