aggregation

Documentation

Index

• func NewAggregatorHealthCheck(aggregator *Aggregator) actuator.HealthCheck
• type Aggregate
• type Aggregator
  • func NewAggregator(cfg *config.Config, clock clock.Clock) *Aggregator
  • func (a *Aggregator) Alerts(dashboardName string) Aggregate
  • func (a *Aggregator) Reconfigure(cfg *config.Config)
  • func (a *Aggregator) Register(handler string) <-chan bool
  • func (a *Aggregator) Run(ctx context.Context)
  • func (a *Aggregator) Silence(ctx context.Context, alertId, user string)
  • func (a *Aggregator) Unregister(handler string)
• type Alert
• type BlockedAlert

Functions

func NewAggregatorHealthCheck

func NewAggregatorHealthCheck(aggregator *Aggregator) actuator.HealthCheck

Types

type Aggregate

type Aggregate struct {
	CheckTime time.Time
	Alerts    []Alert
	Blocked   []BlockedAlert
}

type Aggregator

type Aggregator struct {
	CheckTime time.Time
	// contains filtered or unexported fields
}

func NewAggregator

func NewAggregator(cfg *config.Config, clock clock.Clock) *Aggregator

func (*Aggregator) Alerts

func (a *Aggregator) Alerts(dashboardName string) Aggregate

func (*Aggregator) Reconfigure

func (a *Aggregator) Reconfigure(cfg *config.Config)

func (*Aggregator) Register

func (a *Aggregator) Register(handler string) <-chan bool

func (*Aggregator) Run

func (a *Aggregator) Run(ctx context.Context)

func (*Aggregator) Silence

func (a *Aggregator) Silence(ctx context.Context, alertId, user string)

func (*Aggregator) Unregister

func (a *Aggregator) Unregister(handler string)

type Alert

type Alert struct {
	Id      string
	Where   string
	Tag     string
	What    string
	Details string
	When    time.Duration
	Status  string
	Links   []html.HTML
	Labels  map[string]string
	Silence connectors.SilencerFunc
}

type BlockedAlert

type BlockedAlert struct {
	Alert
	Reason string
}