mirrors/statsd_exporter
1
0
Fork 1
mirror of https://github.com/prometheus/statsd_exporter.git synced 2025-02-18 08:35:20 +00:00
Code Issues Projects Releases Packages Wiki Activity

Merge pull request #510 from sumeshpremraj/spremraj/improve-network-debug-logging

Browse source 
Convert line payloads to string for debug logging
This commit is contained in:
Matthias Rampke 2023-07-10 22:39:30 +02:00 committed by GitHub
commit 871e2d8df1
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
pkg/listener/listener.go
View file

@ -133,7 +133,7 @@ func (l *StatsDTCPListener) HandleConn(c *net.TCPConn) {
} }
break break
} }
level.Debug(l.Logger).Log("msg", "Incoming line", "proto", "tcp", "line", line) level.Debug(l.Logger).Log("msg", "Incoming line", "proto", "tcp", "line", string(line))
if isPrefix { if isPrefix {
l.TCPLineTooLong.Inc() l.TCPLineTooLong.Inc()
level.Debug(l.Logger).Log("msg", "Read failed: line too long", "addr", c.RemoteAddr()) level.Debug(l.Logger).Log("msg", "Read failed: line too long", "addr", c.RemoteAddr())

6
pkg/relay/relay.go
View file

@ -127,7 +127,7 @@ func (r *Relay) relayOutput() {
buffer.Reset() buffer.Reset()
buffer.Write(b) buffer.Write(b)
} else { } else {
level.Debug(r.logger).Log("msg", "Adding line to buffer", "line", b) level.Debug(r.logger).Log("msg", "Adding line to buffer", "line", string(b))
buffer.Write(b) buffer.Write(b)
} }
} }
@ -140,7 +140,7 @@ func (r *Relay) sendPacket(buf []byte) error {
level.Debug(r.logger).Log("msg", "Empty buffer, nothing to send") level.Debug(r.logger).Log("msg", "Empty buffer, nothing to send")
return nil return nil
} }
level.Debug(r.logger).Log("msg", "Sending packet", "length", len(buf), "data", buf) level.Debug(r.logger).Log("msg", "Sending packet", "length", len(buf), "data", string(buf))
_, err := r.conn.WriteToUDP(buf, r.addr) _, err := r.conn.WriteToUDP(buf, r.addr)
r.packetsTotal.Inc() r.packetsTotal.Inc()
return err return err
@ -158,7 +158,7 @@ func (r *Relay) RelayLine(l string) {
r.longLinesTotal.Inc() r.longLinesTotal.Inc()
return return
} }
level.Debug(r.logger).Log("msg", "Relaying line", "line", l) level.Debug(r.logger).Log("msg", "Relaying line", "line", string(l))
if !strings.HasSuffix(l, "\n") { if !strings.HasSuffix(l, "\n") {
l = l + "\n" l = l + "\n"
} }