Versions in this module Expand all Collapse all v1 v1.0.1 Jun 6, 2021 v1.0.0 Jun 6, 2021 Changes in this version + func NewClient(opts *mqtt.ClientOptions) mqtt.Client + func NewClientWithOptions(opts map[string]*mqtt.ClientOptions) mqtt.Client + type Client struct + Clients map[string]mqtt.Client + func (*Client) OptionsReader() mqtt.ClientOptionsReader + func (c *Client) AddRoute(topic string, callback mqtt.MessageHandler) + func (c *Client) Connect() mqtt.Token + func (c *Client) Disconnect(quiesce uint) + func (c *Client) IsConnected() bool + func (c *Client) IsConnectionOpen() bool + func (c *Client) Publish(topic string, qos byte, retained bool, payload interface{}) mqtt.Token + func (c *Client) Subscribe(topic string, qos byte, callback mqtt.MessageHandler) mqtt.Token + func (c *Client) SubscribeMultiple(filters map[string]byte, callback mqtt.MessageHandler) mqtt.Token + func (c *Client) Unsubscribe(topics ...string) mqtt.Token