Documentation
¶
Index ¶
- func InitClient(clusterId, natsUrl string) stan.Conn
- func InitOneClient(clusterId, natsUrl, clientId string) stan.Conn
- func Pub(subject string, msg []byte) error
- func Subscribe(subject string, callback func(m *stan.Msg))
- func SubscribeDurable(subject, durableName string, callback func(m *stan.Msg)) *stan.Subscription
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func InitClient ¶
func InitOneClient ¶
func SubscribeDurable ¶
func SubscribeDurable(subject, durableName string, callback func(m *stan.Msg)) *stan.Subscription
SubscribeDurable 持久化订阅
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.