pipeline

package
v0.0.0-...-8ca999e Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 16, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewBufferDB

func NewBufferDB(db kioradb.DB, alertCapacity, silenceCapacity, lengthLimit int, timeLimit time.Duration) *bufferDB

NewBufferDB creates a new bufferDB.

Types

type DBEventDelegate

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

DBEventDelegate provides an EventDelegate that stores incoming data in the underlying database.

func NewDBEventDelegate

func NewDBEventDelegate(db kioradb.DB) *DBEventDelegate

func (*DBEventDelegate) Name

func (d *DBEventDelegate) Name() string

func (*DBEventDelegate) ProcessAlert

func (d *DBEventDelegate) ProcessAlert(ctx context.Context, alert model.Alert)

func (*DBEventDelegate) ProcessAlertAcknowledgement

func (d *DBEventDelegate) ProcessAlertAcknowledgement(ctx context.Context, alertID string, ack model.AlertAcknowledgement)

func (*DBEventDelegate) ProcessSilence

func (d *DBEventDelegate) ProcessSilence(ctx context.Context, silence model.Silence)

func (*DBEventDelegate) Run

func (d *DBEventDelegate) Run(ctx context.Context) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL