nflog

Documentation

Overview

Package nflog implements a garbage-collected and snapshottable append-only log of active/resolved notifications. Each log entry stores the active/resolved state, the notified receiver, and a hash digest of the notification's identifying contents. The log can be queried along different parameters.

Index

• Variables
• type Log
  • func New(opts ...Option) (*Log, error)
  • func (l *Log) GC() (int, error)
  • func (l *Log) Log(r *pb.Receiver, gkey string, firingAlerts, resolvedAlerts []uint64) error
  • func (l *Log) MarshalBinary() ([]byte, error)
  • func (l *Log) Merge(b []byte) error
  • func (l *Log) Query(params ...QueryParam) ([]*pb.Entry, error)
  • func (l *Log) SetBroadcast(f func([]byte))
  • func (l *Log) Snapshot(w io.Writer) (int64, error)
• type Option
  • func WithLogger(logger log.Logger) Option
  • func WithMaintenance(d time.Duration, stopc chan struct{}, done func()) Option
  • func WithMetrics(r prometheus.Registerer) Option
  • func WithNow(f func() time.Time) Option
  • func WithRetention(d time.Duration) Option
  • func WithSnapshot(sf string) Option
• type QueryParam
  • func QGroupKey(gk string) QueryParam
  • func QReceiver(r *pb.Receiver) QueryParam

Variables

var ErrInvalidState = fmt.Errorf("invalid state")

ErrInvalidState is returned if the state isn't valid.

var ErrNotFound = errors.New("not found")

ErrNotFound is returned for empty query results.

Types

type Log

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

func New

func New(opts ...Option) (*Log, error)

New creates a new notification log based on the provided options. The snapshot is loaded into the Log if it is set.

func (*Log) GC

func (l *Log) GC() (int, error)

GC implements the Log interface.

func (*Log) Log

func (l *Log) Log(r *pb.Receiver, gkey string, firingAlerts, resolvedAlerts []uint64) error

func (*Log) MarshalBinary

func (l *Log) MarshalBinary() ([]byte, error)

MarshalBinary serializes all contents of the notification log.

func (*Log) Merge

func (l *Log) Merge(b []byte) error

Merge merges notification log state received from the cluster with the local state.

func (*Log) Query

func (l *Log) Query(params ...QueryParam) ([]*pb.Entry, error)

Query implements the Log interface.

func (*Log) SetBroadcast

func (l *Log) SetBroadcast(f func([]byte))

SetBroadcast sets a broadcast callback that will be invoked with serialized state on updates.

func (*Log) Snapshot

func (l *Log) Snapshot(w io.Writer) (int64, error)

Snapshot implements the Log interface.

type Option

type Option func(*Log) error

Option configures a new Log implementation.

func WithLogger

func WithLogger(logger log.Logger) Option

WithLogger configures a logger for the notification log.

func WithMaintenance

func WithMaintenance(d time.Duration, stopc chan struct{}, done func()) Option

WithMaintenance configures the Log to run garbage collection and snapshotting, if configured, at the given interval.

The maintenance terminates on receiving from the provided channel. The done function is called after the final snapshot was completed.

func WithMetrics

func WithMetrics(r prometheus.Registerer) Option

WithMetrics registers metrics for the notification log.

func WithNow

func WithNow(f func() time.Time) Option

WithNow overwrites the function used to retrieve a timestamp for the current point in time. This is generally useful for injection during tests.

func WithRetention

func WithRetention(d time.Duration) Option

WithRetention sets the retention time for log st.

func WithSnapshot

func WithSnapshot(sf string) Option

WithSnapshot configures the log to be initialized from a given snapshot file. If maintenance is configured, a snapshot will be saved periodically and on shutdown as well.

type QueryParam

type QueryParam func(*query) error

QueryParam is a function that modifies a query to incorporate a set of parameters. Returns an error for invalid or conflicting parameters.

func QGroupKey

func QGroupKey(gk string) QueryParam

QGroupKey adds a group key as querying argument.

func QReceiver

func QReceiver(r *pb.Receiver) QueryParam

QReceiver adds a receiver parameter to a query.