- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for endpointCount (0.14 sec)
-
pilot/pkg/serviceregistry/util/xdsfake/updater.go
ID string Reason model.ReasonStats Namespace string // The endpoints associated with an EDS push if any Endpoints []*model.IstioEndpoint // EndpointCount, used in matches only EndpointCount int } func (fx *Updater) EDSUpdate(c model.ShardKey, hostname string, ns string, entry []*model.IstioEndpoint) { select {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 29 18:40:34 UTC 2024 - 6.2K bytes - Viewed (0) -
pkg/proxy/healthcheck/service_health.go
hcs.lock.Lock() defer hcs.lock.Unlock() for nsn, count := range newEndpoints { if hcs.services[nsn] == nil { continue } klog.V(3).InfoS("Reporting endpoints for healthcheck", "endpointCount", count, "service", nsn) hcs.services[nsn].endpoints = count } for nsn, hci := range hcs.services { if _, found := newEndpoints[nsn]; !found { hci.endpoints = 0 } } return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 30 09:25:48 UTC 2023 - 8.9K bytes - Viewed (0)