Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for HTTPFilters (0.4 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
Back to top