start

Documentation

Index

• type Node
  • func New(ctx context.Context, wiring *flow_node.Wiring, startEvent *schema.StartEvent, ...) (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
  • func (node *Node) Trigger()

Types

type Node

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

func New

func New(ctx context.Context, wiring *flow_node.Wiring,
	startEvent *schema.StartEvent, idGenerator id.IGenerator,
) (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

func (*Node) Trigger

func (node *Node) Trigger()