pulsarclient

README

pulsar

Documentation

Index

• type Client
  • 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)

Types

type Client

type Client struct {
	Client   pulsar.Client
	Producer pulsar.Producer
}

func (*Client) Init

func (client *Client) Init(configFilePath string, topic string) (err error)

func (*Client) Receive

func (client *Client) Receive(ctx context.Context, consumer pulsar.Consumer, msg any) (err error)

func (*Client) Send

func (client *Client) Send(ctx context.Context, msg any) (msgId pulsar.MessageID, err error)