added to OnChange() for getting loaded during DAG build

Author: YashNandwana

apis/projectcontour/v1alpha1/contourconfig.go

@@ -438,7 +438,7 @@ type EnvoyListenerConfig struct {
 	// connection open where possible (if the entire request is read for HTTP/1.1)
 	//
 	// +optional
-	StreamErrorOnInvalidHTTP bool `json:"streamErrorOnInvalidHTTP,omitempty"`
+	StreamErrorOnInvalidHTTP *bool `json:"streamErrorOnInvalidHTTP,omitempty"`
 }
 
 // SocketOptions defines configurable socket options for Envoy listeners.

internal/xdscache/v3/listener.go

@@ -402,6 +402,7 @@ func (c *ListenerCache) OnChange(root *dag.DAG) {
 				StripTrailingHostDot(cfg.StripTrailingHostDot).
 				MaxRequestsPerConnection(cfg.MaxRequestsPerConnection).
 				HTTP2MaxConcurrentStreams(cfg.HTTP2MaxConcurrentStreams).
+				StreamErrorOnInvalidHTTP(cfg.StreamErrorOnInvalidHTTP).
 				AddFilter(httpGlobalExternalAuthConfig(cfg.GlobalExternalAuthConfig)).
 				Tracing(envoy_v3.TracingConfig(envoyTracingConfig(cfg.TracingConfig))).
 				AddFilter(envoy_v3.GlobalRateLimitFilter(envoyGlobalRateLimitConfig(cfg.RateLimitConfig))).
@@ -482,6 +483,7 @@ func (c *ListenerCache) OnChange(root *dag.DAG) {
 					ForwardClientCertificate(forwardClientCertificate).
 					MaxRequestsPerConnection(cfg.MaxRequestsPerConnection).
 					HTTP2MaxConcurrentStreams(cfg.HTTP2MaxConcurrentStreams).
+					StreamErrorOnInvalidHTTP(cfg.StreamErrorOnInvalidHTTP).
 					EnableWebsockets(listener.EnableWebsockets).
 					Get()
 
@@ -565,6 +567,7 @@ func (c *ListenerCache) OnChange(root *dag.DAG) {
 					ForwardClientCertificate(forwardClientCertificate).
 					MaxRequestsPerConnection(cfg.MaxRequestsPerConnection).
 					HTTP2MaxConcurrentStreams(cfg.HTTP2MaxConcurrentStreams).
+					StreamErrorOnInvalidHTTP(cfg.StreamErrorOnInvalidHTTP).
 					EnableWebsockets(listener.EnableWebsockets).
 					Get()
 

pkg/config/parameters.go

@@ -1112,7 +1112,8 @@ func Defaults() Parameters {
 			EnvoyAdminPort:            9001,
 		},
 		Listener: ListenerParameters{
-			ConnectionBalancer: "",
+			ConnectionBalancer:       "",
+			StreamErrorOnInvalidHTTP: false,
 		},
 	}
 }