mirror of
https://github.com/prymitive/karma
synced 2026-05-13 03:56:59 +00:00
8a77d620fd
Fixes #104 @status filter was added to the master branch to support new status key from Alertmanager >=0.6.1 status ended up being nested in Alertmanager (it was added to solve AM issue 609 and that was a long PR with lots of changes), current unsee implementation ended being slightly off with how Alertmanager is naming this, it should actually be @state rather than @status.
108 lines
2.9 KiB
Go
108 lines
2.9 KiB
Go
// Package v05 package implements support for interacting with Alertmanager 0.5
|
|
// Collected data will be mapped to unsee internal schema defined the
|
|
// unsee/models package
|
|
// This file defines Alertmanager alerts mapping
|
|
package v05
|
|
|
|
import (
|
|
"errors"
|
|
"time"
|
|
|
|
"github.com/blang/semver"
|
|
"github.com/cloudflare/unsee/config"
|
|
"github.com/cloudflare/unsee/mapper"
|
|
"github.com/cloudflare/unsee/models"
|
|
"github.com/cloudflare/unsee/transport"
|
|
)
|
|
|
|
type alert struct {
|
|
Annotations map[string]string `json:"annotations"`
|
|
Labels map[string]string `json:"labels"`
|
|
StartsAt time.Time `json:"startsAt"`
|
|
EndsAt time.Time `json:"endsAt"`
|
|
GeneratorURL string `json:"generatorURL"`
|
|
Inhibited bool `json:"inhibited"`
|
|
Silenced string `json:"silenced"`
|
|
}
|
|
|
|
type alertsGroups struct {
|
|
Labels map[string]string `json:"labels"`
|
|
Blocks []struct {
|
|
Alerts []alert `json:"alerts"`
|
|
} `json:"blocks"`
|
|
}
|
|
|
|
type alertsGroupsAPISchema struct {
|
|
Status string `json:"status"`
|
|
Groups []alertsGroups `json:"data"`
|
|
Error string `json:"error"`
|
|
}
|
|
|
|
// AlertMapper implements Alertmanager 0.5 API schema
|
|
type AlertMapper struct {
|
|
mapper.AlertMapper
|
|
}
|
|
|
|
// IsSupported returns true if given version string is supported
|
|
func (m AlertMapper) IsSupported(version string) bool {
|
|
versionRange := semver.MustParseRange(">=0.5.0 <=0.6.0")
|
|
return versionRange(semver.MustParse(version))
|
|
}
|
|
|
|
// GetAlerts will make a request to Alertmanager API and parse the response
|
|
// It will only return alerts or error (if any)
|
|
func (m AlertMapper) GetAlerts() ([]models.AlertGroup, error) {
|
|
groups := []models.AlertGroup{}
|
|
resp := alertsGroupsAPISchema{}
|
|
|
|
url, err := transport.JoinURL(config.Config.AlertmanagerURI, "api/v1/alerts/groups")
|
|
if err != nil {
|
|
return groups, err
|
|
}
|
|
|
|
err = transport.ReadJSON(url, config.Config.AlertmanagerTimeout, &resp)
|
|
if err != nil {
|
|
return groups, err
|
|
}
|
|
|
|
if resp.Status != "success" {
|
|
return groups, errors.New(resp.Error)
|
|
}
|
|
|
|
for _, g := range resp.Groups {
|
|
alertList := models.AlertList{}
|
|
for _, b := range g.Blocks {
|
|
for _, a := range b.Alerts {
|
|
status := models.AlertStateActive
|
|
silencedBy := []string{}
|
|
if a.Silenced != "" {
|
|
silencedBy = append(silencedBy, a.Silenced)
|
|
status = models.AlertStateSuppressed
|
|
}
|
|
inhibitedBy := []string{}
|
|
if a.Inhibited {
|
|
inhibitedBy = append(inhibitedBy, "0")
|
|
status = models.AlertStateSuppressed
|
|
}
|
|
us := models.Alert{
|
|
Annotations: a.Annotations,
|
|
Labels: a.Labels,
|
|
StartsAt: a.StartsAt,
|
|
EndsAt: a.EndsAt,
|
|
GeneratorURL: a.GeneratorURL,
|
|
State: status,
|
|
InhibitedBy: inhibitedBy,
|
|
SilencedBy: silencedBy,
|
|
}
|
|
alertList = append(alertList, us)
|
|
}
|
|
}
|
|
ug := models.AlertGroup{
|
|
Labels: g.Labels,
|
|
Alerts: alertList,
|
|
}
|
|
groups = append(groups, ug)
|
|
}
|
|
return groups, nil
|
|
}
|