loglimit

Documentation

Index

• type Config
• type LogLimiter
  • func New(config Config) (*LogLimiter, error)
  • func (l *LogLimiter) Log(entry *log.Entry, level log.Level, args ...any)

Types

type Config

type Config struct {
	// Context is a context to signal stops, cancellations.
	Context context.Context
	// MessageSubstrings contains a list of substrings belonging to the
	// logs that should be deduplicated.
	MessageSubstrings []string
	// Clock is a clock to override in tests, set to real time clock
	// by default.
	Clock clockwork.Clock
}

Config contains the log limiter config.

type LogLimiter

type LogLimiter struct {
	// contains filtered or unexported fields
}

LogLimiter deduplicates logs over a certain time window.

func New

func New(config Config) (*LogLimiter, error)

New creates a new log limiter.

func (*LogLimiter) Log

func (l *LogLimiter) Log(entry *log.Entry, level log.Level, args ...any)

Log deduplicates log entries that should be deduplicated.