mirror of
https://github.com/crazy-max/diun.git
synced 2026-01-03 11:35:02 +01:00
Set ants logger
This commit is contained in:
@@ -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
|
||||
|
||||
@@ -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...)
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user