diff --git a/gateway/server.go b/gateway/server.go index 377f53ac2290be8d4558175ef57116016e25c7a3..a1b96a16ea587be75095d665600e1826337afbf3 100644 --- a/gateway/server.go +++ b/gateway/server.go @@ -23,7 +23,7 @@ func scaleService(req requests.PrometheusAlert, c *client.Client) error { //Todo: convert to loop / handler. serviceName := req.Alerts[0].Labels.FunctionName service, _, inspectErr := c.ServiceInspectWithRaw(context.Background(), serviceName) - if inspectErr != nil { + if inspectErr == nil { var replicas uint64 if req.Status == "firing" { @@ -60,12 +60,17 @@ func scaleService(req requests.PrometheusAlert, c *client.Client) error { func makeAlertHandler(c *client.Client) http.HandlerFunc { return func(w http.ResponseWriter, r *http.Request) { log.Println("Alert received.") - body, _ := ioutil.ReadAll(r.Body) + body, readErr := ioutil.ReadAll(r.Body) + if readErr != nil { + log.Println(readErr) + return + } var req requests.PrometheusAlert err := json.Unmarshal(body, &req) if err != nil { log.Println(err) + return } if len(req.Alerts) > 0 {