Configure OffloadingPolicy using configuration parameters

Author: matnar

cmd/serverledge/main.go

@@ -16,6 +16,7 @@ import (
 	"github.com/serverledge-faas/serverledge/internal/registration"
 	"github.com/serverledge-faas/serverledge/internal/scheduling"
 	"github.com/serverledge-faas/serverledge/internal/telemetry"
+	"github.com/serverledge-faas/serverledge/internal/workflow"
 	"github.com/serverledge-faas/serverledge/utils"
 
 	"github.com/labstack/echo/v4"
@@ -85,9 +86,13 @@ func main() {
 	// Register a signal handler to cleanup things on termination
 	api.RegisterTerminationHandler(registry, e)
 
+	// Function scheduling policy
 	schedulingPolicy := api.CreateSchedulingPolicy()
 	go scheduling.Run(schedulingPolicy)
 
+	// Workflow offloading policy
+	workflow.CreateOffloadingPolicy()
+
 	if !isInCloud {
 		err = registration.InitEdgeMonitoring(registry)
 		if err != nil {

internal/api/server.go

@@ -108,7 +108,7 @@ func RegisterTerminationHandler(r *registration.Registry, e *echo.Echo) {
 
 func CreateSchedulingPolicy() scheduling.Policy {
 	policyConf := config.GetString(config.SCHEDULING_POLICY, "default")
-	log.Printf("Configured policy: %s\n", policyConf)
+	log.Printf("Configured scheduling policy: %s\n", policyConf)
 	if policyConf == "cloudonly" {
 		return &scheduling.CloudOnlyPolicy{}
 	} else if policyConf == "edgecloud" {

internal/config/keys.go

@@ -80,3 +80,7 @@ const TRACING_ENABLED = "tracing.enabled"
 
 // Custom output file for traces
 const TRACING_OUTFILE = "tracing.outfile"
+
+// Offloading policy to use
+// Possible values: "disable", "ilp"
+const OFFLOADING_POLICY = "offloading.policy"

internal/test/main_test.go

@@ -16,6 +16,7 @@ import (
 	"github.com/serverledge-faas/serverledge/internal/node"
 	"github.com/serverledge-faas/serverledge/internal/registration"
 	"github.com/serverledge-faas/serverledge/internal/scheduling"
+	"github.com/serverledge-faas/serverledge/internal/workflow"
 	u "github.com/serverledge-faas/serverledge/utils"
 	"google.golang.org/grpc/codes"
 )
@@ -66,6 +67,9 @@ func testStartServerledge(isInCloud bool, outboundIp string) (*registration.Regi
 
 	metrics.Init()
 
+	// Workflow offloading policy
+	workflow.CreateOffloadingPolicy()
+
 	e := echo.New()
 
 	// Register a signal handler to cleanup things on termination

internal/workflow/workflow.go

@@ -6,6 +6,7 @@ import (
 	"errors"
 	"fmt"
 	"github.com/serverledge-faas/serverledge/internal/client"
+	"github.com/serverledge-faas/serverledge/internal/config"
 	"golang.org/x/exp/slices"
 	"io"
 	"net/http"
@@ -23,7 +24,15 @@ import (
 
 var offloadingPolicy OffloadingPolicy = &IlpOffloadingPolicy{}
 
-//&NoOffloadingPolicy{} // TODO: handle initialization elsewhere
+func CreateOffloadingPolicy() {
+	policyConf := config.GetString(config.OFFLOADING_POLICY, "disable")
+	log.Printf("Configured offloading policy: %s\n", policyConf)
+	if policyConf == "ilp" {
+		offloadingPolicy = &IlpOffloadingPolicy{}
+	} else { // default, disable offloading
+		offloadingPolicy = &NoOffloadingPolicy{}
+	}
+}
 
 // Workflow is a Workflow to drive the execution of the workflow
 type Workflow struct {