From 094eff6a1ee8cefafe41da7fcdd82b4e2cab510f Mon Sep 17 00:00:00 2001 From: Joseph Heyburn <34041368+jdheyburn@users.noreply.github.com> Date: Wed, 31 Jul 2024 09:58:06 +0100 Subject: [PATCH] feat(inputs.statsd): Expose allowed_pending_messages as internal stat (#15687) --- plugins/inputs/statsd/statsd.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/plugins/inputs/statsd/statsd.go b/plugins/inputs/statsd/statsd.go index dc2e55467..7a1224cc7 100644 --- a/plugins/inputs/statsd/statsd.go +++ b/plugins/inputs/statsd/statsd.go @@ -164,6 +164,7 @@ type Statsd struct { UDPBytesRecv selfstat.Stat ParseTimeNS selfstat.Stat PendingMessages selfstat.Stat + MaxPendingMessages selfstat.Stat lastGatherTime time.Time } @@ -356,6 +357,8 @@ func (s *Statsd) Start(ac telegraf.Accumulator) error { s.UDPBytesRecv = selfstat.Register("statsd", "udp_bytes_received", tags) s.ParseTimeNS = selfstat.Register("statsd", "parse_time_ns", tags) s.PendingMessages = selfstat.Register("statsd", "pending_messages", tags) + s.MaxPendingMessages = selfstat.Register("statsd", "max_pending_messages", tags) + s.MaxPendingMessages.Set(int64(s.AllowedPendingMessages)) s.in = make(chan input, s.AllowedPendingMessages) s.done = make(chan struct{})