Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClientNode ¶
type ClientNode struct { //节点配置 Config ClientNodeConfiguration // contains filtered or unexported fields }
ClientNode redis客户端节点, 成功:转向Success链,redis执行结果存放在msg.Data 失败:转向Failure链
func (*ClientNode) Init ¶
func (x *ClientNode) Init(ruleConfig types.Config, configuration types.Configuration) error
Init 初始化组件
func (*ClientNode) New ¶
func (x *ClientNode) New() types.Node
func (*ClientNode) OnMsg ¶
func (x *ClientNode) OnMsg(ctx types.RuleContext, msg types.RuleMsg)
OnMsg 处理消息
type ClientNodeConfiguration ¶
type ClientNodeConfiguration struct { // Server redis服务器地址 Server string // PoolSize 连接池大小 PoolSize int // Cmd 执行命令,例如SET/GET/DEL // 可以使用${}占位符读取metadata元数据 // 支持${msg.data}获取消息负荷,${msg.type}获取消息类型 Cmd string // Params 执行命令参数 // 可以使用${}占位符读取metadata元数据 // 支持${msg.data}获取消息负荷,${msg.type}获取消息类型 Params []interface{} }
ClientNodeConfiguration 节点配置
Click to show internal directories.
Click to hide internal directories.