From 438dd9e27e76939777a0bb561cc721bfdeb133ad Mon Sep 17 00:00:00 2001 From: vyzo Date: Tue, 5 May 2020 20:40:05 +0300 Subject: [PATCH] downgrade tracer Error logs to Warn --- tracer.go | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/tracer.go b/tracer.go index ad386fa..fbf524a 100644 --- a/tracer.go +++ b/tracer.go @@ -113,7 +113,7 @@ func (t *JSONTracer) doWrite() { for i, evt := range buf { err := enc.Encode(evt) if err != nil { - log.Errorf("error writing event trace: %s", err.Error()) + log.Warnf("error writing event trace: %s", err.Error()) } buf[i] = nil } @@ -165,7 +165,7 @@ func (t *PBTracer) doWrite() { for i, evt := range buf { err := w.WriteMsg(evt) if err != nil { - log.Errorf("error writing event trace: %s", err.Error()) + log.Warnf("error writing event trace: %s", err.Error()) } buf[i] = nil } @@ -202,7 +202,7 @@ func (t *RemoteTracer) doWrite() { s, err := t.openStream() if err != nil { - log.Errorf("error opening remote tracer stream: %s", err.Error()) + log.Warnf("error opening remote tracer stream: %s", err.Error()) return } @@ -237,13 +237,13 @@ func (t *RemoteTracer) doWrite() { err = w.WriteMsg(&batch) if err != nil { - log.Errorf("error writing trace event batch: %s", err) + log.Warnf("error writing trace event batch: %s", err) goto end } err = gzipW.Flush() if err != nil { - log.Errorf("error flushin gzip stream: %s", err) + log.Warnf("error flushin gzip stream: %s", err) goto end } @@ -267,7 +267,7 @@ func (t *RemoteTracer) doWrite() { s.Reset() s, err = t.openStream() if err != nil { - log.Errorf("error opening remote tracer stream: %s", err.Error()) + log.Warnf("error opening remote tracer stream: %s", err.Error()) return }