This commit is contained in:
sabban 2023-07-07 15:31:21 +02:00
parent 2812fd1cbe
commit 0a4dcc5bd2

View file

@ -1,11 +1,9 @@
package leakybucket
import (
"fmt"
"time"
"github.com/crowdsecurity/crowdsec/pkg/types"
"github.com/davecgh/go-spew/spew"
log "github.com/sirupsen/logrus"
)
@ -37,7 +35,7 @@ func TimeMachinePour(l *Leaky, msg types.Event) {
}
l.Last_ts = d
l.mutex.Unlock()
fmt.Printf("event: %s", spew.Sdump(msg.Line.Raw))
// fmt.Printf("event: %s", spew.Sdump(msg.Line.Raw))
if l.Limiter.AllowN(d, 1) {
l.logger.Tracef("Time-Pouring event %s (tokens:%f)", d, l.Limiter.GetTokensCount())
l.Queue.Add(msg)