Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. pilot/pkg/networking/core/listenertest/match.go

    				t.Fatalf("%v: missing listener filters: %v", l.Name, missing)
    			}
    		}
    	}
    
    	// Check FilterChains
    	if lt.FilterChains != nil {
    		if lt.TotalMatch {
    			// First check they are the same size
    			if len(lt.FilterChains) != len(l.FilterChains) {
    				want := []string{}
    				for _, n := range lt.FilterChains {
    					want = append(want, n.Name)
    				}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  2. istioctl/pkg/writer/envoy/configdump/listener_test.go

    			},
    			inListener: &listener.Listener{
    				FilterChains: []*listener.FilterChain{{
    					Filters: []*listener.Filter{{
    						Name: wellknown.TCPProxy,
    					}},
    				}},
    			},
    			expect: true,
    		},
    		{
    			desc: "unknown-type",
    			inFilter: &ListenerFilter{
    				Type: "UNKNOWN",
    			},
    			inListener: &listener.Listener{
    				FilterChains: []*listener.FilterChain{{
    					Filters: []*listener.Filter{},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Sep 11 15:29:30 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/listener_test.go

    		if l == nil {
    			t.Fatalf("expected listener on port %d, but not found", 15080)
    		}
    		if len(l.FilterChains) != 1 {
    			t.Fatalf("expected %d filter chains, found %d", 1, len(l.FilterChains))
    		} else {
    			if !isHTTPFilterChain(l.FilterChains[0]) {
    				t.Fatalf("expected http filter chain, found %s", l.FilterChains[1].Filters[0].Name)
    			}
    			if len(l.ListenerFilters) > 0 {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 93.6K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/envoyfilter/listener_patch_test.go

    							PortValue: 6379,
    						},
    					},
    				},
    			},
    			FilterChains: []*listener.FilterChain{
    				{
    					Filters: []*listener.Filter{
    						{Name: "filter1"},
    						{Name: "filter2"},
    					},
    				},
    			},
    		},
    		{
    			Name: "redis-proxy",
    			FilterChains: []*listener.FilterChain{
    				{
    					FilterChainMatch: &listener.FilterChainMatch{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Apr 21 17:42:54 UTC 2024
    - 70.1K bytes
    - Viewed (0)
  5. istioctl/pkg/authz/listener.go

    						log.Errorf("found RBAC network filter but failed to parse: %s", err)
    					} else {
    						parsedFC.rbacTCP = append(parsedFC.rbacTCP, rbacTCP)
    					}
    				}
    			}
    
    			parsed.filterChains = append(parsed.filterChains, parsedFC)
    		}
    		parsedListeners = append(parsedListeners, parsed)
    	}
    	return parsedListeners
    }
    
    func extractName(name string) (string, string) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Sep 11 15:29:30 UTC 2023
    - 6K bytes
    - Viewed (0)
  6. 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)
  7. pilot/test/xdstest/validate.go

    	destPorts := sets.New[uint32]()
    	for _, fc := range l.FilterChains {
    		if fc.GetFilterChainMatch().GetDestinationPort() != nil {
    			destPorts.Insert(fc.GetFilterChainMatch().GetDestinationPort().GetValue())
    		}
    	}
    	for p := range destPorts {
    		hasTLSInspector := false
    		for _, fc := range l.FilterChains {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 17:09:02 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. 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)
Back to top