Versions in this module Expand all Collapse all v0 v0.3.0 Nov 25, 2022 Changes in this version + type Client struct + Client pulsar.Client + Producer pulsar.Producer + func (client *Client) Init(configFilePath string, topic string) (err error) + func (client *Client) Receive(ctx context.Context, consumer pulsar.Consumer, msg any) (err error) + func (client *Client) Send(ctx context.Context, msg any) (msgId pulsar.MessageID, err error)