- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for ListenerFilters (0.33 sec)
-
pilot/pkg/networking/core/envoyfilter/listener_patch.go
if lp.Operation == networking.EnvoyFilter_Patch_ADD { lis.ListenerFilters = append(lis.ListenerFilters, proto.Clone(lp.Value).(*listener.ListenerFilter)) applied = true } else if lp.Operation == networking.EnvoyFilter_Patch_INSERT_FIRST { lis.ListenerFilters = append([]*listener.ListenerFilter{proto.Clone(lp.Value).(*listener.ListenerFilter)}, lis.ListenerFilters...) applied = true
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 15:39:29 UTC 2024 - 26.7K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
pilot/test/xdstest/extract.go
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 { for _, f := range l.GetFilterChains() { if f.GetName() == name {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 19 22:42:42 UTC 2023 - 13.9K bytes - Viewed (0)