mosquitto

Documentation

Index

• type Connection
  • func New(config *MqttConfig) (*Connection, error)
  • func (conn *Connection) InsertDiscoveryRecord(discovery string, state string, fields []ports.DiscoveryField) error
  • func (conn *Connection) InsertRecord(m ports.MeasurementMap) error
  • func (conn *Connection) Subscribe(topic string, callback mqtt.MessageHandler)
• type MqttConfig

Types

type Connection

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

func New

func New(config *MqttConfig) (*Connection, error)

func (*Connection) InsertDiscoveryRecord

func (conn *Connection) InsertDiscoveryRecord(discovery string, state string, fields []ports.DiscoveryField) error

MQTT Discovery: https://www.home-assistant.io/integrations/mqtt/#mqtt-discovery

func (*Connection) InsertRecord

func (conn *Connection) InsertRecord(m ports.MeasurementMap) error

func (*Connection) Subscribe

func (conn *Connection) Subscribe(topic string, callback mqtt.MessageHandler)

type MqttConfig

type MqttConfig struct {
	Url       string  `yaml:"url"`
	User      string  `yaml:"user"`
	Password  string  `yaml:"password"`
	Discovery *string `yaml:"ha_discovery_prefix,omitempty"`
	Prefix    string  `yaml:"prefix"`
}