- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for WaitForKubelet (0.4 sec)
-
cmd/kubeadm/app/util/apiclient/wait.go
// WaitForStaticPodControlPlaneHashes fetches sha256 hashes for the control plane static pods WaitForStaticPodControlPlaneHashes(nodeName string) (map[string]string, error) // WaitForKubelet blocks until the kubelet /healthz endpoint returns 'ok' WaitForKubelet(healthzAddress string, healthzPort int32) error // SetTimeout adjusts the timeout to the specified duration SetTimeout(timeout time.Duration) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 13.3K bytes - Viewed (0) -
cmd/kubeadm/app/util/dryrun/dryrun.go
fmt.Printf("[dryrun] Would wait for the %q Pod in the %s namespace to be deleted\n", podName, metav1.NamespaceSystem) return nil } // WaitForKubelet blocks until the kubelet /healthz endpoint returns 'ok' func (w *Waiter) WaitForKubelet(healthzAddress string, healthzPort int32) error { fmt.Printf("[dryrun] Would make sure the kubelet returns 'ok' at http://%s:%d/healthz\n", healthzAddress, healthzPort) return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 6.5K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/phases/init/waitcontrolplane.go
kubeletConfigTyped, ok := kubeletConfig.(*kubeletconfig.KubeletConfiguration) if !ok { return errors.New("could not convert the KubeletConfiguration to a typed object") } if err := waiter.WaitForKubelet(kubeletConfigTyped.HealthzBindAddress, *kubeletConfigTyped.HealthzPort); err != nil { return handleError(err) } waiter.SetTimeout(data.Cfg().Timeouts.ControlPlaneComponentHealthCheck.Duration)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 5K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/phases/join/kubelet.go
kubeletConfigTyped, ok := kubeletConfig.(*kubeletconfig.KubeletConfiguration) if !ok { return errors.New("could not convert the KubeletConfiguration to a typed object") } if err := waiter.WaitForKubelet(kubeletConfigTyped.HealthzBindAddress, *kubeletConfigTyped.HealthzPort); err != nil { fmt.Printf(kubeadmJoinFailMsg, err) return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 10.3K bytes - Viewed (0) -
cmd/kubeadm/app/phases/upgrade/staticpods_test.go
func (w *fakeWaiter) WaitForStaticPodHashChange(_, _, _ string) error { return w.errsToReturn[waitForHashChange] } // WaitForHKubelet returns a dummy nil just to implement the interface func (w *fakeWaiter) WaitForKubelet(_ string, _ int32) error { return nil } type fakeStaticPodPathManager struct { kubernetesDir string patchesDir string realManifestDir string tempManifestDir string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 32K bytes - Viewed (0)