Documentation
¶
Index ¶
- func ClosePulsarClient()
- func InitPulsarClient()
- func ReceivePulsarMqMessage(pulsarOptions pulsar.ConsumerOptions, f func(message pulsar.Message), ...)
- func ReceivePulsarMqMixMessage(pulsarOptions pulsar.ConsumerOptions, f func(message pulsar.Message), ...)
- func SendPulsarMqMessage(pulsarOptions pulsar.ProducerOptions, message pulsar.ProducerMessage) (pulsar.MessageID, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ClosePulsarClient ¶
func ClosePulsarClient()
func InitPulsarClient ¶
func InitPulsarClient()
func ReceivePulsarMqMessage ¶
func ReceivePulsarMqMessage(pulsarOptions pulsar.ConsumerOptions, f func(message pulsar.Message), stopChan chan error)
ReceivePulsarMqMessage 出现 func 顺序执行 同步执行
func ReceivePulsarMqMixMessage ¶ added in v0.0.37
func ReceivePulsarMqMixMessage(pulsarOptions pulsar.ConsumerOptions, f func(message pulsar.Message), stopChan chan error, pool *ants.Pool)
ReceivePulsarMqMixMessage 出现 执行func 无序 异步执行
func SendPulsarMqMessage ¶
func SendPulsarMqMessage(pulsarOptions pulsar.ProducerOptions, message pulsar.ProducerMessage) (pulsar.MessageID, error)
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.