UUpdate pkg/body-based-routing/README.md

Co-authored-by: Rob Scott <[email protected]>

Author: rramkumar1

cmd/body-based-routing/health.go

@@ -27,7 +27,7 @@ import (
 )
 
 type healthServer struct {
-	logger    logr.Logger
+	logger logr.Logger
 }
 
 func (s *healthServer) Check(ctx context.Context, in *healthPb.HealthCheckRequest) (*healthPb.HealthCheckResponse, error) {

cmd/body-based-routing/main.go

@@ -40,7 +40,7 @@ var (
 		"grpcHealthPort",
 		9003,
 		"The port used for gRPC liveness and readiness probes")
-	
+
 	setupLog = ctrl.Log.WithName("setup")
 )
 
@@ -106,7 +106,7 @@ func run() error {
 func registerHealthServer(mgr manager.Manager, logger logr.Logger, port int) error {
 	srv := grpc.NewServer()
 	healthPb.RegisterHealthServer(srv, &healthServer{
-		logger:    logger,
+		logger: logger,
 	})
 	if err := mgr.Add(
 		runnable.NoLeaderElection(runnable.GRPCServer("health", srv, port))); err != nil {

pkg/body-based-routing/handlers/request.go

@@ -20,11 +20,14 @@ import (
 	"context"
 	"fmt"
 	"encoding/json"
+	"fmt"
 
         "sigs.k8s.io/controller-runtime/pkg/log"
 	logutil "sigs.k8s.io/gateway-api-inference-extension/pkg/epp/util/logging"
 	basepb "github.com/envoyproxy/go-control-plane/envoy/config/core/v3"
 	eppb "github.com/envoyproxy/go-control-plane/envoy/service/ext_proc/v3"
+	"sigs.k8s.io/controller-runtime/pkg/log"
+	logutil "sigs.k8s.io/gateway-api-inference-extension/pkg/epp/util/logging"
 )
 
 // HandleRequestBody handles request bodies.
@@ -48,7 +51,7 @@ func (s *Server) HandleRequestBody(ctx context.Context, body *eppb.HttpBody) (*e
 
 	modelStr, ok := modelVal.(string)
 	if !ok {
-		logger.V(logutil.DEFAULT).Error("Model parameter value is not a string")
+		logger.V(logutil.DEFAULT).Info("Model parameter value is not a string")
 		return &eppb.ProcessingResponse{
 			Response: &eppb.ProcessingResponse_RequestBody{
 				RequestBody: &eppb.BodyResponse{},

pkg/body-based-routing/handlers/server.go

@@ -34,7 +34,7 @@ func NewServer() *Server {
 
 // Server implements the Envoy external processing server.
 // https://www.envoyproxy.io/docs/envoy/latest/api-v3/service/ext_proc/v3/external_processor.proto
-type Server struct {}
+type Server struct{}
 
 func (s *Server) Process(srv extProcPb.ExternalProcessor_ProcessServer) error {
 	ctx := srv.Context()
@@ -66,7 +66,7 @@ func (s *Server) Process(srv extProcPb.ExternalProcessor_ProcessServer) error {
 		case *extProcPb.ProcessingRequest_RequestHeaders:
 			resp, err = s.HandleRequestHeaders(req.GetRequestHeaders())
 		case *extProcPb.ProcessingRequest_RequestBody:
-			resp, err = s.HandleRequestBody(req.GetRequestBody())
+			resp, err = s.HandleRequestBody(ctx, req.GetRequestBody())
 		case *extProcPb.ProcessingRequest_ResponseHeaders:
 			resp, err = s.HandleResponseHeaders(req.GetResponseHeaders())
 		case *extProcPb.ProcessingRequest_ResponseBody:

pkg/body-based-routing/server/runserver.go

@@ -32,8 +32,8 @@ import (
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/credentials"
 	"sigs.k8s.io/controller-runtime/pkg/manager"
-	"sigs.k8s.io/gateway-api-inference-extension/pkg/body-based-routing/handlers"
 	"sigs.k8s.io/gateway-api-inference-extension/internal/runnable"
+	"sigs.k8s.io/gateway-api-inference-extension/pkg/body-based-routing/handlers"
 )
 
 // ExtProcServerRunner provides methods to manage an external process server.
@@ -43,7 +43,7 @@ type ExtProcServerRunner struct {
 
 // Default values for CLI flags in main
 const (
-	DefaultGrpcPort = 9002  // default for --grpcPort
+	DefaultGrpcPort = 9002 // default for --grpcPort
 )
 
 func NewDefaultExtProcServerRunner() *ExtProcServerRunner {