Documentation
¶
Index ¶
- type MqttClient
- func (m *MqttClient) Publish(topic string, payload interface{}, qos byte, retained bool) error
- func (m *MqttClient) PublishRetain(topic string, payload interface{}) error
- func (m *MqttClient) Run(ctx context.Context) error
- func (m *MqttClient) Subscribe(topic string, qos byte) (<-chan *MqttMessage, error)
- func (m *MqttClient) SubscribeMultiple(topics []string, qos byte) (<-chan *MqttMessage, error)
- type MqttMessage
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MqttClient ¶
type MqttClient struct {
Broker string
User string
Password string
CleanSession bool
Clientid string
// contains filtered or unexported fields
}
func NewMqttClient ¶
func NewMqttClient(cfg interface{}) (*MqttClient, error)
func (*MqttClient) Publish ¶
func (m *MqttClient) Publish(topic string, payload interface{}, qos byte, retained bool) error
func (*MqttClient) PublishRetain ¶
func (m *MqttClient) PublishRetain(topic string, payload interface{}) error
PublishRetain is simplified version of Publish intended to use by sensors
func (*MqttClient) Subscribe ¶
func (m *MqttClient) Subscribe(topic string, qos byte) (<-chan *MqttMessage, error)
func (*MqttClient) SubscribeMultiple ¶
func (m *MqttClient) SubscribeMultiple(topics []string, qos byte) (<-chan *MqttMessage, error)
type MqttMessage ¶
Source Files
Click to show internal directories.
Click to hide internal directories.