Documentation
¶
Index ¶
- func CreateConsumer(client *pulsar.Client, topic string, sub_name string) *pulsar.Consumer
- func CreateProducer(client *pulsar.Client, topic string) *pulsar.Producer
- func DestroyConsumer(consumer *pulsar.Consumer)
- func InitClient(URL string) *pulsar.Client
- func ReceiveMessage(consumer *pulsar.Consumer) []byte
- func SendMessage(producer *pulsar.Producer, message []byte)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateConsumer ¶
func DestroyConsumer ¶
func InitClient ¶
Default configuration URL: "pulsar://localhost:6650"
func ReceiveMessage ¶
func SendMessage ¶
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.