Documentation ¶ Index ¶ type Client func New(mqttBroker, clientID string) *Client func (client *Client) ConnectBroker() error func (client *Client) PublishMessage(topic string, message []byte, qos uint8, retain bool) error func (client *Client) Subscribe(topic string, qos byte, callback mqtt.MessageHandler) error Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type Client ¶ type Client struct { MqttClient mqtt.Client // contains filtered or unexported fields } func New ¶ func New(mqttBroker, clientID string) *Client func (*Client) ConnectBroker ¶ func (client *Client) ConnectBroker() error func (*Client) PublishMessage ¶ func (client *Client) PublishMessage(topic string, message []byte, qos uint8, retain bool) error func (*Client) Subscribe ¶ func (client *Client) Subscribe(topic string, qos byte, callback mqtt.MessageHandler) error Source Files ¶ View all Source files client.go Click to show internal directories. Click to hide internal directories.