fix(logging): Add Close() func for redirectLogger (#16219)
This commit is contained in:
parent
3dea61cb5c
commit
16401c73cb
|
|
@ -125,3 +125,13 @@ func (l *redirectLogger) Print(level telegraf.LogLevel, ts time.Time, prefix str
|
||||||
msg := append([]interface{}{ts.In(time.UTC).Format(time.RFC3339), " ", level.Indicator(), " ", prefix + attrMsg}, args...)
|
msg := append([]interface{}{ts.In(time.UTC).Format(time.RFC3339), " ", level.Indicator(), " ", prefix + attrMsg}, args...)
|
||||||
fmt.Fprintln(l.writer, msg...)
|
fmt.Fprintln(l.writer, msg...)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (l *redirectLogger) Close() error {
|
||||||
|
if l.writer == os.Stderr {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
if closer, ok := l.writer.(io.Closer); ok {
|
||||||
|
return closer.Close()
|
||||||
|
}
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue