redis

package
v0.20.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 23, 2024 License: Apache-2.0 Imports: 5 Imported by: 0

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) Destroy

func (x *ClientNode) Destroy()

Destroy 销毁组件

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 处理消息

func (*ClientNode) Type

func (x *ClientNode) Type() string

Type 返回组件类型

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL