faas-rs/faas
1
0
Fork 0
mirror of https://github.com/openfaas/faas.git synced 2025-06-19 12:36:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix if-guard for replica scaling

Browse Source
This commit is contained in:
Alex
2017-01-23 22:12:47 +00:00
parent 6feaff784e
commit 59ca597903
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
gateway/server.go
View File

@ -23,7 +23,7 @@ func scaleService(req requests.PrometheusAlert, c *client.Client) error {
//Todo: convert to loop / handler. //Todo: convert to loop / handler.
serviceName := req.Alerts[0].Labels.FunctionName serviceName := req.Alerts[0].Labels.FunctionName
service, _, inspectErr := c.ServiceInspectWithRaw(context.Background(), serviceName) service, _, inspectErr := c.ServiceInspectWithRaw(context.Background(), serviceName)
if inspectErr != nil { if inspectErr == nil {
var replicas uint64 var replicas uint64
if req.Status == "firing" { if req.Status == "firing" {
@ -60,12 +60,17 @@ func scaleService(req requests.PrometheusAlert, c *client.Client) error {
func makeAlertHandler(c *client.Client) http.HandlerFunc { func makeAlertHandler(c *client.Client) http.HandlerFunc {
return func(w http.ResponseWriter, r *http.Request) { return func(w http.ResponseWriter, r *http.Request) {
log.Println("Alert received.") 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 var req requests.PrometheusAlert
err := json.Unmarshal(body, &req) err := json.Unmarshal(body, &req)
if err != nil { if err != nil {
log.Println(err) log.Println(err)
return
} }
if len(req.Alerts) > 0 { if len(req.Alerts) > 0 {