- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for ReadyzChecks (0.15 sec)
-
cmd/kube-scheduler/app/server.go
defer cc.EventBroadcaster.Shutdown() // Setup healthz checks. var checks, readyzChecks []healthz.HealthChecker if cc.ComponentConfig.LeaderElection.LeaderElect { checks = append(checks, cc.LeaderElection.WatchDog) readyzChecks = append(readyzChecks, cc.LeaderElection.WatchDog) } readyzChecks = append(readyzChecks, healthz.NewShutdownHealthz(ctx.Done())) waitingForLeader := make(chan struct{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 19:11:24 UTC 2024 - 14.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/config.go
c.LivezChecks = append(c.LivezChecks, healthChecks...) c.ReadyzChecks = append(c.ReadyzChecks, healthChecks...) } // AddReadyzChecks adds a health check to our config to be exposed by the readyz endpoint // of our configured apiserver. func (c *Config) AddReadyzChecks(healthChecks ...healthz.HealthChecker) { c.ReadyzChecks = append(c.ReadyzChecks, healthChecks...) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 47.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/etcd_test.go
t.Fatalf("Failed to add healthz error: %v", err) } healthChecksAreEqual(t, tc.wantHealthzChecks, serverConfig.HealthzChecks, "healthz") healthChecksAreEqual(t, tc.wantReadyzChecks, serverConfig.ReadyzChecks, "readyz") healthChecksAreEqual(t, tc.wantLivezChecks, serverConfig.LivezChecks, "livez") }) } } func TestReadinessCheck(t *testing.T) { testCases := []struct { name string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 16.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/etcd.go
} } return nil } func addHealthChecksWithoutLivez(c *server.Config, healthChecks ...healthz.HealthChecker) { c.HealthzChecks = append(c.HealthzChecks, healthChecks...) c.ReadyzChecks = append(c.ReadyzChecks, healthChecks...) } func (s *EtcdOptions) addEtcdHealthEndpoint(c *server.Config) error { healthCheck, err := storagefactory.CreateHealthCheck(s.StorageConfig, c.DrainedNotify()) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 15:02:16 UTC 2024 - 20K bytes - Viewed (0)