mqtt

Documentation

Index

• type Broker
  • func NewBroker(uri string) Broker
• type Conn
• type MQTTClientConfig

Types

type Broker

type Broker interface {
	Dial(clientId string, statusTopic string) (Conn, error)
}

func NewBroker

func NewBroker(uri string) Broker

type Conn

type Conn interface {
	io.Closer
	Publish(topic string, payload string)
	PublishRetain(topic string, payload string)
	Subscribe(topic string, cb func(topic string, payload string))
}

type MQTTClientConfig

type MQTTClientConfig struct {
	URI      string `yaml:"uri"`
	ClientID string `yaml:"client_id"`
}