Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrParsingTopicName is error emit when parsing of topic failed ErrParsingTopicName = errors.New("failure on parsing topic name to extract meta data") )
Functions ¶
This section is empty.
Types ¶
type MQTT ¶
type MQTT struct {
// contains filtered or unexported fields
}
MQTT is a concrete implementation of Subscriber that using underlying MQTT protocol
func NewMQTT ¶
func NewMQTT(opts ...OptionFunc) *MQTT
NewMQTT returns a new instance of MQTT Subscriber
func (*MQTT) SetCollector ¶
SetCollector inject a collector inside the subscriber
type OptionFunc ¶
type OptionFunc func(m *MQTT)
OptionFunc defines option functions for MQTT instances
func OptionWithAddress ¶
func OptionWithAddress(a string) OptionFunc
OptionWithAddress set MQTT endpoint
func OptionWithCollector ¶
func OptionWithCollector(c collector.Collector) OptionFunc
OptionWithCollector inject a collector
func OptionWithLogger ¶
func OptionWithLogger(log logr.Logger) OptionFunc
OptionWithLogger to set logger
func OptionWithTopics ¶
func OptionWithTopics(topics ...string) OptionFunc
OptionWithTopics appends topics to existing topics
Source Files
Click to show internal directories.
Click to hide internal directories.