Get ILP Optimizer host and port from configuration

Author: matnar

internal/config/keys.go

@@ -84,3 +84,9 @@ const TRACING_OUTFILE = "tracing.outfile"
 // Offloading policy to use
 // Possible values: "disable", "ilp"
 const OFFLOADING_POLICY = "offloading.policy"
+
+// Port used by ILP Offloading Policy for solving the ILP formulation
+const OFFLOADING_POLICY_ILP_OPTIMIZER_PORT = "offloading.policy.ilp.port"
+
+// IP address / hostname used by ILP Offloading Policy for solving the ILP formulation
+const OFFLOADING_POLICY_ILP_OPTIMIZER_HOST = "offloading.policy.ilp.host"

internal/workflow/ilp_offloading_policy.go

@@ -8,6 +8,7 @@ import (
 	"strconv"
 	"time"
 
+	"github.com/serverledge-faas/serverledge/internal/config"
 	"github.com/serverledge-faas/serverledge/internal/function"
 	"github.com/serverledge-faas/serverledge/internal/metrics"
 	"github.com/serverledge-faas/serverledge/internal/node"
@@ -278,7 +279,9 @@ func (policy *IlpOffloadingPolicy) Evaluate(r *Request, p *Progress) (Offloading
 	}
 
 	// Create POST request
-	url := "http://localhost:8080/" // TODO: configurable
+	ilpOptimizerHost := config.GetString(config.OFFLOADING_POLICY_ILP_OPTIMIZER_HOST, "localhost")
+	ilpOptimizerPort := config.GetInt(config.OFFLOADING_POLICY_ILP_OPTIMIZER_PORT, 8080)
+	url := fmt.Sprintf("http://%s:%d", ilpOptimizerHost, ilpOptimizerPort)
 	req, err := http.NewRequest("POST", url, bytes.NewBuffer(jsonData))
 	if err != nil {
 		panic(err)