diff --git a/klog.go b/klog.go index 152f8a6b..3462978b 100644 --- a/klog.go +++ b/klog.go @@ -873,6 +873,9 @@ func (l *loggingT) output(s severity.Severity, logger *logWriter, buf *buffer.Bu if logger.writeKlogBuffer != nil { logger.writeKlogBuffer(data) } else { + if data[len(data)-1] == '\n' { + data = data[:len(data)-1] + } // TODO: set 'severity' and caller information as structured log info // keysAndValues := []interface{}{"severity", severityName[s], "file", file, "line", line} if s == severity.ErrorLog { diff --git a/klog_test.go b/klog_test.go index 76303e06..c31b7fb1 100644 --- a/klog_test.go +++ b/klog_test.go @@ -1522,7 +1522,7 @@ func TestInfoSWithLogr(t *testing.T) { keysValues: []interface{}{}, expected: testLogrEntry{ severity: severity.InfoLog, - msg: "foo", + msg: "foo\n", keysAndValues: []interface{}{}, }, }, { @@ -1530,7 +1530,7 @@ func TestInfoSWithLogr(t *testing.T) { keysValues: []interface{}{"a", 1}, expected: testLogrEntry{ severity: severity.InfoLog, - msg: "bar", + msg: "bar\n", keysAndValues: []interface{}{"a", 1}, }, }} @@ -1810,7 +1810,7 @@ func (l *testLogr) Info(level int, msg string, keysAndValues ...interface{}) { defer l.mutex.Unlock() l.entries = append(l.entries, testLogrEntry{ severity: severity.InfoLog, - msg: msg, + msg: msg + "\n", keysAndValues: keysAndValues, }) }