chore(examples): fix extensionserver build

Signed-off-by: Maxime Brunet <[email protected]>

Author: maxbrunet

examples/extension-server/Makefile

@@ -10,8 +10,8 @@ APP_NAME ?= extension-server
 TAG ?= latest
 
 .PHONY: docker-buildx
-docker-buildx:
-	docker buildx build -f tools/docker/extension-server/Dockerfile . -t $(IMAGE_PREFIX)$(APP_NAME):$(TAG) --build-arg GO_LDFLAGS="$(GO_LDFLAGS)" --load
+docker-buildx: build
+	docker buildx build -f tools/docker/extension-server/Dockerfile . -t $(IMAGE_PREFIX)$(APP_NAME):$(TAG) --load
 
 build: generate manifests
 	mkdir -p bin

examples/extension-server/charts/extension-server/crds/generated/example.extensions.io_listenercontextexamples.yaml

@@ -3,7 +3,7 @@ apiVersion: apiextensions.k8s.io/v1
 kind: CustomResourceDefinition
 metadata:
   annotations:
-    controller-gen.kubebuilder.io/version: v0.17.1
+    controller-gen.kubebuilder.io/version: v0.19.0
   name: listenercontextexamples.example.extensions.io
 spec:
   group: example.extensions.io
@@ -17,7 +17,7 @@ spec:
   - name: v1alpha1
     schema:
       openAPIV3Schema:
-        description: ListenerContext provides an example extension policy context
+        description: ListenerContextExample provides an example extension policy context
           resource.
         properties:
           apiVersion:

examples/extension-server/internal/extensionserver/post_cluster_modify.go

@@ -53,7 +53,7 @@ func (s *Server) PostClusterModify(ctx context.Context, req *pb.PostClusterModif
 			s.log.Info("found InferencePool for cluster modification",
 				slog.String("name", pool.GetName()),
 				slog.String("namespace", pool.GetNamespace()),
-				slog.Int("targetPortNumber", int(pool.Spec.TargetPortNumber)))
+				slog.Any("targetPorts", pool.Spec.TargetPorts))
 
 			inferencePoolConfigs = append(inferencePoolConfigs, &pool)
 		}

examples/extension-server/internal/extensionserver/post_route_modify.go

@@ -62,7 +62,7 @@ func (s *Server) PostRouteModify(ctx context.Context, req *pb.PostRouteModifyReq
 			s.log.Info("found InferencePool backend",
 				slog.String("name", pool.GetName()),
 				slog.String("namespace", pool.GetNamespace()),
-				slog.Int("targetPortNumber", int(pool.Spec.TargetPortNumber)))
+				slog.Any("targetPorts", pool.Spec.TargetPorts))
 			break
 		}
 	}
@@ -92,7 +92,7 @@ func (s *Server) PostRouteModify(ctx context.Context, req *pb.PostRouteModifyReq
 		slog.String("route_name", modifiedRoute.GetName()),
 		slog.String("inference_pool_name", inferencePool.GetName()),
 		slog.String("inference_pool_namespace", inferencePool.GetNamespace()),
-		slog.Int("target_port", int(inferencePool.Spec.TargetPortNumber)))
+		slog.Any("target_ports", inferencePool.Spec.TargetPorts))
 
 	return &pb.PostRouteModifyResponse{
 		Route: modifiedRoute,

examples/extension-server/internal/extensionserver/server_test.go

@@ -32,7 +32,9 @@ func TestPostRouteModify_WithInferencePool(t *testing.T) {
 			"namespace": "default",
 		},
 		"spec": map[string]interface{}{
-			"targetPortNumber": 8000,
+			"targetPorts": []map[string]interface{}{
+				{"number": 8000},
+			},
 			"selector": map[string]interface{}{
 				"app": "vllm-llama3-8b-instruct",
 			},
@@ -188,7 +190,9 @@ func TestPostClusterModify_WithInferencePool(t *testing.T) {
 			"namespace": "default",
 		},
 		"spec": map[string]interface{}{
-			"targetPortNumber": 8000,
+			"targetPorts": []map[string]interface{}{
+				{"number": 8000},
+			},
 			"selector": map[string]interface{}{
 				"app": "vllm-llama3-8b-instruct",
 			},