Function NewRateLimitedLogger

pkg/util/log/rate_limited_logger.go:25–30

NewRateLimitedLogger returns a new RateLimitedLogger that logs at most logsPerSecond messages per second. TODO: migrate to the dskit rate limited logger

(logsPerSecond int, logger gkLog.Logger)

// NewRateLimitedLogger returns a new RateLimitedLogger that logs at most logsPerSecond messages per second.
// TODO: migrate to the dskit rate limited logger
func NewRateLimitedLogger(logsPerSecond int, logger gkLog.Logger) *RateLimitedLogger {
	return &RateLimitedLogger{
		limiter: rate.NewLimiter(rate.Limit(logsPerSecond), 1),
		logger:  logger,
	}
}

func (l *RateLimitedLogger) Log(keyvals ...interface{}) {
	if !l.limiter.AllowN(time.Now(), 1) {