Architecture-aware mechanisms and LB policies

Author: grussorusso

.github/workflows/run_tests.yml

@@ -0,0 +1,26 @@
+name: Run Tests CI
+
+on:
+  push:
+
+
+jobs:
+  build:
+    runs-on: ubuntu-latest
+
+    steps:
+      - name: Setup Go
+        uses: actions/setup-go@v3
+        with:
+          go-version: "1.24.0"
+
+      - name: Checkout branch
+        uses: actions/checkout@v4
+        with:
+          ref: ${{ github.ref_name }}
+
+      - name: Install dependencies
+        run: make
+
+      - name: Run tests
+        run: make unit-test && make test

Makefile

@@ -14,7 +14,7 @@ serverledge-cli:
 executor:
 	CGO_ENABLED=0 $(GO) build -o $(BIN)/$@ cmd/$@/executor.go
 
-DOCKERHUB_USER=grussorusso
+DOCKERHUB_USER=fmuschera
 images:  image-python310 image-nodejs17ng image-base
 image-python310:
 	docker build -t $(DOCKERHUB_USER)/serverledge-python310 -f images/python310/Dockerfile .
@@ -28,8 +28,16 @@ push-images:
 	docker push $(DOCKERHUB_USER)/serverledge-base
 	docker push $(DOCKERHUB_USER)/serverledge-nodejs17ng
 
+# Runs integration tests (all tests EXCEPT unit tests)
 test:
-	go test -v ./...
+	$(GO) test -v $(shell $(GO) list ./... | grep -Ev 'internal/container|examples')
 
-.PHONY: serverledge serverledge-cli lb executor test images
+# Runs only unit tests
+unit-test:
+	go test -v -short ./internal/container/... ./internal/lb/...
+
+.PHONY: serverledge serverledge-cli lb executor test unit-test integration-test images
+
+clean:
+	@test -n "$(BIN)" && [ -d "$(BIN)" ] && rm -rf $(BIN) || { echo "Invalid BIN directory: $(BIN)"; exit 1; } && go clean -testcache
 

README.md

@@ -69,7 +69,7 @@ Start a local Serverledge node:
 
 Register a function `func` from example python code (the handler is formatted like this: $(filename).$(functionName)):
 
-	$ bin/serverledge-cli create -f func --memory 600 --src examples/hello.py --runtime python310 --handler "hello.handler"
+	$ bin/serverledge-cli create -f func --memory 600 --src examples/hello.py --runtime python314 --handler "hello.handler"
 
 Register a function `func` from example javascript code (the handler is formatted like this: $(filename) and the name of the function is "handler"):
 

cmd/lb/main.go

@@ -2,12 +2,14 @@ package main
 
 import (
 	"fmt"
-	"github.com/serverledge-faas/serverledge/internal/node"
 	"log"
 	"os"
 	"os/signal"
 	"time"
 
+	"github.com/serverledge-faas/serverledge/internal/mab"
+	"github.com/serverledge-faas/serverledge/internal/node"
+
 	"golang.org/x/net/context"
 
 	"github.com/labstack/echo/v4"
@@ -59,5 +61,6 @@ func main() {
 	// Register a signal handler to cleanup things on termination
 	registerTerminationHandler(e)
 
+	mab.InitBanditManager()
 	lb.StartReverseProxy(e, myArea)
 }

examples/HelloFunction.java

@@ -0,0 +1,29 @@
+package com.test;
+
+// The compiled jar used by serverledge-cli is in ./java_build/target
+
+
+import java.util.Map;
+import java.util.HashMap;
+
+
+public class HelloFunction {
+
+
+    public Map<String, Object> handler(Object params, Map<String, Object> context) {
+        // Test output capture (stdout)
+        System.out.println("Log: Iniziata esecuzione Java Function!");
+        System.out.println("Log: Parametri ricevuti: " + params);
+
+        // Test output capture (stderr)
+        System.err.println("[DEBUG]: This is a debug message on stderr");
+
+
+        Map<String, Object> result = new HashMap<>();
+        result.put("message", "Hello from the Java default runtime of Serverledge!");
+        result.put("received_params", params);
+        result.put("java_version", System.getProperty("java.version"));
+
+        return result;
+    }
+}

examples/go-example/Makefile

@@ -0,0 +1,18 @@
+# EXAMPLE OF MAKEFILE
+
+AMD64_BIN=handler_amd64
+ARM64_BIN=handler_arm64
+
+all: $(AMD64_BIN) $(ARM64_BIN)
+
+$(AMD64_BIN):
+	CGO_ENABLED=0 GOOS=linux GOARCH=amd64 go build -ldflags="-s -w" -o $(AMD64_BIN) main.go
+
+$(ARM64_BIN):
+	CGO_ENABLED=0 GOOS=linux GOARCH=arm64 go build -ldflags="-s -w" -o $(ARM64_BIN) main.go
+
+zip: all
+	zip -j go-function.zip $(AMD64_BIN) $(ARM64_BIN)
+
+clean:
+	rm -f $(AMD64_BIN) $(ARM64_BIN) go-function.zip

examples/go-example/compiling-examples.md

@@ -0,0 +1,70 @@
+# Building Go Functions for Serverledge
+
+To ensure your Go function runs correctly on Serverledge's lightweight Alpine containers (avoiding `glibc` vs `musl` issues) and supports multi-architecture clusters (x86 & ARM), follow these build steps.
+
+## 1. Static Compilation
+You must disable CGO to make the executable self-contained and compatible with any Linux distribution (including Alpine and Scratch).
+You can check the example Makefile as well.
+
+### Create executables for both architectures (run **both** commands)
+```bash
+CGO_ENABLED=0 GOOS=linux GOARCH=amd64 go build -ldflags="-s -w" -o handler_amd64 main.go
+CGO_ENABLED=0 GOOS=linux GOARCH=arm64 go build -ldflags="-s -w" -o handler_arm64 main.go
+```
+Removing debugging information is not strictly necessary, but may help producing smaller executables. 
+
+## 2. Packaging the fat zip
+```bash
+zip -j function.zip handler_amd64 handler_arm64
+```
+
+## 3. Deploy to Serverledge
+```bash
+# create the function
+bin/serverledge-cli create \
+  -f gofunc \
+  --memory 300 \
+  --src examples/go-example/go-function.zip \
+  --runtime go125
+
+# and then execute it
+bin/serverledge-cli invoke \
+-f gofunc \
+-p "name:Serverledge User" \
+-p "num:127"
+
+# Expected output
+{
+        "Success": true,
+        "Result": "{\"message\":\"Hello Serverledge User\",\"number\":127,\"is_prime\":true}",
+        "ResponseTime": 0.397966139,
+        "IsWarmStart": false,
+        "InitTime": 0.3957812,
+        "QueueingTime": 0,
+        "OffloadLatency": 0,
+        "Duration": 0.002184848000000017,
+        "Output": ""
+}
+```
+
+### Or with output capture enabled
+```bash
+bin/serverledge-cli invoke \
+-f gofunc \
+-p "name:Serverledge User" \
+-p "num:127" \
+-o # flag to capture the output
+
+# Expected output
+{
+        "Success": true,
+        "Result": "{\"message\":\"Hello  Serverledge User\",\"number\":127,\"is_prime\":true}",
+        "ResponseTime": 0.001020982,
+        "IsWarmStart": true,
+        "InitTime": 0.000054193,
+        "QueueingTime": 0,
+        "OffloadLatency": 0,
+        "Duration": 0.000966691,
+        "Output": "2025/12/01 11:12:46 Processing request for user:  Serverledge User...\n2025/12/01 11:12:46 Checked number: 127 (Prime: true)\n"
+}
+```

examples/go-example/go-function.zip

@@ -0,0 +1,8 @@
+module go-example
+
+go 1.25
+
+// TODO: THIS HAS TO BE REMOVED IF THIS IS EVER MERGED TO THE MAIN REPOSITORY
+replace github.com/serverledge-faas/serverledge => github.com/FilippoMuschera/serverledge-tesi v0.0.0-20251201113838-6fd3cf13f0a4
+
+require github.com/serverledge-faas/serverledge v0.1.0

examples/go-example/go.mod

@@ -0,0 +1 @@
+github.com/FilippoMuschera/serverledge-tesi v0.0.0-20251201113838-6fd3cf13f0a4/go.mod h1:i84eEsGrw4XoYgA3zsiyFOk8bV7oA6S4LLR8137QvNE=