From 70b51a73d3a0029394dbdbc9f52a4d3d8e89d6f5 Mon Sep 17 00:00:00 2001 From: Ondřej Benkovský Date: Fri, 9 Jul 2021 16:23:02 +0200 Subject: add configurable log level to errors plugin (#4718) Automatically submitted. --- plugin/errors/errors.go | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) (limited to 'plugin/errors/errors.go') diff --git a/plugin/errors/errors.go b/plugin/errors/errors.go index 9565f11ab..c045f6992 100644 --- a/plugin/errors/errors.go +++ b/plugin/errors/errors.go @@ -18,10 +18,11 @@ import ( var log = clog.NewWithPlugin("errors") type pattern struct { - ptimer unsafe.Pointer - count uint32 - period time.Duration - pattern *regexp.Regexp + ptimer unsafe.Pointer + count uint32 + period time.Duration + pattern *regexp.Regexp + logCallback func(format string, v ...interface{}) } func (p *pattern) timer() *time.Timer { @@ -46,7 +47,7 @@ func newErrorHandler() *errorHandler { func (h *errorHandler) logPattern(i int) { cnt := atomic.SwapUint32(&h.patterns[i].count, 0) if cnt > 0 { - log.Errorf("%d errors like '%s' occurred in last %s", + h.patterns[i].logCallback("%d errors like '%s' occurred in last %s", cnt, h.patterns[i].pattern.String(), h.patterns[i].period) } } -- cgit v1.2.3