- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 32 for listenerfilter (0.2 sec)
-
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/xds/testdata/none_lds_tcp.json
} } } } } } ] } ], "listener_filters": null }, "127.0.0.1_2000": { "name": "127.0.0.1_2000", "address": { "Address": { "SocketAddress": { "address": "127.0.0.1", "PortSpecifier": {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jul 22 21:13:54 UTC 2020 - 22.4K 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/xds/testdata/none_lds_http.json
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jan 13 02:10:15 UTC 2021 - 32.9K bytes - Viewed (0) -
releasenotes/notes/41541.yaml
apiVersion: release-notes/v2 kind: feature area: traffic-management issue: - 41445 releaseNotes: - |
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Oct 31 13:36:00 UTC 2022 - 255 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)