Versions in this module Expand all Collapse all v0 v0.0.1 Sep 12, 2020 Changes in this version + var ErrParsingTopicName = errors.New("failure on parsing topic name to extract meta data") + type MQTT struct + func NewMQTT(opts ...OptionFunc) *MQTT + func (m *MQTT) Connect() (mqtt.Client, error) + func (m *MQTT) Logger() logr.Logger + func (m *MQTT) SetCollector(c collector.Collector) + func (m *MQTT) SetLogger(log logr.Logger) + func (m *MQTT) Subscribe() error + type OptionFunc func(m *MQTT) + func OptionWithAddress(a string) OptionFunc + func OptionWithCollector(c collector.Collector) OptionFunc + func OptionWithLogger(log logr.Logger) OptionFunc + func OptionWithTopics(topics ...string) OptionFunc v0.0.1-ci.2 Sep 12, 2020
Go to main page