mqtt

Documentation

Index

• type Config
• type MQTT
  • func New(cfg Config) *MQTT
  • func (m *MQTT) Connect() error
  • func (m *MQTT) Disconnect()
  • func (m *MQTT) Subscribe(topic string)
• type Publish

Types

type Config

type Config struct {
	Host string
	Port string
	User string
	Pass string
	CID  string
}

type MQTT

type MQTT struct {
	Config
	Messages chan Publish
	// contains filtered or unexported fields
}

func New

func New(cfg Config) *MQTT

func (*MQTT) Connect

func (m *MQTT) Connect() error

func (*MQTT) Disconnect

func (m *MQTT) Disconnect()

func (*MQTT) Subscribe

func (m *MQTT) Subscribe(topic string)

type Publish

type Publish struct {
	Topic string
	ID    uint16
	Msg   string
}