diff options
| author | Paul Buetow <paul@buetow.org> | 2021-08-21 14:54:24 +0300 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2021-08-21 14:54:24 +0300 |
| commit | c2522ffb59514443816a96386c16bb7527cbe57c (patch) | |
| tree | 6e6fb065e14b92e362f66103cfed2cbdc51ceccf /internal/io/logger | |
| parent | 70cc67e78278fcf103acc57dfe513bd6f5f258c9 (diff) | |
read files bytewise for more control of whats happening - change transport protocol for more control over newlines
Diffstat (limited to 'internal/io/logger')
| -rw-r--r-- | internal/io/logger/logger.go | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/internal/io/logger/logger.go b/internal/io/logger/logger.go index bb9dc02..3a3935d 100644 --- a/internal/io/logger/logger.go +++ b/internal/io/logger/logger.go @@ -205,7 +205,7 @@ func Trace(args ...interface{}) string { // Write log line to buffer and/or log file. func write(what, severity, message string) { if Mode.logToStdout { - line := fmt.Sprintf("%s|%s|%s|%s\n", what, hostname, severity, message) + line := fmt.Sprintf("%s|%s|%s|%s", what, hostname, severity, message) if config.Client.TermColorsEnable { line = brush.Colorfy(line) @@ -219,7 +219,7 @@ func write(what, severity, message string) { timeStr := t.Format("20060102-150405") fileLogBufCh <- buf{ time: t, - message: fmt.Sprintf("%s|%s|%s|%s\n", severity, timeStr, what, message), + message: fmt.Sprintf("%s|%s|%s|%s", severity, timeStr, what, message), } } } @@ -326,6 +326,7 @@ func Flush() { select { case message := <-stdoutBufCh: stdoutWriter.WriteString(message) + stdoutWriter.WriteString("\n") default: stdoutWriter.Flush() return @@ -338,6 +339,7 @@ func writeToStdout(ctx context.Context) { select { case message := <-stdoutBufCh: stdoutWriter.WriteString(message) + stdoutWriter.WriteString("\n") case <-time.After(time.Millisecond * 100): stdoutWriter.Flush() case <-pauseCh: @@ -365,6 +367,7 @@ func writeToFile(ctx context.Context) { dateStr := buf.time.Format("20060102") w := fileWriter(dateStr) w.WriteString(buf.message) + w.WriteString("\n") case <-pauseCh: PAUSE: for { |