mosquitto

Documentation

Index

• type Connection
  • func New(config *MqttConfig) (*Connection, error)
  • func (conn *Connection) InsertGenericRecord(topicName string, measurement map[string]interface{}) error
  • func (conn *Connection) InsertRecord(measurement map[string]interface{}) 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) InsertGenericRecord

func (conn *Connection) InsertGenericRecord(topicName string, measurement map[string]interface{}) error

func (*Connection) InsertRecord

func (conn *Connection) InsertRecord(measurement map[string]interface{}) 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"`
	Prefix   string `yaml:"prefix"`
}