chore(inputs.nats_consumer)!: Remove deprecated 'metric_buffer' option (#14915)

This commit is contained in:
Sven Rebhan 2024-02-29 20:26:47 +01:00 committed by GitHub
parent c5d864af9c
commit e78b813405
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 13 additions and 19 deletions

View File

@ -37,27 +37,21 @@ func (e natsError) Error() string {
}
type natsConsumer struct {
QueueGroup string `toml:"queue_group"`
Subjects []string `toml:"subjects"`
Servers []string `toml:"servers"`
Secure bool `toml:"secure"`
Username string `toml:"username"`
Password string `toml:"password"`
Credentials string `toml:"credentials"`
NkeySeed string `toml:"nkey_seed"`
JsSubjects []string `toml:"jetstream_subjects"`
QueueGroup string `toml:"queue_group"`
Subjects []string `toml:"subjects"`
Servers []string `toml:"servers"`
Secure bool `toml:"secure"`
Username string `toml:"username"`
Password string `toml:"password"`
Credentials string `toml:"credentials"`
NkeySeed string `toml:"nkey_seed"`
JsSubjects []string `toml:"jetstream_subjects"`
PendingMessageLimit int `toml:"pending_message_limit"`
PendingBytesLimit int `toml:"pending_bytes_limit"`
MaxUndeliveredMessages int `toml:"max_undelivered_messages"`
Log telegraf.Logger `toml:"-"`
tls.ClientConfig
Log telegraf.Logger
// Client pending limits:
PendingMessageLimit int `toml:"pending_message_limit"`
PendingBytesLimit int `toml:"pending_bytes_limit"`
MaxUndeliveredMessages int `toml:"max_undelivered_messages"`
MetricBuffer int `toml:"metric_buffer" deprecated:"0.10.3;1.30.0;option is ignored"`
conn *nats.Conn
jsConn nats.JetStreamContext
subs []*nats.Subscription