logging

Documentation

Index

• type Deduper
  • func Dedupe(next *slog.Logger, repeat time.Duration) *Deduper
  • func (d *Deduper) Enabled(ctx context.Context, level slog.Level) bool
  • func (d *Deduper) Handle(ctx context.Context, r slog.Record) error
  • func (d *Deduper) Stop()
  • func (d *Deduper) WithAttrs(attrs []slog.Attr) slog.Handler
  • func (d *Deduper) WithGroup(name string) slog.Handler
• type JSONFileLogger
  • func NewJSONFileLogger(s string) (*JSONFileLogger, error)
  • func (l *JSONFileLogger) Close() error
  • func (l *JSONFileLogger) Log(ctx context.Context, level slog.Level, msg string, args ...any)
  • func (l *JSONFileLogger) With(args ...any)

Types

type Deduper

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

Deduper implements *slog.Handler, dedupes log lines based on a time duration.

func Dedupe

func Dedupe(next *slog.Logger, repeat time.Duration) *Deduper

Dedupe log lines to next, only repeating every repeat duration.

func (*Deduper) Enabled

func (d *Deduper) Enabled(ctx context.Context, level slog.Level) bool

Enabled returns true if the Deduper's internal slog.Logger is enabled at the provided context and log level, and returns false otherwise. It implements slog.Handler.

func (*Deduper) Handle

func (d *Deduper) Handle(ctx context.Context, r slog.Record) error

Handle uses the provided context and slog.Record to deduplicate messages every 1m. Log records received within the interval are not acted on, and thus dropped. Log records that pass deduplication and need action invoke the Handle() method on the Deduper's internal slog.Logger's handler, effectively chaining log calls to the internal slog.Logger.

func (*Deduper) Stop

func (d *Deduper) Stop()

Stop the Deduper.

func (*Deduper) WithAttrs

func (d *Deduper) WithAttrs(attrs []slog.Attr) slog.Handler

WithAttrs adds the provided attributes to the Deduper's internal slog.Logger. It implements slog.Handler.

func (*Deduper) WithGroup

func (d *Deduper) WithGroup(name string) slog.Handler

WithGroup adds the provided group name to the Deduper's internal slog.Logger. It implements slog.Handler.

type JSONFileLogger

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

JSONFileLogger represents a logger that writes JSON to a file. It implements the promql.QueryLogger interface.

func NewJSONFileLogger

func NewJSONFileLogger(s string) (*JSONFileLogger, error)

NewJSONFileLogger returns a new JSONFileLogger.

func (*JSONFileLogger) Close

func (l *JSONFileLogger) Close() error

Close closes the underlying file. It implements the promql.QueryLogger interface.

func (*JSONFileLogger) Log

func (l *JSONFileLogger) Log(ctx context.Context, level slog.Level, msg string, args ...any)

Log calls the `Log()` method on the underlying `log/slog.Logger` with the provided msg and args. It implements the promql.QueryLogger interface.

func (*JSONFileLogger) With

func (l *JSONFileLogger) With(args ...any)

With calls the `With()` method on the underlying `log/slog.Logger` with the provided msg and args. It implements the promql.QueryLogger interface.