From 16401c73cbb7b13cd55b0f3bd807179c7bc22154 Mon Sep 17 00:00:00 2001 From: Mingyang Zheng Date: Mon, 25 Nov 2024 02:26:09 -0800 Subject: [PATCH] fix(logging): Add Close() func for redirectLogger (#16219) --- logger/handler.go | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/logger/handler.go b/logger/handler.go index 7f23b32b0..6bc066658 100644 --- a/logger/handler.go +++ b/logger/handler.go @@ -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...) 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 +}