mqtt

Documentation

Index

• type Mqtt
  • func NewMqttClient(logger logger.Logger) *Mqtt
  • func (m *Mqtt) Connect()
  • func (m *Mqtt) Create(broker string, client_id string)
  • func (m *Mqtt) Disconnect()
  • func (m *Mqtt) Publish(topic string, message string)
  • func (m *Mqtt) Subscribe(topic string, callback func(MQTT.Client, MQTT.Message))

Types

type Mqtt

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

func NewMqttClient

func NewMqttClient(logger logger.Logger) *Mqtt

func (*Mqtt) Connect

func (m *Mqtt) Connect()

func (*Mqtt) Create

func (m *Mqtt) Create(broker string, client_id string)

func (*Mqtt) Disconnect

func (m *Mqtt) Disconnect()

func (*Mqtt) Publish

func (m *Mqtt) Publish(topic string, message string)

func (*Mqtt) Subscribe

func (m *Mqtt) Subscribe(topic string, callback func(MQTT.Client, MQTT.Message))