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
• type RefNode
  • func (x *RefNode) Destroy()
  • func (x *RefNode) Init(ruleConfig types.Config, configuration types.Configuration) error
  • func (x *RefNode) New() types.Node
  • func (x *RefNode) OnMsg(ctx types.RuleContext, msg types.RuleMsg)
  • func (x *RefNode) Type() string
• type RefNodeConfiguration

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 节点配置

type RefNode

type RefNode struct {
	//节点配置
	Config RefNodeConfiguration
	// contains filtered or unexported fields
}

RefNode 引用指定规则链或者当前规则链节点，用于节点复用 格式：[{chainId}]:{nodeId}，如果是引入本规则链，则格式为：{nodeId} 执行成功则使用该节点的输出关系发送到下一个节点 如果找不到节点，则把消息通过`Failure`关系发送到下一个节点

func (*RefNode) Destroy

func (x *RefNode) Destroy()

Destroy 销毁

func (*RefNode) Init

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

Init 初始化

func (*RefNode) New

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

func (*RefNode) OnMsg

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

OnMsg 处理消息

func (*RefNode) Type

func (x *RefNode) Type() string

Type 组件类型

type RefNodeConfiguration

type RefNodeConfiguration struct {
	//TargetId 节点ID，
	TargetId string
}

RefNodeConfiguration 节点配置