Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 16 of 16 for FilterChains (0.31 sec)

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