From 5123a1caa60d37466b44ba8800f25900b0cc5843 Mon Sep 17 00:00:00 2001 From: Sumesh Premraj Date: Mon, 10 Jul 2023 11:19:21 +0200 Subject: [PATCH] Convert line payload debug logs to string Signed-off-by: Sumesh Premraj --- pkg/listener/listener.go | 2 +- pkg/relay/relay.go | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/pkg/listener/listener.go b/pkg/listener/listener.go index 09f9dbf..c8acc0a 100644 --- a/pkg/listener/listener.go +++ b/pkg/listener/listener.go @@ -133,7 +133,7 @@ func (l *StatsDTCPListener) HandleConn(c *net.TCPConn) { } 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 { l.TCPLineTooLong.Inc() level.Debug(l.Logger).Log("msg", "Read failed: line too long", "addr", c.RemoteAddr()) diff --git a/pkg/relay/relay.go b/pkg/relay/relay.go index 6e8e752..08f109c 100644 --- a/pkg/relay/relay.go +++ b/pkg/relay/relay.go @@ -127,7 +127,7 @@ func (r *Relay) relayOutput() { buffer.Reset() buffer.Write(b) } 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) } } @@ -140,7 +140,7 @@ func (r *Relay) sendPacket(buf []byte) error { level.Debug(r.logger).Log("msg", "Empty buffer, nothing to send") 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) r.packetsTotal.Inc() return err @@ -158,7 +158,7 @@ func (r *Relay) RelayLine(l string) { r.longLinesTotal.Inc() 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") { l = l + "\n" }