mqttClient

Documentation

Index

• Constants
• type Config
• type MqttClient
  • func Run(config Config, statistics Statistics) (*MqttClient, error)
  • func (mq *MqttClient) Name() string
  • func (mq *MqttClient) Shutdown()
  • func (mq *MqttClient) Subscribe(topic string, callback mqtt.MessageHandler) error
• type Statistics

Constants

const (
	OfflinePayload string = "Offline"
	OnlinePayload  string = "Online"
)

Types

type Config

type Config interface {
	Name() string
	Broker() string
	User() string
	Password() string
	ClientId() string
	Qos() byte
	AvailabilityTopic() string
	TopicPrefix() string
	LogMessages() bool
}

type MqttClient

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

func Run

func Run(config Config, statistics Statistics) (*MqttClient, error)

func (*MqttClient) Name

func (mq *MqttClient) Name() string

func (*MqttClient) Shutdown

func (mq *MqttClient) Shutdown()

func (*MqttClient) Subscribe

func (mq *MqttClient) Subscribe(topic string, callback mqtt.MessageHandler) error

type Statistics

type Statistics interface {
	IncrementOne(module, name, field string)
}