Documentation
¶
Index ¶
- func GetNsqProducer(alia string) *nsq.Producer
- func InitNsqConsumer(topic, channel, addr string, config *nsq.Config, fn func(msg []byte) error)
- func InitNsqProducer(alia, addr string, config *nsq.Config) *nsq.Producer
- func InitSimpleNsqConsumer(topic, channel, addr string, fn func(msg []byte) error)
- func InitSimpleNsqProducer(alia, addr string) *nsq.Producer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetNsqProducer ¶
func GetNsqProducer(alia string) *nsq.Producer
func InitNsqConsumer ¶
func InitNsqProducer ¶
func InitNsqProducer(alia, addr string, config *nsq.Config) *nsq.Producer
func InitSimpleNsqConsumer ¶
func InitSimpleNsqProducer ¶
func InitSimpleNsqProducer(alia, addr string) *nsq.Producer
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.