Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 482 for pod6 (0.04 sec)

  1. pkg/kubelet/volumemanager/cache/actual_state_of_world_test.go

    // Call MarkVolumeAsDetached() on a volume which mounted by pod(s) should be skipped
    func Test_MarkVolumeAsDetached_Negative_PodInVolume(t *testing.T) {
    	// Arrange
    	volumePluginMgr, plugin := volumetesting.GetTestVolumePluginMgr(t)
    	devicePath := "fake/device/path"
    	asw := NewActualStateOfWorld("mynode", volumePluginMgr)
    	pod := &v1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name: "pod1",
    			UID:  "pod1uid",
    		},
    		Spec: v1.PodSpec{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 46.3K bytes
    - Viewed (0)
  2. plugin/pkg/admission/serviceaccount/admission_test.go

    	// clear generated volume names
    	for i := range pod.Spec.Volumes {
    		if len(pod.Spec.Volumes[i].Name) > 0 {
    			pod.Spec.Volumes[i].Name = "cleared"
    		}
    	}
    	for i := range pod.Spec.Containers[0].VolumeMounts {
    		if len(pod.Spec.Containers[0].VolumeMounts[i].Name) > 0 {
    			pod.Spec.Containers[0].VolumeMounts[i].Name = "cleared"
    		}
    	}
    
    	if !reflect.DeepEqual(expectedVolumes, pod.Spec.Volumes) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 12 17:49:30 UTC 2024
    - 36.9K bytes
    - Viewed (0)
  3. pkg/controller/volume/attachdetach/cache/desired_state_of_world_test.go

    	// Assert
    	if len(pods) != 1 {
    		t.Fatalf("Expected 1 pod, got %d", len(pods))
    	}
    	if pods[0].Name != pod1Name {
    		t.Errorf("Expected pod %s/%s, got %s", pod1Name, pod1Name, pods[0].Name)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 10:42:15 UTC 2024
    - 35.9K bytes
    - Viewed (0)
  4. pkg/kubelet/preemption/preemption.go

    		// subtract the pod from requirements, and transfer the pod from input-pods to pods-to-evicted
    		requirements = requirements.subtract(pods[bestPodIndex])
    		podsToEvict = append(podsToEvict, pods[bestPodIndex])
    		pods[bestPodIndex] = pods[len(pods)-1]
    		pods = pods[:len(pods)-1]
    	}
    	return podsToEvict, nil
    }
    
    type admissionRequirement struct {
    	resourceName v1.ResourceName
    	quantity     int64
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 02 16:53:19 UTC 2023
    - 11.5K bytes
    - Viewed (0)
  5. tools/bug-report/pkg/cluster/cluster_test.go

    				},
    			},
    			true,
    		},
    		{
    			"tested pod name not skip",
    			&v1.Pod{
    				ObjectMeta: metav1.ObjectMeta{
    					Name: "in-pod1",
    				},
    			},
    			&config2.BugReportConfig{
    				Include: []*config2.SelectionSpec{
    					{
    						Pods: []string{"in-"},
    					},
    				},
    				Exclude: []*config2.SelectionSpec{
    					{
    						Pods: []string{"ex-"},
    					},
    				},
    			},
    			false,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jul 06 17:23:32 UTC 2023
    - 11K bytes
    - Viewed (0)
  6. pkg/controller/daemon/util/daemonset_util_test.go

    		tests := []struct {
    			pod         *v1.Pod
    			nodeName    string
    			expectedErr bool
    		}{
    			{
    				pod: &v1.Pod{
    					ObjectMeta: metav1.ObjectMeta{
    						Name:      "pod1",
    						Namespace: "default",
    					},
    					Spec: v1.PodSpec{
    						NodeName: "node-1",
    					},
    				},
    				nodeName: "node-1",
    			},
    			{
    				pod: &v1.Pod{
    					ObjectMeta: metav1.ObjectMeta{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 14.5K bytes
    - Viewed (0)
  7. cmd/kubeadm/app/util/staticpod/utils.go

    	}
    
    	pod2, ok := obj.(*v1.Pod)
    	if !ok {
    		return pod, errors.Wrap(err, "patched manifest is not a valid Pod object")
    	}
    
    	return pod2, nil
    }
    
    // WriteStaticPodToDisk writes a static pod file to disk
    func WriteStaticPodToDisk(componentName, manifestDir string, pod v1.Pod) error {
    
    	// creates target folder if not already exists
    	if err := os.MkdirAll(manifestDir, 0700); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 14 13:07:56 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  8. pkg/volume/fc/fc_test.go

    	}
    	fm := mount.NewFakeMounter(
    		[]mount.MountPoint{
    			{Device: "/dev/sdb", Path: "/var/lib/kubelet/pods/some-pod/volumes/kubernetes.io~fc/fc-in-pod1"},
    			{Device: "/dev/sdb", Path: "/var/lib/kubelet/plugins/kubernetes.io/fc/50060e801049cfd1-lun-0"},
    			{Device: "/dev/sdc", Path: "/var/lib/kubelet/pods/some-pod/volumes/kubernetes.io~fc/fc-in-pod2"},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Aug 01 15:56:32 UTC 2022
    - 14.1K bytes
    - Viewed (0)
  9. pkg/kubelet/volumemanager/reconciler/reconstruct_test.go

    			for _, tpodInfo := range tc.podInfos {
    				pod := getInlineFakePod(tpodInfo.podName, tpodInfo.podUID, tpodInfo.outerVolumeName, tpodInfo.innerVolumeName)
    				volumeSpec := &volume.Spec{Volume: &pod.Spec.Volumes[0]}
    				podName := util.GetUniquePodName(pod)
    				volumeName, err := rcInstance.desiredStateOfWorld.AddPodToVolume(
    					podName, pod, volumeSpec, volumeSpec.Name(), "" /* volumeGidValue */, nil /* SELinuxContext */)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  10. pkg/controller/statefulset/stateful_pod_control_test.go

    	pvcs := getPersistentVolumeClaims(set, pod)
    	volumes := make([]v1.Volume, 0, len(pod.Spec.Volumes))
    	for i := range pod.Spec.Volumes {
    		if _, contains := pvcs[pod.Spec.Volumes[i].Name]; !contains {
    			volumes = append(volumes, pod.Spec.Volumes[i])
    		}
    	}
    	pod.Spec.Volumes = volumes
    	fakeClient.AddReactor("update", "pods", func(action core.Action) (bool, runtime.Object, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 35.5K bytes
    - Viewed (0)
Back to top