Documentation ¶
Index ¶
- Variables
- func Subscribe(subject string, cb nats.MsgHandler)
- type NatsConsumer
- type NatsMq
- func (n *NatsMq) Publish(subject string, content interface{}) error
- func (n *NatsMq) QueueSubscribe(subject string, queue string, cb nats.MsgHandler)
- func (n *NatsMq) Reply(subject string, fun func() interface{})
- func (n *NatsMq) ReplyWithPara(subject string, fun func(m *nats.Msg) interface{})
- func (n *NatsMq) Request(subject string, content interface{}, timeout time.Duration, v any) error
- func (n *NatsMq) Subscribe(subject string, cb nats.MsgHandler)
- type NatsProducer
- type NatsSubscribeInfo
Constants ¶
This section is empty.
Variables ¶
View Source
var Conn *nats.Conn
Functions ¶
Types ¶
type NatsConsumer ¶
type NatsConsumer struct { Conn *nats.Conn // contains filtered or unexported fields }
func (*NatsConsumer) QueueSubscribe ¶
func (n *NatsConsumer) QueueSubscribe(subject string, queue string, cb nats.MsgHandler)
func (*NatsConsumer) Subscribe ¶
func (n *NatsConsumer) Subscribe(subject string, cb nats.MsgHandler)
type NatsMq ¶
type NatsMq struct {
// contains filtered or unexported fields
}
func (*NatsMq) QueueSubscribe ¶
func (*NatsMq) ReplyWithPara ¶
type NatsProducer ¶
type NatsProducer struct {
Conn *nats.Conn
}
func (*NatsProducer) Publish ¶
func (n *NatsProducer) Publish(subject string, content interface{}) error
type NatsSubscribeInfo ¶
type NatsSubscribeInfo struct {
// contains filtered or unexported fields
}
Click to show internal directories.
Click to hide internal directories.