natsx

Jan 3, 2023

Changes in this version

+ const DefaultNatsServer

+ const DefaultNatsServerIp

+ const DefaultNatsServerPort

+ type HFunc func(topic, reply string, data []byte)

+ type NatsClient struct

+ func NewNatsClient(addr string) *NatsClient

+ func (c *NatsClient) AddTopic(topic string, hFunc HFunc)

+ func (c *NatsClient) AddTopics(topics map[string]HFunc)

+ func (c *NatsClient) Push(topic string, param *NatsMessage) error

+ func (c *NatsClient) Push2(topic string, param interface{}) error

+ func (c *NatsClient) Request(topic string, param *NatsMessage) (*NatsMessageRsp, error)

+ func (c *NatsClient) Response(topic string, param *NatsMessageRsp) error

+ func (c *NatsClient) Start()

+ func (c *NatsClient) Subscribe(topic string, h HFunc)

+ type NatsMessage struct

+ Data interface{}

+ ObjID int

+ Operation int

+ ProID int

+ ReqCode int

+ type NatsMessageRsp struct

+ Data interface{}

+ ErrMsg string

+ ObjId int

+ Operation int

+ ProID int

+ ReqCode int

+ ResCode int