Versions in this module Expand all Collapse all v0 v0.0.1 Aug 13, 2022 Changes in this version + type Client struct + func NewClient(addrs []string, username, password string) (*Client, error) + func (c *Client) GetChannelStatus() (int, int) + func (c *Client) SendMessageAsync(msg *Message) + func (c *Client) SendMessageSync(msg *Message) error + func (c *Client) StartSendingMessage(sendGoroutineCount, channelSize int, logger *zap.Logger) + func (c *Client) StopSendingMessage() + type Message struct + Topic string + Value []byte