Documentation
¶
Index ¶
- Constants
- type ConnectionStatus
- type Message
- type MqttClient
- func (c *MqttClient) Close() error
- func (c *MqttClient) Connect(host string, port int, username, password string, onCompletion func(error))
- func (c *MqttClient) Incoming() <-chan *Message
- func (c *MqttClient) IsConnected() bool
- func (c *MqttClient) Publish(topic string, qos Qos, retained bool, message []byte, onCompletion func(error))
- func (c *MqttClient) SetConnectionStatusFunc(f func(ConnectionStatus))
- func (c *MqttClient) Subscribe(topic string, qos Qos, onCompletion func(error))
- func (c *MqttClient) Unsubscribe(topic string, onCompletion func(error))
- type Qos
Constants ¶
View Source
const ( StatusConnected = iota StatusDisconnected StatusReconnecting )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConnectionStatus ¶
type ConnectionStatus int
type MqttClient ¶
type MqttClient struct {
// contains filtered or unexported fields
}
func NewMqttClient ¶
func NewMqttClient() *MqttClient
func (*MqttClient) Close ¶
func (c *MqttClient) Close() error
func (*MqttClient) Connect ¶
func (c *MqttClient) Connect(host string, port int, username, password string, onCompletion func(error))
func (*MqttClient) Incoming ¶
func (c *MqttClient) Incoming() <-chan *Message
func (*MqttClient) IsConnected ¶ added in v0.0.4
func (c *MqttClient) IsConnected() bool
func (*MqttClient) SetConnectionStatusFunc ¶
func (c *MqttClient) SetConnectionStatusFunc(f func(ConnectionStatus))
func (*MqttClient) Subscribe ¶
func (c *MqttClient) Subscribe(topic string, qos Qos, onCompletion func(error))
func (*MqttClient) Unsubscribe ¶
func (c *MqttClient) Unsubscribe(topic string, onCompletion func(error))
Source Files
Click to show internal directories.
Click to hide internal directories.