- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for buildMetricsNetworkFilters (0.34 sec)
-
pilot/pkg/networking/core/networkfilter.go
if features.MetadataExchange { filterstack = append(filterstack, xdsfilters.TCPListenerMx) } return filterstack } func buildMetricsNetworkFilters(push *model.PushContext, proxy *model.Proxy, class istionetworking.ListenerClass, svc *model.Service) []*listener.Filter { return push.Telemetry.TCPFilters(proxy, class, svc) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 13.7K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_builder.go
StatPrefix: egressCluster, ClusterSpecifier: &tcp.TcpProxy_Cluster{Cluster: egressCluster}, IdleTimeout: parseDuration(node.Metadata.IdleTimeout), } filterStack := buildMetricsNetworkFilters(push, node, istionetworking.ListenerClassSidecarOutbound, nil) accessLogBuilder.setTCPAccessLog(push, node, tcpProxy, istionetworking.ListenerClassSidecarOutbound, nil) filterStack = append(filterStack, &listener.Filter{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 17.9K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_inbound.go
var filters []*listener.Filter if !lb.node.IsWaypointProxy() { filters = append(filters, buildMetadataExchangeNetworkFilters()...) } filters = append(filters, buildMetricsNetworkFilters(lb.push, lb.node, istionetworking.ListenerClassSidecarInbound, nil)...) filters = append(filters, &listener.Filter{ Name: wellknown.TCPProxy,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 35.1K bytes - Viewed (0)