flow

Documentation

Index

• Variables
• type ChainNode
  • func (x *ChainNode) Destroy()
  • func (x *ChainNode) Init(ruleConfig types.Config, configuration types.Configuration) error
  • func (x *ChainNode) New() types.Node
  • func (x *ChainNode) OnMsg(ctx types.RuleContext, msg types.RuleMsg)
  • func (x *ChainNode) Type() string
• type ChainNodeConfiguration

Variables

var Registry = &types.SafeComponentSlice{}

Types

type ChainNode

type ChainNode struct {
	//节点配置
	Config ChainNodeConfiguration
}

ChainNode 子规则链 如果找不到规则链，则把消息通过`Failure`关系发送到下一个节点 子规则链所有分支执行完后，把每个结束节点处理的消息合后通过`Success`关系发送到下一个节点。消息格式：[]WrapperMsg

func (*ChainNode) Destroy

func (x *ChainNode) Destroy()

Destroy 销毁

func (*ChainNode) Init

func (x *ChainNode) Init(ruleConfig types.Config, configuration types.Configuration) error

Init 初始化

func (*ChainNode) New

func (x *ChainNode) New() types.Node

func (*ChainNode) OnMsg

func (x *ChainNode) OnMsg(ctx types.RuleContext, msg types.RuleMsg)

OnMsg 处理消息

func (*ChainNode) Type

func (x *ChainNode) Type() string

Type 组件类型

type ChainNodeConfiguration

type ChainNodeConfiguration struct {
	//TargetId 子规则链ID
	TargetId string
}

ChainNodeConfiguration 节点配置