- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for NamedCheck (0.11 sec)
-
staging/src/k8s.io/apiserver/pkg/server/healthz/healthz.go
if notStarted := informersByStarted[false]; len(notStarted) > 0 { return fmt.Errorf("%d informers not started yet: %v", len(notStarted), notStarted) } return nil } // NamedCheck returns a healthz checker for the given name and function. func NamedCheck(name string, check func(r *http.Request) error) HealthChecker { return &healthzCheck{name, check} } // InstallHandler registers handlers for health checking on the path
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 19:11:24 UTC 2024 - 10.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/config_test.go
clientset := fake.NewSimpleClientset() if clientset == nil { t.Fatal("unable to create fake client set") } delegateConfig.HealthzChecks = append(delegateConfig.HealthzChecks, healthz.NamedCheck("delegate-health", func(r *http.Request) error { return fmt.Errorf("delegate failed healthcheck") })) sharedInformers := informers.NewSharedInformerFactory(clientset, delegateConfig.LoopbackClientConfig.Timeout)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 13.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/etcd.go
if err != nil { return err } c.AddHealthChecks(healthz.NamedCheck("etcd", func(r *http.Request) error { return healthCheck() })) readyCheck, err := storagefactory.CreateReadyCheck(s.StorageConfig, c.DrainedNotify()) if err != nil { return err } c.AddReadyzChecks(healthz.NamedCheck("etcd-readiness", func(r *http.Request) error { return readyCheck() })) return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 15:02:16 UTC 2024 - 20K bytes - Viewed (0) -
cmd/kube-scheduler/app/server.go
return !ok default: // channel is open, we are waiting for a leader return false } } handlerSyncReadyCh := make(chan struct{}) handlerSyncCheck := healthz.NamedCheck("sched-handler-sync", func(_ *http.Request) error { select { case <-handlerSyncReadyCh: return nil default: } return fmt.Errorf("waiting for handlers to sync") })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 19:11:24 UTC 2024 - 14.3K bytes - Viewed (0) -
pkg/controlplane/apiserver/aggregator.go
UpdateFunc: func(old, new interface{}) { handleAPIServiceChange(new.(*v1.APIService)) }, }) // Don't return healthy until the pending list is empty return healthz.NamedCheck(name, func(r *http.Request) error { pendingServiceNamesLock.RLock() defer pendingServiceNamesLock.RUnlock() if pendingServiceNames.Len() > 0 { return fmt.Errorf("missing APIService: %v", pendingServiceNames.List())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 18:08:20 UTC 2024 - 15.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/config.go
} func (h *kmsPluginProbe) toHealthzCheck(idx int) healthz.HealthChecker { return healthz.NamedCheck(fmt.Sprintf("kms-provider-%d", idx), func(r *http.Request) error { return h.check() }) } func (h *kmsv2PluginProbe) toHealthzCheck(idx int) healthz.HealthChecker { return healthz.NamedCheck(fmt.Sprintf("kms-provider-%d", idx), func(r *http.Request) error { return h.check(r.Context()) }) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 16:56:39 UTC 2024 - 41.2K bytes - Viewed (0) -
pkg/kubelet/server/server.go
// patterns with the restful Container. func (s *Server) InstallDefaultHandlers() { s.addMetricsBucketMatcher("healthz") healthz.InstallHandler(s.restfulCont, healthz.PingHealthz, healthz.LogHealthz, healthz.NamedCheck("syncloop", s.syncLoopHealthCheck), ) slis.SLIMetricsWithReset{}.Install(s.restfulCont) s.addMetricsBucketMatcher("pods") ws := new(restful.WebService) ws. Path("/pods").
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 40.1K bytes - Viewed (0)