Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for WaitForStaticPodControlPlaneHashes (0.52 sec)

  1. cmd/kubeadm/app/util/apiclient/wait.go

    	// By doing that we can be sure that the kubelet has restarted the given Static Pod
    	WaitForStaticPodHashChange(nodeName, component, previousHash string) error
    	// 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'
    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

    	return nil
    }
    
    // SetTimeout is a no-op; we don't wait in this implementation
    func (w *Waiter) SetTimeout(_ time.Duration) {}
    
    // WaitForStaticPodControlPlaneHashes returns an empty hash for all control plane images;
    func (w *Waiter) WaitForStaticPodControlPlaneHashes(_ string) (map[string]string, error) {
    	return map[string]string{
    		kubeadmconstants.KubeAPIServer:         "",
    		kubeadmconstants.KubeControllerManager: "",
    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/phases/upgrade/staticpods_test.go

    	return nil
    }
    
    // SetTimeout is a no-op; we don't use it in this implementation
    func (w *fakeWaiter) SetTimeout(_ time.Duration) {}
    
    // WaitForStaticPodControlPlaneHashes returns an error if set from errsToReturn
    func (w *fakeWaiter) WaitForStaticPodControlPlaneHashes(_ string) (map[string]string, error) {
    	return map[string]string{}, w.errsToReturn[waitForHashes]
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 01 07:10:31 UTC 2024
    - 32K bytes
    - Viewed (0)
  4. cmd/kubeadm/app/phases/upgrade/staticpods.go

    	recoverManifests := map[string]string{}
    	var isExternalEtcd bool
    
    	beforePodHashMap, err := waiter.WaitForStaticPodControlPlaneHashes(cfg.NodeRegistration.Name)
    	if err != nil {
    		return err
    	}
    
    	if oldEtcdClient == nil {
    		if cfg.Etcd.External != nil {
    			// External etcd
    			isExternalEtcd = true
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 10:07:41 UTC 2024
    - 30.7K bytes
    - Viewed (0)
Back to top