From 143a06b3eb222a5333150cb96c8a5f4254f9ae93 Mon Sep 17 00:00:00 2001 From: CrazyMax Date: Wed, 27 May 2020 23:08:39 +0200 Subject: [PATCH] Set ants logger --- internal/app/diun.go | 3 ++- internal/logging/logger.go | 8 ++++++++ 2 files changed, 10 insertions(+), 1 deletion(-) diff --git a/internal/app/diun.go b/internal/app/diun.go index 9805f3eb..a0c2ae3c 100644 --- a/internal/app/diun.go +++ b/internal/app/diun.go @@ -10,6 +10,7 @@ import ( "github.com/crazy-max/diun/v3/internal/config" "github.com/crazy-max/diun/v3/internal/db" + "github.com/crazy-max/diun/v3/internal/logging" "github.com/crazy-max/diun/v3/internal/model" "github.com/crazy-max/diun/v3/internal/notif" dockerPrd "github.com/crazy-max/diun/v3/internal/provider/docker" @@ -115,7 +116,7 @@ func (di *Diun) Run() { Msg("Cannot run job") } di.wg.Done() - }) + }, ants.WithLogger(new(logging.AntsLogger))) defer di.pool.Release() // Docker provider diff --git a/internal/logging/logger.go b/internal/logging/logger.go index 10905faf..98d6f663 100644 --- a/internal/logging/logger.go +++ b/internal/logging/logger.go @@ -71,3 +71,11 @@ func (f *LogrusFormatter) Format(entry *logrus.Entry) ([]byte, error) { } return nil, nil } + +// AntsLogger is a logger for ants module +type AntsLogger struct{} + +// Printf must have the same semantics as log.Printf +func (w *AntsLogger) Printf(format string, args ...interface{}) { + log.Debug().Msgf(format, args...) +}