/* * P2PFaaS - A framework for FaaS Load Balancing * Copyright (c) 2019 - 2022. Gabriele Proietti Mattia * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation, either version 3 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program. If not, see . */ package faas_openfaas import ( "encoding/json" "io/ioutil" "scheduler/errors" "scheduler/log" "scheduler/types" ) func functionScaleApiCall(host string, functionName string, replicas uint) (*types.FaasApiResponse, error) { payload := FunctionScalePayload{ Service: functionName, Replicas: replicas, } payloadJson, err := json.Marshal(payload) if err != nil { return nil, errors.ErrorJSONEncode{} } res, err := HttpPostJSON(GetApiScaleFunction(host, functionName), string(payloadJson)) if err != nil { log.Log.Debugf("Cannot create POST request to %s: %s", GetApiSystemFunctionsUrl(host), err.Error()) return nil, err } body, _ := ioutil.ReadAll(res.Body) _ = res.Body.Close() response := types.FaasApiResponse{ Headers: res.Header, Body: body, StatusCode: res.StatusCode, } return &response, err }