Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for FilterChains (0.26 sec)

  1. pilot/pkg/xds/lds_test.go

    	// instead of looking at it as a listener with multiple filter chains
    	l := adsc.GetHTTPListeners()["0.0.0.0_443"]
    
    	if l != nil {
    		if len(l.FilterChains) != 3 {
    			t.Fatalf("Expected 3 filter chains, got %d\n", len(l.FilterChains))
    		}
    	}
    }
    
    // TestLDS is running LDS tests.
    func TestLDS(t *testing.T) {
    	t.Run("sidecar", func(t *testing.T) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jan 12 18:20:36 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  2. pilot/pkg/networking/core/listener_inbound.go

    				fcm.TransportProtocol = ""
    			}
    		}
    		l.FilterChains = append(l.FilterChains, chains...)
    	}
    	// If there are no filter chains, populate a dummy one that never matches. Envoy doesn't allow no chains, but removing the
    	// entire listeners makes the errors logs more confusing (instead of "no filter chain found" we have no listener at all).
    	if len(l.FilterChains) == 0 {
    		l.FilterChains = []*listener.FilterChain{{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 35.1K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/gateway.go

    	}
    	httpConnectionManagers := make([]*hcm.HttpConnectionManager, len(ml.Listener.FilterChains))
    	for i := range ml.Listener.FilterChains {
    		filterChain := ml.Listener.FilterChains[i]
    		opt := opts.filterChainOpts[i]
    		ml.Listener.FilterChains[i].Metadata = opt.metadata
    		if opt.httpOpts == nil {
    			filterChain.Filters = opt.networkFilters
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 04:44:06 UTC 2024
    - 46.4K bytes
    - Viewed (0)
  4. pilot/pkg/xds/xds_test.go

    			Equals("virtualOutbound", "{.name}").
    			Equals("0.0.0.0", "{.address.socketAddress.address}").
    			Equals(wellknown.TCPProxy, "{.filterChains[1].filters[0].name}").
    			Equals("PassthroughCluster", "{.filterChains[1].filters[0].typedConfig.cluster}").
    			Equals("PassthroughCluster", "{.filterChains[1].filters[0].typedConfig.statPrefix}").
    			Equals(true, "{.useOriginalDst}").
    			CheckOrFail(t)
    	})
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Mar 27 16:59:05 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  5. pilot/pkg/networking/core/envoyfilter/listener_patch.go

    				continue
    			}
    			IncrementEnvoyFilterMetric(lp.Key(), FilterChain, true)
    			lis.FilterChains = append(lis.FilterChains, proto.Clone(lp.Value).(*listener.FilterChain))
    		}
    	}
    	if filterChainsRemoved {
    		lis.FilterChains = slices.FilterInPlace(lis.FilterChains, func(fc *listener.FilterChain) bool {
    			return fc.Filters != nil
    		})
    	}
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 17 15:39:29 UTC 2024
    - 26.7K bytes
    - Viewed (0)
  6. pkg/adsc/delta_test.go

    			SocketAddress: &core.SocketAddress{
    				Protocol: core.SocketAddress_TCP,
    				Address:  "0.0.0.0",
    				PortSpecifier: &core.SocketAddress_PortValue{
    					PortValue: 8080,
    				},
    			},
    		},
    	},
    	FilterChains: []*listener.FilterChain{
    		{
    			Filters: []*listener.Filter{
    				{
    					Name: wellknown.HTTPConnectionManager,
    					ConfigType: &listener.Filter_TypedConfig{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Feb 02 09:32:41 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  7. pilot/pkg/networking/core/listener_builder.go

    		Address:          util.BuildAddress(actualWildcards[0], uint32(lb.push.Mesh.ProxyListenPort)),
    		Transparent:      isTransparentProxy,
    		UseOriginalDst:   proto.BoolTrue,
    		FilterChains:     filterChains,
    		TrafficDirection: core.TrafficDirection_OUTBOUND,
    	}
    	// add extra addresses for the listener
    	if features.EnableDualStack && len(actualWildcards) > 1 {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 04:44:06 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  8. pilot/pkg/networking/core/listener_builder_test.go

    		if vi == nil {
    			t.Fatalf("expect virtual inbound listener, found %s", listeners[0].Name)
    		}
    
    		byListenerName := map[string]int{}
    
    		for _, fc := range vi.FilterChains {
    			byListenerName[fc.Name]++
    		}
    
    		for k, v := range byListenerName {
    			if k == model.VirtualInboundListenerName && v != 3 {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 24.7K bytes
    - Viewed (0)
  9. pilot/pkg/networking/core/listener_waypoint.go

    	actualWildcard, _ := getActualWildcardAndLocalHost(lb.node)
    	l := &listener.Listener{
    		Name:    ConnectTerminate,
    		Address: util.BuildAddress(actualWildcard, model.HBoneInboundListenPort),
    		FilterChains: []*listener.FilterChain{
    			{
    				Name: "default",
    				TransportSocket: &core.TransportSocket{
    					Name: "tls",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 27.6K bytes
    - Viewed (0)
  10. pkg/adsc/adsc.go

    			// TODO: extract VIP and RDS or cluster
    			continue
    		}
    		fc := l.FilterChains[len(l.FilterChains)-1]
    		// Find the terminal filter
    		filter := fc.Filters[len(fc.Filters)-1]
    
    		// The actual destination will be the next to the last if the last filter is a passthrough filter
    		if fc.GetName() == util.PassthroughFilterChain {
    			fc = l.FilterChains[len(l.FilterChains)-2]
    			filter = fc.Filters[len(fc.Filters)-1]
    		}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Feb 05 22:18:49 UTC 2024
    - 35K bytes
    - Viewed (0)
Back to top