Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for WaitForKubelet (0.25 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
Back to top