Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 31 for FilterChains (0.54 sec)

  1. pilot/pkg/networking/core/gateway_test.go

    							{
    								Port: &networking.Port{Name: "http", Number: 80, Protocol: "HTTP"},
    							},
    						},
    					},
    				},
    			},
    			expectedListener: listenertest.ListenerTest{FilterChains: []listenertest.FilterChainTest{
    				{
    					NetworkFilters: []string{
    						wellknown.HTTPConnectionManager,
    					},
    					HTTPFilters: []string{
    						xdsfilters.MxFilterName,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 04:44:06 UTC 2024
    - 144K bytes
    - Viewed (0)
  2. 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)
  3. pilot/pkg/simulation/traffic.go

    		if alpn := protocolToAlpn(input.Protocol); alpn != "" && input.TLS == Plaintext {
    			input.Alpn = alpn
    		}
    	}
    
    	fc, err := sim.matchFilterChain(l.FilterChains, l.DefaultFilterChain, input, hasTLSInspector)
    	if err != nil {
    		result.Error = err
    		return
    	}
    	result.FilterChainMatched = fc.Name
    	// Plaintext to TLS is an error
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/fake.go

    	}
    	return cfgs
    }
    
    // copied from xdstest to avoid import issues
    func ExtractRoutesFromListeners(ll []*listener.Listener) []string {
    	routes := []string{}
    	for _, l := range ll {
    		for _, fc := range l.FilterChains {
    			for _, filter := range fc.Filters {
    				if filter.Name == wellknown.HTTPConnectionManager {
    					h := &hcm.HttpConnectionManager{}
    					_ = filter.GetTypedConfig().UnmarshalTo(h)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  5. pilot/test/xdstest/extract.go

    	for _, v := range res {
    		s.Insert(v.Name)
    	}
    	return s
    }
    
    func ExtractRoutesFromListeners(ll []*listener.Listener) []string {
    	routes := []string{}
    	for _, l := range ll {
    		for _, fc := range l.FilterChains {
    			for _, filter := range fc.Filters {
    				if filter.Name == wellknown.HTTPConnectionManager {
    					h := SilentlyUnmarshalAny[hcm.HttpConnectionManager](filter.GetTypedConfig())
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Dec 19 22:42:42 UTC 2023
    - 13.9K bytes
    - Viewed (0)
  6. pilot/pkg/networking/grpcgen/lds.go

    				SocketAddress: &core.SocketAddress{
    					Address: listenHost,
    					PortSpecifier: &core.SocketAddress_PortValue{
    						PortValue: uint32(listenPort),
    					},
    				},
    			}},
    			FilterChains: buildInboundFilterChains(node, push, si, mtlsPolicy),
    			// the following must not be set or the client will NACK
    			ListenerFilters: nil,
    			UseOriginalDst:  nil,
    		}
    		// add extra addresses for the listener
    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/networking/core/accesslog_test.go

    					t.Fatal("expected filter config in listener access log configuration")
    				}
    				// Verify listener access log.
    				verify(t, tc.encoding, l.AccessLog[0], tc.wantFormat)
    
    				for _, fc := range l.FilterChains {
    					for _, filter := range fc.Filters {
    						switch filter.Name {
    						case wellknown.TCPProxy:
    							tcpConfig := &tcp.TcpProxy{}
    							if err := filter.GetTypedConfig().UnmarshalTo(tcpConfig); err != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:30 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  8. istioctl/pkg/writer/envoy/configdump/listener.go

    	}
    	if l.Type != "" && !strings.EqualFold(retrieveListenerType(listener), l.Type) {
    		return false
    	}
    	return true
    }
    
    func getFilterChains(l *listener.Listener) []*listener.FilterChain {
    	res := l.FilterChains
    	if l.DefaultFilterChain != nil {
    		res = append(res, l.DefaultFilterChain)
    	}
    	return res
    }
    
    // retrieveListenerType classifies a Listener as HTTP|TCP|HTTP+TCP|UNKNOWN
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Nov 29 12:37:14 UTC 2023
    - 18.1K bytes
    - Viewed (0)
  9. istioctl/pkg/describe/describe.go

    		err = l.ActiveState.Listener.UnmarshalTo(listenerTyped)
    		if err != nil {
    			return nil, err
    		}
    		if listenerTyped.Name == model.VirtualInboundListenerName {
    			for _, filterChain := range listenerTyped.FilterChains {
    				for _, filter := range filterChain.Filters {
    					hcm := &hcm.HttpConnectionManager{}
    					if err := filter.GetTypedConfig().UnmarshalTo(hcm); err == nil {
    						return hcm, nil
    					}
    				}
    			}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Apr 13 05:23:38 UTC 2024
    - 50.4K bytes
    - Viewed (0)
  10. pkg/proxy/ipvs/proxier_test.go

    		iptablesData:          bytes.NewBuffer(nil),
    		filterChainsData:      bytes.NewBuffer(nil),
    		natChains:             proxyutil.NewLineBuffer(),
    		natRules:              proxyutil.NewLineBuffer(),
    		filterChains:          proxyutil.NewLineBuffer(),
    		filterRules:           proxyutil.NewLineBuffer(),
    		netlinkHandle:         netlinkHandle,
    		ipsetList:             ipsetList,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 186.8K bytes
    - Viewed (0)
Back to top