Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for buildMetricsNetworkFilters (0.34 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top