CL-Softwares
/
telegraf
8
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

chore(inputs.mqtt_consumer)!: Remove deprecated 'metric_buffer' option (#14914)

This commit is contained in:
Sven Rebhan 2024-02-29 20:26:06 +01:00 committed by GitHub
parent 9ee91f0f45
commit c5d864af9c
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
plugins/inputs/mqtt_consumer/mqtt_consumer.go
View File

@ -48,7 +48,9 @@ type Client interface {
AddRoute(topic string, callback mqtt.MessageHandler) AddRoute(topic string, callback mqtt.MessageHandler)
Disconnect(quiesce uint) Disconnect(quiesce uint)
} }
type ClientFactory func(o *mqtt.ClientOptions) Client type ClientFactory func(o *mqtt.ClientOptions) Client
type TopicParsingConfig struct { type TopicParsingConfig struct {
Topic string `toml:"topic"` Topic string `toml:"topic"`
Measurement string `toml:"measurement"` Measurement string `toml:"measurement"`
@ -61,6 +63,7 @@ type TopicParsingConfig struct {
SplitFields []string SplitFields []string
SplitTopic []string SplitTopic []string
} }
type MQTTConsumer struct { type MQTTConsumer struct {
Servers []string `toml:"servers"` Servers []string `toml:"servers"`
Topics []string `toml:"topics"` Topics []string `toml:"topics"`
@ -72,15 +75,12 @@ type MQTTConsumer struct {
ConnectionTimeout config.Duration `toml:"connection_timeout"` ConnectionTimeout config.Duration `toml:"connection_timeout"`
ClientTrace bool `toml:"client_trace"` ClientTrace bool `toml:"client_trace"`
MaxUndeliveredMessages int `toml:"max_undelivered_messages"` MaxUndeliveredMessages int `toml:"max_undelivered_messages"`
parser telegraf.Parser PersistentSession bool `toml:"persistent_session"`
MetricBuffer int `toml:"metric_buffer" deprecated:"0.10.3;1.30.0;option is ignored"`
PersistentSession bool
ClientID string `toml:"client_id"` ClientID string `toml:"client_id"`
Log telegraf.Logger `toml:"-"`
tls.ClientConfig tls.ClientConfig
Log telegraf.Logger parser telegraf.Parser
clientFactory ClientFactory clientFactory ClientFactory
client Client client Client
opts *mqtt.ClientOptions opts *mqtt.ClientOptions