nats

Documentation

Index

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

Types

type ClientNode

type ClientNode struct {
	base.SharedNode[*nats.Conn]
	// 节点配置
	Config ClientNodeConfiguration
	// contains filtered or unexported fields
}

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 {
	// NATS服务器地址
	Server string
	// NATS用户名
	Username string
	// NATS密码
	Password string
	// 发布主题
	Topic string
}