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

feat(inputs.statsd): Expose allowed_pending_messages as internal stat (#15687)

This commit is contained in:
Joseph Heyburn 2024-07-31 09:58:06 +01:00 committed by GitHub
parent f9f029e7e8
commit 094eff6a1e
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
plugins/inputs/statsd/statsd.go
View File

@ -164,6 +164,7 @@ type Statsd struct {
UDPBytesRecv selfstat.Stat UDPBytesRecv selfstat.Stat
ParseTimeNS selfstat.Stat ParseTimeNS selfstat.Stat
PendingMessages selfstat.Stat PendingMessages selfstat.Stat
MaxPendingMessages selfstat.Stat
lastGatherTime time.Time 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.UDPBytesRecv = selfstat.Register("statsd", "udp_bytes_received", tags)
s.ParseTimeNS = selfstat.Register("statsd", "parse_time_ns", tags) s.ParseTimeNS = selfstat.Register("statsd", "parse_time_ns", tags)
s.PendingMessages = selfstat.Register("statsd", "pending_messages", 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.in = make(chan input, s.AllowedPendingMessages)
s.done = make(chan struct{}) s.done = make(chan struct{})