Fixed cluster creation issue with connection pooling disabled

wso2 · Oct 31, 2024 · 9f00af2 · 9f00af2
1 parent 444d219
commit 9f00af2
Showing 1 changed file with 1 addition and 15 deletions.
diff --git a/adapter/internal/oasparser/envoyconf/routes_with_clusters.go b/adapter/internal/oasparser/envoyconf/routes_with_clusters.go
@@ -622,21 +622,7 @@ func processEndpoints(clusterName string, clusterDetails *model.EndpointCluster,
 	// If the endpoint is within the cluster, set the max requests per connection to 1
 	// This ensure cilium proxy will not reuse the connection
 	if withinClusterEndpoint && os.Getenv("ROUTER_DISABLE_IN_CLUSTER_CONNECTION_POOLING") == "true" {
-		config := &upstreams.HttpProtocolOptions{
-			CommonHttpProtocolOptions: &corev3.HttpProtocolOptions{
-				MaxRequestsPerConnection: wrapperspb.UInt32(1),
-			},
-		}
-
-		marshalledConfig, err := anypb.New(config)
-		if err != nil {
-			return nil, nil, errors.New("internal Error while marshalling the HTTP Protocol Options")
-		}
-
-		// Add to cluster's TypedExtensionProtocolOptions instead of deprecated fields
-		cluster.TypedExtensionProtocolOptions = map[string]*any.Any{
-			"envoy.extensions.upstreams.http.v3.HttpProtocolOptions": marshalledConfig,
-		}
+		cluster.MaxRequestsPerConnection = wrapperspb.UInt32(1)
 	}
 
 	if len(clusterDetails.Endpoints) > 1 {