- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for HTTPFilters (0.4 sec)
-
pilot/pkg/networking/core/envoyfilter/listener_patch.go
} if lp.Operation == networking.EnvoyFilter_Patch_ADD { applied = true httpconn.HttpFilters = append(httpconn.HttpFilters, proto.Clone(lp.Value).(*hcm.HttpFilter)) } else if lp.Operation == networking.EnvoyFilter_Patch_INSERT_FIRST { httpconn.HttpFilters = append([]*hcm.HttpFilter{proto.Clone(lp.Value).(*hcm.HttpFilter)}, httpconn.HttpFilters...) } else if lp.Operation == networking.EnvoyFilter_Patch_INSERT_AFTER {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 15:39:29 UTC 2024 - 26.7K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_waypoint.go
} } h := lb.buildHTTPConnectionManager(httpOpts) // Last filter must be router. router := h.HttpFilters[len(h.HttpFilters)-1] h.HttpFilters = append(pre, h.HttpFilters[:len(h.HttpFilters)-1]...) h.HttpFilters = append(h.HttpFilters, post...) h.HttpFilters = append(h.HttpFilters, router) filters = append(filters, &listener.Filter{ Name: wellknown.HTTPConnectionManager,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 27.6K bytes - Viewed (0) -
pilot/test/xdstest/extract.go
nwFilters := []string{} httpFilters := []string{} for _, fc := range fcs.Filters { if fc.Name == wellknown.HTTPConnectionManager { h := &hcm.HttpConnectionManager{} if fc.GetTypedConfig() != nil { if err := fc.GetTypedConfig().UnmarshalTo(h); err != nil { t.Fatalf("failed to unmarshal hcm: %v", err) } } for _, hf := range h.HttpFilters { httpFilters = append(httpFilters, hf.Name)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 19 22:42:42 UTC 2023 - 13.9K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_builder.go
} } // TypedPerFilterConfig in route needs these filters. filters = append(filters, xdsfilters.Fault, xdsfilters.Cors) if !httpOpts.isWaypoint { filters = append(filters, lb.push.Telemetry.HTTPFilters(lb.node, httpOpts.class, nil)...) } // Add EmptySessionFilter so that it can be overridden at route level per service.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 17.9K bytes - Viewed (0) -
pilot/pkg/networking/grpcgen/grpcgen_test.go
_ = proto.Unmarshal(valBytes, ll) if strings.HasPrefix(ll.Name, "echo-persistent.test.svc.cluster.local:") { proto.Unmarshal(ll.ApiListener.ApiListener.Value, hcm) for index, f := range hcm.HttpFilters { if f.Name == util.StatefulSessionFilter { proto.Unmarshal(f.GetTypedConfig().Value, ss) filterIndex = index if ss.GetSessionState().Name == "envoy.http.stateful_session.cookie" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 09:04:02 UTC 2024 - 16.9K bytes - Viewed (0) -
pilot/pkg/networking/grpcgen/lds.go
PathSpecifier: &route.RouteMatch_Prefix{Prefix: "/"}, }, Action: &route.Route_NonForwardingAction{}, }}, }}, }, }, HttpFilters: fc, }), }, }}, } if tlsContext != nil { out.TransportSocket = &core.TransportSocket{ Name: transportSocketName,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 14.6K bytes - Viewed (0) -
pilot/pkg/model/telemetry.go
serverSpec.Disabled = true } cfg := TracingConfig{ ClientSpec: clientSpec, ServerSpec: serverSpec, } return &cfg } // HTTPFilters computes the HttpFilter for a given proxy/class func (t *Telemetries) HTTPFilters(proxy *Proxy, class networking.ListenerClass, svc *Service) []*hcm.HttpFilter { if res := t.telemetryFilters(proxy, class, networking.ListenerProtocolHTTP, svc); res != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 18:14:09 UTC 2024 - 35.2K bytes - Viewed (0) -
pilot/pkg/xds/lds_test.go
if err != nil { t.Fatalf("Could not deserialize http connection manager config: %v", err) } found := false for _, filter := range connectionManagerCfg.HttpFilters { if filter.Name == "envoy.lua" { found = true } } if expected != found { t.Fatalf("Expected Lua filter: %v, found: %v", expected, found) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 13.1K bytes - Viewed (0) -
pilot/pkg/networking/core/gateway.go
} filterChain.Filters = append(filterChain.Filters, filter) log.Debugf("attached HTTP filter with %d http_filter options to listener %q filter chain %d", len(httpConnectionManagers[i].HttpFilters), ml.Listener.Name, i) } } return nil } func (configgen *ConfigGeneratorImpl) buildGatewayListeners(builder *ListenerBuilder) *ListenerBuilder { if builder.node.MergedGateway == nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 46.4K bytes - Viewed (0)