sum7/hook2xmpp
sum7
/
hook2xmpp
1
1
Fork 0
Code Issues 1 Pull Requests Releases Wiki Activity

Update prometheus/main.go

This commit is contained in:
Martin/Geno 2019-06-17 15:33:50 +02:00
parent 73c9b9fb77
commit 23c2eb44eb
1 changed files with 13 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
prometheus/main.go
View File

@ -24,22 +24,21 @@ func init() {
logger := log.WithField("type", hookType) logger := log.WithField("type", hookType)
var request notify.WebhookMessage var request notify.WebhookMessage
if err := libHTTP.Read(r, &request); err != nil { if err := libHTTP.Read(r, &request); err != nil {
logger.Errorf("no readable payload: %s", err) logger.Errorf("no readable payload: %s", err)
http.Error(w, fmt.Sprintf("no readable payload"), http.StatusInternalServerError) http.Error(w, fmt.Sprintf("no readable payload"), http.StatusInternalServerError)
return return
} }
content := "" content := ""
firingAlerts := len(request.Alerts.Firing()) firingAlerts := len(request.Alerts.Firing())
if firingAlerts > 0 { if firingAlerts > 0 {
content = fmt.Sprintf("[%s:%d] %s", request.Status, firingAlerts, strings.Join(request.CommonAnnotations.Values()," ")) content = fmt.Sprintf("[%s:%d] %s", request.Status, firingAlerts, strings.Join(request.CommonAnnotations.Values()," "))
} else { } else {
content = fmt.Sprintf("[%s] %s", request.Status, strings.Join(request.CommonAnnotations.Values()," ")) content = fmt.Sprintf("[%s] %s", request.Status, strings.Join(request.CommonAnnotations.Values()," "))
} }
logger = logger.WithField("body", content)
logger = logger.WithField("body", content)
ok := false ok := false
for _, hook := range hooks { for _, hook := range hooks {