transform

Documentation

Index

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

Variables

var Registry = &types.SafeComponentSlice{}

Types

type JsTransformNode

type JsTransformNode struct {
	// contains filtered or unexported fields
}

JsTransformNode 使用JavaScript更改消息metadata，msg或msgType JavaScript 函数接收3个参数： metadata:是消息的 metadata msg:是消息的payload msgType:是消息的 type 法返回结构:return {'msg':msg,'metadata':metadata,'msgType':msgType}; 脚本执行成功，发送信息到`Success`链, 否则发到`Failure`链。

func (*JsTransformNode) Destroy

func (x *JsTransformNode) Destroy()

Destroy 销毁

func (*JsTransformNode) Init

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

Init 初始化

func (*JsTransformNode) New

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

func (*JsTransformNode) OnMsg

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

OnMsg 处理消息

func (*JsTransformNode) Type

func (x *JsTransformNode) Type() string

Type 组件类型

type JsTransformNodeConfiguration

type JsTransformNodeConfiguration struct {
	//JsScript 配置函数体脚本内容
	//对msg、metadata、msgType 进行转换、增强
	//完整脚本函数：
	//function Transform(msg, metadata, msgType) { ${JsScript} }
	//return {'msg':msg,'metadata':metadata,'msgType':msgType};
	JsScript string
}

JsTransformNodeConfiguration 节点配置