- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for endpointCount (0.15 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) -
pilot/pkg/serviceregistry/serviceentry/controller_test.go
// Delete the other config deleteConfigs([]*config.Config{wle}, store, t) instances = []*model.ServiceInstance{} expectServiceInstances(t, sd, selector, 0, instances) expectProxyInstances(t, sd, instances, "2.2.2.2") expectEvents(t, events, Event{Type: "eds", ID: "selector.com", Namespace: selector.Namespace, EndpointCount: 0}) // Add the config back
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 92.9K 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) -
pilot/pkg/serviceregistry/serviceregistry_test.go
fx.WaitOrFail(t, "proxy") fx.AssertEmpty(t, 40*time.Millisecond) makeService(t, kube, service) fx.MatchOrFail(t, xdsfake.Event{Type: "eds cache", EndpointCount: 1}) instances := []EndpointResponse{{ Address: workloadEntry.Spec.(*networking.WorkloadEntry).Address, Port: 80, }} expectServiceEndpoints(t, fx, expectedSvc, 80, instances) })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 51.2K bytes - Viewed (0)