Documentation
¶
Index ¶
- func GetMsgChannel() chan *nats.Msg
- func HandleMsg(msg *nats.Msg) error
- func Publish(subject string, api NatsMsgApi, data []byte) error
- func RegisterMsgHandler(api NatsMsgApi, handler NatsMsgHandler)
- func Start(name, user, passwd string, serverList []string)
- func Stop()
- func Subscribe(subject string) error
- type NatsClient
- func (this *NatsClient) Close()
- func (this *NatsClient) HandleMsg(msg *nats.Msg) error
- func (this *NatsClient) Publish(subject string, api NatsMsgApi, data interface{}) error
- func (this *NatsClient) RegisterMsgHandler(api NatsMsgApi, handler NatsMsgHandler)
- func (this *NatsClient) Subscribe(subject string) error
- type NatsMsgApi
- type NatsMsgData
- type NatsMsgHandler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetMsgChannel ¶
func GetMsgChannel() chan *nats.Msg
func RegisterMsgHandler ¶
func RegisterMsgHandler(api NatsMsgApi, handler NatsMsgHandler)
Types ¶
type NatsClient ¶
type NatsClient struct {
MsgChannel chan *nats.Msg
// contains filtered or unexported fields
}
func NewNatsClient ¶
func NewNatsClient(name, user, passwd string, serverList []string) *NatsClient
func (*NatsClient) Close ¶
func (this *NatsClient) Close()
func (*NatsClient) HandleMsg ¶
func (this *NatsClient) HandleMsg(msg *nats.Msg) error
func (*NatsClient) Publish ¶
func (this *NatsClient) Publish(subject string, api NatsMsgApi, data interface{}) error
func (*NatsClient) RegisterMsgHandler ¶
func (this *NatsClient) RegisterMsgHandler(api NatsMsgApi, handler NatsMsgHandler)
func (*NatsClient) Subscribe ¶
func (this *NatsClient) Subscribe(subject string) error
type NatsMsgData ¶
type NatsMsgData struct {
Api NatsMsgApi
Data interface{}
}
type NatsMsgHandler ¶
type NatsMsgHandler func(*NatsMsgData) error
Source Files
Click to show internal directories.
Click to hide internal directories.