diff --git a/fluentd/logger.go b/fluentd/logger.go index 5e01875..cbbc309 100644 --- a/fluentd/logger.go +++ b/fluentd/logger.go @@ -1,7 +1,6 @@ package fluentd import ( - "errors" "fmt" "log" @@ -38,11 +37,15 @@ func (l *Logger) Log(format string, v ...any) { } func (l *Logger) Ping() error { - if l.fluent.RequestAck { - return nil + mapData := map[string]string{ + "message": "Checking is Fluentd alive", + } + err := l.fluent.Post(l.appName, mapData) + if err != nil { + return err } - return errors.New("Logger service is unavailable") + return nil } func (l *Logger) Close() error {