- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for listenerfilter (0.28 sec)
-
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) -
pilot/pkg/networking/core/envoyfilter/monitoring.go
const ( Error Result = "error" Applied Result = "applied" ) type PatchType string const ( Cluster PatchType = "cluster" Listener PatchType = "listener" ListenerFilter PatchType = "listenerfilter" FilterChain PatchType = "filterchain" NetworkFilter PatchType = "networkfilter" // nolint HttpFilter PatchType = "httpfilter" Route PatchType = "route" VirtualHost PatchType = "vhost"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 2.9K 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/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/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) -
istioctl/pkg/proxyconfig/proxyconfig.go
configdump.ClusterFilter{ FQDN: host.Name(fqdn), Port: port, Subset: subset, Direction: model.TrafficDirection(direction), }, configdump.ListenerFilter{ Address: address, Port: uint32(port), Type: listenerType, Verbose: verboseProxyConfig, }, configdump.RouteFilter{ Name: routeName,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 03:28:36 UTC 2024 - 48K bytes - Viewed (0) -
pilot/pkg/networking/core/listener.go
filterChains := make([]*listener.FilterChain, 0, len(opts.filterChainOpts)) var listenerFilters []*listener.ListenerFilter // Strip PROXY header first for non-QUIC traffic if requested. if opts.needPROXYProtocol { listenerFilters = append(listenerFilters, xdsfilters.ProxyProtocol) } // add a TLS inspector if we need to detect ServerName or ALPN
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 55.1K bytes - Viewed (0) -
istioctl/pkg/describe/describe.go
} // Return the first HTTP Connection Manager config for the inbound port func getInboundHTTPConnectionManager(cd *configdump.Wrapper, port int32) (*hcm.HttpConnectionManager, error) { filter := istio_envoy_configdump.ListenerFilter{ Port: uint32(port), } listeners, err := cd.GetListenerConfigDump() if err != nil { return nil, err } for _, l := range listeners.DynamicListeners { if l.ActiveState == 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) -
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/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)