mqtt

Mar 13, 2023

Changes in this version

+ type HomieGenerator struct

+ PluginName string

+ func NewHomieGenerator(tmpl string) (*HomieGenerator, error)

+ func (t *HomieGenerator) Generate(m telegraf.Metric) (string, error)

+ func (t *HomieGenerator) Tag(key string) string

type MQTT

+ HomieDeviceName string

+ HomieNodeID string

+ Layout string

+ Topic string

+ func (m *MQTT) Init() error

+ type TopicNameGenerator struct

+ Hostname string

+ PluginName string

+ TopicPrefix string

+ func NewTopicNameGenerator(topicPrefix string, topic string) (*TopicNameGenerator, error)

+ func (t *TopicNameGenerator) Generate(hostname string, m telegraf.Metric) (string, error)

+ func (t *TopicNameGenerator) Tag(key string) string

Sep 12, 2022

Changes in this version

+ type Client interface

+ Close func() error

+ Connect func() error

+ Publish func(topic string, data []byte) error

type MQTT

+ Protocol string

Dec 15, 2021

Changes in this version

type MQTT

+ Log telegraf.Logger

Oct 6, 2021

Changes in this version

type MQTT

+ KeepAlive int64

Mar 26, 2020

Changes in this version

type MQTT

+ BatchMessage bool

+ ClientID string

+ QoS int

+ Retain bool

+ func (m *MQTT) SetSerializer(serializer serializers.Serializer)

Jan 9, 2016

Changes in this version

+ const ClientIdPrefix

+ const MaxClientIdLen

+ const MaxRetryCount

+ type MQTT struct

+ Client *paho.Client

+ Database string

+ Opts *paho.ClientOptions

+ Password string

+ Servers []string

+ Timeout internal.Duration

+ TopicPrefix string

+ Username string

+ func (m *MQTT) Close() error

+ func (m *MQTT) Connect() error

+ func (m *MQTT) CreateOpts() (*paho.ClientOptions, error)

+ func (m *MQTT) Description() string

+ func (m *MQTT) SampleConfig() string

+ func (m *MQTT) Write(points []*client.Point) error