Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 30 for listenerFilters (0.19 sec)

  1. pilot/pkg/networking/core/envoyfilter/listener_patch.go

    				continue
    			}
    			lis.ListenerFilters, applied = insertBeforeFunc(
    				lis.ListenerFilters,
    				func(e *listener.ListenerFilter) (bool, *listener.ListenerFilter) {
    					if listenerFilterMatch(e, lp) {
    						return true, proto.Clone(lp.Value).(*listener.ListenerFilter)
    					}
    					return false, 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)
  2. pilot/pkg/networking/core/networkfilter_test.go

    				clusterName:       "inbound|8888||",
    				port: model.ServiceInstancePort{
    					ServicePort: &model.Port{},
    				},
    			}
    
    			listenerFilters := NewListenerBuilder(cg.SetupProxy(nil), cg.PushContext()).buildInboundNetworkFilters(fcc)
    			tcp := &tcp.TcpProxy{}
    			listenerFilters[len(listenerFilters)-1].GetTypedConfig().UnmarshalTo(tcp)
    			if tcp.StatPrefix != tt.expectedStatPrefix {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 22:20:44 UTC 2024
    - 25.8K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/listenertest/match.go

    	}
    }
    
    func VerifyListener(t test.Failer, l *listener.Listener, lt ListenerTest) {
    	t.Helper()
    	haveFilters := []string{}
    	for _, lf := range l.ListenerFilters {
    		haveFilters = append(haveFilters, lf.Name)
    	}
    
    	// Check ListenerFilters
    
    	if lt.Filters != nil {
    		if lt.TotalMatch {
    			assert.Equal(t, lt.Filters, haveFilters, l.Name+": listener filters should be equal")
    		} else {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/listener.go

    	// removed, but have not yet
    	if needTLSInspector || needHTTPInspector {
    		l.ListenerFilters = append(l.ListenerFilters, xdsfilters.TLSInspector)
    	}
    
    	if needHTTPInspector {
    		l.ListenerFilters = append(l.ListenerFilters, xdsfilters.HTTPInspector)
    		// Enable timeout only if they configure it and we have an HTTP inspector.
    		// This is really unsafe, so hopefully not used...
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 04:44:06 UTC 2024
    - 55.1K bytes
    - Viewed (0)
  5. pilot/pkg/networking/core/listener_inbound.go

    	}
    	lb.authzBuilder = oldBuilder
    	accessLogBuilder.setListenerAccessLog(lb.push, lb.node, l, istionetworking.ListenerClassSidecarInbound)
    	l.ListenerFilters = append(l.ListenerFilters, xdsfilters.OriginalDestination)
    	// TODO: Exclude inspectors from some inbound ports.
    	l.ListenerFilters = append(l.ListenerFilters, populateListenerFilters(lb.node, l, true)...)
    	return []*listener.Listener{terminate, l}
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 35.1K bytes
    - Viewed (0)
  6. pilot/pkg/networking/core/envoyfilter/listener_patch_test.go

    			DefaultFilterChain: &listener.FilterChain{
    				Filters: []*listener.Filter{
    					{Name: "default-network-filter"},
    					{Name: "default-network-filter-removed"},
    				},
    			},
    			ListenerFilters: []*listener.ListenerFilter{
    				{
    					Name: "filter-to-be-removed",
    				},
    				{
    					Name: "filter-before-replace",
    				},
    			},
    		},
    		{
    			Name: "another-listener",
    		},
    		{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Apr 21 17:42:54 UTC 2024
    - 70.1K bytes
    - Viewed (0)
  7. pilot/test/xdstest/validate.go

    func validateInspector(t testing.TB, l *listener.Listener) {
    	t.Helper()
    	for _, lf := range l.ListenerFilters {
    		if lf.Name == xdsfilters.TLSInspector.Name {
    			return
    		}
    	}
    	for _, fc := range l.FilterChains {
    		m := fc.FilterChainMatch
    		if fc.FilterChainMatch == nil {
    			continue
    		}
    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_test.go

    		} 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 {
    				t.Fatalf("expected %d listener filter, found %d", 0, len(l.ListenerFilters))
    			}
    		}
    	}
    }
    
    func TestGetActualWildcardAndLocalHost(t *testing.T) {
    	tests := []struct {
    		name     string
    		proxy    *model.Proxy
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 93.6K bytes
    - Viewed (0)
  9. pilot/pkg/networking/core/listener_waypoint.go

    		}
    	}
    	l := &listener.Listener{
    		Name:              MainInternalName,
    		ListenerSpecifier: &listener.Listener_InternalListener{InternalListener: &listener.Listener_InternalListenerConfig{}},
    		ListenerFilters: []*listener.ListenerFilter{
    			xdsfilters.OriginalDestination,
    			// TODO: This may affect the data path due to the server-first protocols triggering a time-out. Need exception filter.
    			xdsfilters.HTTPInspector,
    		},
    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. pilot/test/xdstest/extract.go

    	for _, l := range rc {
    		res[l.Name] = l
    	}
    	return res
    }
    
    func ExtractListenerFilters(l *listener.Listener) map[string]*listener.ListenerFilter {
    	res := map[string]*listener.ListenerFilter{}
    	for _, lf := range l.ListenerFilters {
    		res[lf.Name] = lf
    	}
    	return res
    }
    
    func ExtractFilterChain(name string, l *listener.Listener) *listener.FilterChain {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Dec 19 22:42:42 UTC 2023
    - 13.9K bytes
    - Viewed (0)
Back to top