Implement sending allert from handler to alertmaner

even if still to cleanup

alerts.go

@@ -3,10 +3,7 @@ package main
 import (
 	"bytes"
 	"encoding/json"
-	"fmt"
-	"io"
 	"net/http"
-	"os"
 	"time"
 
 	log "github.com/sirupsen/logrus"
@@ -51,7 +48,9 @@ type AlertFire struct {
 }
 
 func (alert *AlertFire) sendAlert(url string) {
-	body := &alert
+	alerts := make([]AlertFire, 1)
+	alerts[0] = *alert
+	body := alerts
 	buf := new(bytes.Buffer)
 	json.NewEncoder(buf).Encode(body)
 	req, err := http.NewRequest("POST", url, buf)
@@ -63,10 +62,6 @@ func (alert *AlertFire) sendAlert(url string) {
 	if err != nil {
 		log.Error(err)
 	}
-
+	log.Infof("Alert from handler to alertmanager sent %s", alert.Labels.Alertname)
 	defer res.Body.Close()
-
-	fmt.Println("response Status:", res.Status)
-	// Print the body to the stdout
-	io.Copy(os.Stdout, res.Body)
 }

alerts_test.go

@@ -21,12 +21,12 @@ func TestAlertFiring(t *testing.T) {
 	ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
 		// read body json from Prometheus alertmanager
 		decoder := json.NewDecoder(r.Body)
-		var alert AlertFire
+		alert := make([]AlertFire, 1)
 		decoder.Decode(&alert)
-		t.Log(alert.Status)
-		t.Log(alert.Labels.Component)
-		if alert.GeneratorURL != "unit-test" {
-			t.Errorf("got %s expected unit-test", alert.GeneratorURL)
+		t.Log(alert[0].Status)
+		t.Log(alert[0].Labels.Component)
+		if alert[0].GeneratorURL != "unit-test" {
+			t.Errorf("got %s expected unit-test", alert[0].GeneratorURL)
 		}
 	}))
 	defer ts.Close()

main.go

@@ -29,6 +29,18 @@ func main() {
 
 	log.Infof("starting handler on port: %s", handlerWebSrvPort)
 
+	var a *AlertFire
+	a = new(AlertFire)
+	a.Status = "firing"
+	a.Labels.Alertname = "FOO-ALERT"
+	a.Labels.Component = "unit-test component"
+	a.Labels.Severity = "critical"
+	a.Labels.Instance = "test instance"
+	a.Annotations.Summary = "just a test"
+	a.GeneratorURL = "unit-test"
+
+	a.sendAlert("http://10.162.31.2:9093/api/v1/alerts")
+
 	// register the various handler
 	h := new(HanaDiskFull)
 	// make sure we run only 1 handler until it finish.