api: adds request/response attributes ExtProc options

api/v1alpha1/ext_proc_types.go

@@ -70,4 +70,18 @@ type ExtProc struct {
 	//
 	// +optional
 	ProcessingMode *ExtProcProcessingMode `json:"processingMode,omitempty"`
+
+	// RequestAttributes is a list of request attributes that should be sent to the external processor
+	// on the request_headers message. The possible attributes are defined in the envoy documentation:
+	// https://www.envoyproxy.io/docs/envoy/latest/intro/arch_overview/advanced/attributes#arch-overview-attributes
+	//
+	// +optional
+	RequestAttributes []string `json:"requestAttributes,omitempty"`
+
+	// ResponseAttributes is a list of response attributes that should be sent to the external processor
+	// on the response_headers message. The possible attributes are defined in the envoy documentation:
+	// https://www.envoyproxy.io/docs/envoy/latest/intro/arch_overview/advanced/attributes#arch-overview-attributes
+	//
+	// +optional
+	ResponseAttributes []string `json:"responseAttributes,omitempty"`
 }

charts/gateway-helm/crds/generated/gateway.envoyproxy.io_envoyextensionpolicies.yaml

@@ -940,6 +940,22 @@ spec:
                               type: string
                           type: object
                       type: object
+                    requestAttributes:
+                      description: |-
+                        RequestAttributes is a list of request attributes that should be sent to the external processor
+                        on the request_headers message. The possible attributes are defined in the envoy documentation:
+                        https://www.envoyproxy.io/docs/envoy/latest/intro/arch_overview/advanced/attributes#arch-overview-attributes
+                      items:
+                        type: string
+                      type: array
+                    responseAttributes:
+                      description: |-
+                        ResponseAttributes is a list of response attributes that should be sent to the external processor
+                        on the response_headers message. The possible attributes are defined in the envoy documentation:
+                        https://www.envoyproxy.io/docs/envoy/latest/intro/arch_overview/advanced/attributes#arch-overview-attributes
+                      items:
+                        type: string
+                      type: array
                   type: object
                   x-kubernetes-validations:
                   - message: BackendRefs must be used, backendRef is not supported.

internal/gatewayapi/envoyextensionpolicy.go

@@ -491,6 +491,14 @@ func (t *Translator) buildExtProc(
 		}
 	}
 
+	if extProc.RequestAttributes != nil {
+		extProcIR.RequestAttributes = extProc.RequestAttributes
+	}
+
+	if extProc.ResponseAttributes != nil {
+		extProcIR.ResponseAttributes = extProc.ResponseAttributes
+	}
+
 	return extProcIR, err
 }
 

internal/ir/xds.go

@@ -2546,6 +2546,12 @@ type ExtProc struct {
 
 	// ResponseBodyProcessingMode Defines response body processing
 	ResponseBodyProcessingMode *ExtProcBodyProcessingMode `json:"responseBodyProcessingMode,omitempty" yaml:"responseBodyProcessingMode,omitempty"`
+
+	// RequestAttributes defines the attributes to be sent to the external processor
+	RequestAttributes []string `json:"requestAttributes,omitempty" yaml:"requestAttributes,omitempty"`
+
+	// ResponseAttributes defines the attributes to be sent to the external processor
+	ResponseAttributes []string `json:"responseAttributes,omitempty" yaml:"responseAttributes,omitempty"`
 }
 
 // Wasm holds the information associated with the Wasm extensions.

internal/xds/translator/extproc.go

@@ -137,6 +137,14 @@ func extProcConfig(extProc ir.ExtProc) *extprocv3.ExternalProcessor {
 		config.ProcessingMode.ResponseHeaderMode = extprocv3.ProcessingMode_SEND
 	}
 
+	if extProc.RequestAttributes != nil {
+		config.RequestAttributes = extProc.RequestAttributes
+	}
+
+	if extProc.ResponseAttributes != nil {
+		config.ResponseAttributes = extProc.ResponseAttributes
+	}
+
 	return config
 }
 

test/cel-validation/envoyextensionpolicy_test.go

@@ -293,6 +293,8 @@ func TestEnvoyExtensionPolicyTarget(t *testing.T) {
 									},
 								},
 							},
+							RequestAttributes:  []string{"request.path"},
+							ResponseAttributes: []string{"response.code"},
 						},
 					},
 					PolicyTargetReferences: egv1a1.PolicyTargetReferences{