Commit 3a7939c9 by Thibault Chataigner Committed by bergquist

Alertmanager notifier: make it match the new notifier interface

Signed-off-by: Thibault Chataigner <t.chataigner@criteo.com>
parent 20d94f97
...@@ -45,6 +45,13 @@ type AlertmanagerNotifier struct { ...@@ -45,6 +45,13 @@ type AlertmanagerNotifier struct {
log log.Logger log log.Logger
} }
func (this *AlertmanagerNotifier) ShouldNotify(evalContext *alerting.EvalContext) bool {
if evalContext.Rule.State == m.AlertStateAlerting {
return true
}
return false
}
func (this *AlertmanagerNotifier) Notify(evalContext *alerting.EvalContext) error { func (this *AlertmanagerNotifier) Notify(evalContext *alerting.EvalContext) error {
this.log.Info("Sending alertmanager") this.log.Info("Sending alertmanager")
...@@ -52,11 +59,8 @@ func (this *AlertmanagerNotifier) Notify(evalContext *alerting.EvalContext) erro ...@@ -52,11 +59,8 @@ func (this *AlertmanagerNotifier) Notify(evalContext *alerting.EvalContext) erro
for _, match := range evalContext.EvalMatches { for _, match := range evalContext.EvalMatches {
alertJSON := simplejson.New() alertJSON := simplejson.New()
alertJSON.Set("startsAt", evalContext.StartTime.UTC().Format(time.RFC3339)) alertJSON.Set("startsAt", evalContext.StartTime.UTC().Format(time.RFC3339))
if evalContext.Rule.State == m.AlertStateAlerting { // Rule state should always be alerting if notifying.
alertJSON.Set("endsAt", "0001-01-01T00:00:00Z") alertJSON.Set("endsAt", "0001-01-01T00:00:00Z")
} else {
alertJSON.Set("endsAt", evalContext.EndTime.UTC().Format(time.RFC3339))
}
ruleUrl, err := evalContext.GetRuleUrl() ruleUrl, err := evalContext.GetRuleUrl()
if err == nil { if err == nil {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment