- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for buildClusterKey (0.15 sec)
-
pilot/pkg/networking/core/cluster_cache.go
return c.hits == 0 && c.miss == 0 } func (c cacheStats) merge(other cacheStats) cacheStats { return cacheStats{ hits: c.hits + other.hits, miss: c.miss + other.miss, } } func buildClusterKey(service *model.Service, port *model.Port, cb *ClusterBuilder, proxy *model.Proxy, efKeys []string) clusterCache { clusterName := model.BuildSubsetKey(model.TrafficDirectionOutbound, "", service.Hostname, port.Port)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 6.1K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster.go
if service.Resolution == model.Alias { continue } for _, port := range service.Ports { if port.Protocol == protocol.UDP { continue } clusterKey := buildClusterKey(service, port, cb, proxy, efKeys) cached, allFound := cb.getAllCachedSubsetClusters(clusterKey) if allFound && !features.EnableUnsafeAssertions { hit += len(cached) resources = append(resources, cached...)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 33K bytes - Viewed (0)