- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for serviceProxyHealthy (0.27 sec)
-
pkg/proxy/healthcheck/healthcheck_test.go
} if payload.LocalEndpoints != endpoints { t.Errorf("expected %d endpoints, got %d", endpoints, payload.LocalEndpoints) } if payload.ServiceProxyHealthy != kubeProxyHealthy { t.Errorf("expected %v kubeProxyHealthy, got %v", kubeProxyHealthy, payload.ServiceProxyHealthy) } if !cmp.Equal(resp.Header()["Content-Type"], []string{"application/json"}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 13:27:41 UTC 2024 - 21.4K bytes - Viewed (0) -
pkg/proxy/healthcheck/service_health.go
} fmt.Fprint(resp, strings.Trim(dedent.Dedent(fmt.Sprintf(` { "service": { "namespace": %q, "name": %q }, "localEndpoints": %d, "serviceProxyHealthy": %v } `, h.name.Namespace, h.name.Name, count, kubeProxyHealthy)), "\n")) } func (hcs *server) SyncEndpoints(newEndpoints map[types.NamespacedName]int) error { hcs.lock.Lock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 30 09:25:48 UTC 2023 - 8.9K bytes - Viewed (0)