Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for ReadStaticPodFromDisk (0.42 sec)

  1. cmd/kubeadm/app/util/staticpod/utils.go

    		return errors.Wrapf(err, "failed to write static pod manifest file for %q (%q)", componentName, filename)
    	}
    
    	return nil
    }
    
    // ReadStaticPodFromDisk reads a static pod file from disk
    func ReadStaticPodFromDisk(manifestPath string) (*v1.Pod, error) {
    	buf, err := os.ReadFile(manifestPath)
    	if err != nil {
    		return &v1.Pod{}, errors.Wrapf(err, "failed to read manifest for %q", manifestPath)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 14 13:07:56 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  2. cmd/kubeadm/app/cmd/phases/reset/removeetcdmember.go

    		// etcd.yaml is removed by other reset phases, e.g. cleanup-node.
    		cfg := &v1beta3.ClusterConfiguration{}
    		scheme.Scheme.Default(cfg)
    		return cfg.Etcd.Local.DataDir, nil
    	}
    	etcdPod, err := utilstaticpod.ReadStaticPodFromDisk(manifestPath)
    	if err != nil {
    		return "", err
    	}
    	for _, volumeMount := range etcdPod.Spec.Volumes {
    		if volumeMount.Name == etcdVolumeName {
    			dataDir = volumeMount.HostPath.Path
    			break
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 11 08:02:50 UTC 2022
    - 4.5K bytes
    - Viewed (0)
  3. cmd/kubeadm/app/phases/etcd/local_test.go

    	if err != nil {
    		t.Errorf("Error executing createStaticPodFunction: %v", err)
    		return
    	}
    
    	pod, err := staticpodutil.ReadStaticPodFromDisk(filepath.Join(manifestPath, kubeadmconstants.Etcd+".yaml"))
    	if err != nil {
    		t.Errorf("Error executing ReadStaticPodFromDisk: %v", err)
    		return
    	}
    	if pod.Spec.DNSPolicy != "" {
    		t.Errorf("DNSPolicy should be empty but: %v", pod.Spec.DNSPolicy)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 23 14:07:27 UTC 2024
    - 15.2K bytes
    - Viewed (0)
  4. cmd/kubeadm/app/util/staticpod/utils_test.go

    				if err != nil {
    					t.Fatalf("Failed to write pod manifest\n%s\n\tfatal error: %v", rt.description, err)
    				}
    			}
    
    			_, actualErr := ReadStaticPodFromDisk(manifestPath)
    			if (actualErr != nil) != rt.expectErr {
    				t.Errorf(
    					"ReadStaticPodFromDisk failed\n%s\n\texpected error: %t\n\tgot: %t\n\tactual error: %v",
    					rt.description,
    					rt.expectErr,
    					(actualErr != nil),
    					actualErr,
    				)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Sep 12 15:44:44 UTC 2023
    - 22.6K bytes
    - Viewed (0)
  5. cmd/kubeadm/app/phases/controlplane/manifests_test.go

    	if err != nil {
    		t.Errorf("Error executing createStaticPodFunction: %v", err)
    		return
    	}
    
    	pod, err := staticpodutil.ReadStaticPodFromDisk(filepath.Join(manifestPath, fmt.Sprintf("%s.yaml", kubeadmconstants.KubeAPIServer)))
    	if err != nil {
    		t.Errorf("Error executing ReadStaticPodFromDisk: %v", err)
    		return
    	}
    
    	if _, ok := pod.ObjectMeta.Annotations["patched"]; !ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Mar 03 14:43:47 UTC 2024
    - 48.5K bytes
    - Viewed (0)
  6. cmd/kubeadm/app/phases/upgrade/staticpods.go

    func GetEtcdImageTagFromStaticPod(manifestDir string) (string, error) {
    	realPath := constants.GetStaticPodFilepath(constants.Etcd, manifestDir)
    	pod, err := staticpod.ReadStaticPodFromDisk(realPath)
    	if err != nil {
    		return "", err
    	}
    
    	return convertImageTagMetadataToSemver(image.TagFromImage(pod.Spec.Containers[0].Image)), nil
    }
    
    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