- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 95 for healthChecks (0.17 sec)
-
pkg/kubelet/runtime.go
s.Lock() defer s.Unlock() s.healthChecks = append(s.healthChecks, &healthCheck{name: name, fn: f}) } func (s *runtimeState) setRuntimeSync(t time.Time) { s.Lock() defer s.Unlock() s.lastBaseRuntimeSync = t } func (s *runtimeState) setNetworkState(err error) { s.Lock() defer s.Unlock() s.networkError = err } func (s *runtimeState) setRuntimeState(err error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 00:48:07 UTC 2024 - 3.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/controller/controller_test.go
}, mockLoadEncryptionConfig: func(ctx context.Context, filepath string, reload bool, apiServerID string) (*encryptionconfig.EncryptionConfiguration, error) { return &encryptionconfig.EncryptionConfiguration{ HealthChecks: []healthz.HealthChecker{ &mockHealthChecker{ pluginName: "valid-plugin", err: nil, }, }, EncryptionFileContentHash: "some new config hash", }, nil },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 16.2K 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 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 15:02:16 UTC 2024 - 20K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/controller/controller.go
if !configChanged { return } if len(encryptionConfiguration.HealthChecks) != 1 { err = fmt.Errorf("unexpected number of healthz checks: %d. Should have only one", len(encryptionConfiguration.HealthChecks)) return } // get healthz checks for all new KMS plugins. if err = d.validateNewTransformersHealth(ctx, encryptionConfiguration.HealthChecks[0], encryptionConfiguration.KMSCloseGracePeriod); err != nil { return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.5K bytes - Viewed (0) -
pkg/kubeapiserver/authenticator/config.go
} jwtAuthenticators = append(jwtAuthenticators, oidcAuth) healthChecks = append(healthChecks, oidcAuth.HealthCheck) } return &jwtAuthenticatorWithCancel{ jwtAuthenticator: authenticator.WrapAudienceAgnosticToken(apiAudiences, tokenunion.NewFailOnError(jwtAuthenticators...)), // this handles the empty jwtAuthenticators slice case correctly healthCheck: func() error { var errs []error for _, check := range healthChecks {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 19:29:33 UTC 2024 - 15.4K bytes - Viewed (0) -
cmd/kubeadm/app/phases/upgrade/health.go
_, _ = printer.Println("[upgrade] Running cluster health checks") healthChecks := []preflight.Checker{ &healthCheck{ name: "CreateJob", client: client, cfg: cfg, f: createJob, }, &healthCheck{ name: "ControlPlaneNodesReady", client: client, f: controlPlaneNodesReady, }, &healthCheck{ name: "StaticPodManifest", f: staticPodManifestHealth, }, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 09:18:02 UTC 2024 - 8.8K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
) // TODO BML I don't think we need UDP? TCP healthcheck redir should catch everything. // This is effectively an analog for Istio's old-style podSpec-based health check rewrites. // Before Istio would update the pod manifest to rewrite healthchecks to go to sidecar Envoy port 15021, // so that it could distinguish things that can be unauthenticated (healthchecks) from other kinds of node traffic
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 21:45:18 UTC 2024 - 19.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/config.go
// the config unless we explicitly want to add a healthcheck only to a specific health endpoint. func (c *Config) AddHealthChecks(healthChecks ...healthz.HealthChecker) { c.HealthzChecks = append(c.HealthzChecks, healthChecks...) c.LivezChecks = append(c.LivezChecks, healthChecks...) 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
healthChecksAreEqual(t, tc.wantHealthzChecks, serverConfig.HealthzChecks, "healthz") healthChecksAreEqual(t, tc.wantLivezChecks, serverConfig.LivezChecks, "livez") }) } } func healthChecksAreEqual(t *testing.T, want []string, healthChecks []healthz.HealthChecker, checkerType string) { t.Helper() wantSet := sets.NewString(want...)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 16.4K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
} else { addedIps, err := addPodToHostNSIpset(pod, podIPs, &s.hostsideProbeIPSet) if err != nil { log.Errorf("pod %s has IP collision, pod will be skipped and will fail healthchecks", pod.Name, podIPs) } addedIPSnapshot = append(addedIPSnapshot, addedIps...) } } return pruneHostIPset(sets.New(addedIPSnapshot...), &s.hostsideProbeIPSet) } // addPodToHostNSIpset:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 13.4K bytes - Viewed (0)