mqttclient

Documentation

Index

• type MqttClient
  • func NewMqttClient(host string, port int, user, password string, client_id string) *MqttClient
  • func (mc *MqttClient) Connect() error
  • func (mc *MqttClient) SendCommand(topic, payload string) error
  • func (mc *MqttClient) Subscribe(topic string, callback mqtt.MessageHandler) error

Types

type MqttClient

type MqttClient struct {
	// contains filtered or unexported fields
}

func NewMqttClient

func NewMqttClient(host string, port int, user, password string, client_id string) *MqttClient

func (*MqttClient) Connect

func (mc *MqttClient) Connect() error

func (*MqttClient) SendCommand

func (mc *MqttClient) SendCommand(topic, payload string) error

func (*MqttClient) Subscribe

func (mc *MqttClient) Subscribe(topic string, callback mqtt.MessageHandler) error