pipeline

Documentation

Index

• func NewBufferDB(db kioradb.DB, alertCapacity, silenceCapacity, lengthLimit int, ...) *bufferDB
• type DBEventDelegate
  • func NewDBEventDelegate(db kioradb.DB) *DBEventDelegate
  • func (d *DBEventDelegate) Name() string
  • func (d *DBEventDelegate) ProcessAlert(ctx context.Context, alert model.Alert)
  • func (d *DBEventDelegate) ProcessAlertAcknowledgement(ctx context.Context, alertID string, ack model.AlertAcknowledgement)
  • func (d *DBEventDelegate) ProcessSilence(ctx context.Context, silence model.Silence)
  • func (d *DBEventDelegate) Run(ctx context.Context) error

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