base

func (*BaseNode) Cleanup ¶

func (node *BaseNode) Cleanup() error

is invoked when node flow is stopped

func (*BaseNode) ConnectorRegistry ¶

func (node *BaseNode) ConnectorRegistry() *connector.Registry

func (*BaseNode) Ctx ¶

func (node *BaseNode) Ctx() *model.Context

func (*BaseNode) FlowOpCtx ¶

func (node *BaseNode) FlowOpCtx() *model.FlowOperationalContext

func (*BaseNode) FlowRunner ¶

func (node *BaseNode) FlowRunner() model.FlowRunner

func (*BaseNode) GetLog ¶

func (node *BaseNode) GetLog() *log.Entry

func (*BaseNode) GetMetaNode ¶

func (node *BaseNode) GetMetaNode() *model.MetaNode

func (*BaseNode) GetNextErrorNode ¶

func (node *BaseNode) GetNextErrorNode() model.NodeID

func (*BaseNode) GetNextSuccessNodes ¶

func (node *BaseNode) GetNextSuccessNodes() []model.NodeID

func (*BaseNode) GetNextTimeoutNode ¶

func (node *BaseNode) GetNextTimeoutNode() model.NodeID

func (*BaseNode) Init ¶

func (node *BaseNode) Init() error

is invoked right before is started but after node was configured

func (*BaseNode) IsMsgReactorNode ¶

func (node *BaseNode) IsMsgReactorNode() bool

func (*BaseNode) IsReactorRunning ¶

func (node *BaseNode) IsReactorRunning() bool

func (*BaseNode) IsStartNode ¶

func (node *BaseNode) IsStartNode() bool

func (*BaseNode) Meta ¶

func (node *BaseNode) Meta() model.MetaNode

func (*BaseNode) SetConnectorRegistry ¶

func (node *BaseNode) SetConnectorRegistry(connectorRegistry *connector.Registry)

func (*BaseNode) SetCtx ¶

func (node *BaseNode) SetCtx(ctx *model.Context)

func (*BaseNode) SetFlowOpCtx ¶

func (node *BaseNode) SetFlowOpCtx(flowOpCtx *model.FlowOperationalContext)

func (*BaseNode) SetFlowRunner ¶

func (node *BaseNode) SetFlowRunner(flowRunner model.FlowRunner)

func (*BaseNode) SetMeta ¶

func (node *BaseNode) SetMeta(meta model.MetaNode)

func (*BaseNode) SetMsgReactorNode ¶

func (node *BaseNode) SetMsgReactorNode(flag bool)

func (*BaseNode) SetReactorRunning ¶

func (node *BaseNode) SetReactorRunning(isReactorRunning bool)

func (*BaseNode) SetStartNode ¶

func (node *BaseNode) SetStartNode(flag bool)

func (*BaseNode) SetupBaseNode ¶

func (node *BaseNode) SetupBaseNode()