alert

Documentation

Index

• type AlertmanagerClient
  • func NewAlertmanagerClient(address, receiver string, silenced bool) (*AlertmanagerClient, error)
  • func (a *AlertmanagerClient) GetAlerts(ctx context.Context) ([]promv1.Alert, bool, error)
• type Cache
• type Client
  • func NewPrometheusClient(address string) (Client, error)
  • func NewPrometheusMultiClient(addresses []string) (Client, error)
• type PromClient
  • func (p *PromClient) GetAlerts(ctx context.Context) ([]promv1.Alert, bool, error)
• type PromMultiClient
  • func (p *PromMultiClient) GetAlerts(ctx context.Context) ([]promv1.Alert, bool, error)
• type Syncer
  • func NewSyncer(alertClient Client, log logr.Logger, prom prometheus.Registerer, ...) (Syncer, error)

Types

type AlertmanagerClient

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

Get alerts from Alertmanager

func NewAlertmanagerClient

func NewAlertmanagerClient(address, receiver string, silenced bool) (*AlertmanagerClient, error)

func (*AlertmanagerClient) GetAlerts

func (a *AlertmanagerClient) GetAlerts(ctx context.Context) ([]promv1.Alert, bool, error)

type Cache

type Cache interface {
	// Get will return the currently cached alerts for a given node. An error
	// will be returned if the cache is not populated, node specific filters
	// cannot be run, or if the last retrieval resulted in an error. The time
	// returned is the time of the last retrieval attempt.
	Get(nodeName string) ([]promv1.Alert, time.Time, error)
}

Cache outlines an interface to interact with cached alerts

type Client

type Client interface {
	GetAlerts(context.Context) ([]promv1.Alert, bool, error)
}

func NewPrometheusClient

func NewPrometheusClient(address string) (Client, error)

func NewPrometheusMultiClient

func NewPrometheusMultiClient(addresses []string) (Client, error)

type PromClient

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

Get alerts from a single prometheus

func (*PromClient) GetAlerts

func (p *PromClient) GetAlerts(ctx context.Context) ([]promv1.Alert, bool, error)

type PromMultiClient

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

Get alerts from multiple promethei and combine them

func (*PromMultiClient) GetAlerts

func (p *PromMultiClient) GetAlerts(ctx context.Context) ([]promv1.Alert, bool, error)

type Syncer

type Syncer interface {
	manager.LeaderElectionRunnable
	manager.Runnable
	Cache
	// SyncOnce enables the cache to be initialized before use by the Manager
	SyncOnce()
}

Syncer is an interface designed to be run by a manager.Manager that also provides a Cache interface

func NewSyncer

func NewSyncer(
	alertClient Client,
	log logr.Logger,
	prom prometheus.Registerer,
	celExpression string,
	syncInterval time.Duration,
) (Syncer, error)

NewSyncer provides an implementation of Syncer that gets alerts at syncInterval