Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for GetPossiblyMountedVolumesForPod (1.04 sec)

  1. pkg/kubelet/volumemanager/volume_manager_fake.go

    // GetMountedVolumesForPod is not implemented
    func (f *FakeVolumeManager) GetMountedVolumesForPod(podName types.UniquePodName) container.VolumeMap {
    	return nil
    }
    
    // GetPossiblyMountedVolumesForPod is not implemented
    func (f *FakeVolumeManager) GetPossiblyMountedVolumesForPod(podName types.UniquePodName) container.VolumeMap {
    	return nil
    }
    
    // GetExtraSupplementalGroupsForPod is not implemented
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 17 16:53:28 UTC 2023
    - 3.3K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet_volumes_test.go

    	podVolumes := kubelet.volumeManager.GetMountedVolumesForPod(
    		util.GetUniquePodName(pod))
    	allPodVolumes := kubelet.volumeManager.GetPossiblyMountedVolumesForPod(
    		util.GetUniquePodName(pod))
    	assert.Equal(t, podVolumes, allPodVolumes, "GetMountedVolumesForPod and GetPossiblyMountedVolumesForPod should return the same volumes")
    
    	expectedPodVolumes := []string{"vol1"}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 17 16:53:28 UTC 2023
    - 20.4K bytes
    - Viewed (0)
  3. pkg/kubelet/volumemanager/volume_manager.go

    		}
    	}
    	return podVolumes
    }
    
    func (vm *volumeManager) GetPossiblyMountedVolumesForPod(podName types.UniquePodName) container.VolumeMap {
    	podVolumes := make(container.VolumeMap)
    	for _, mountedVolume := range vm.actualStateOfWorld.GetPossiblyMountedVolumesForPod(podName) {
    		podVolumes[mountedVolume.OuterVolumeSpecName] = container.VolumeInfo{
    			Mounter:             mountedVolume.Mounter,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 21.5K bytes
    - Viewed (0)
  4. pkg/kubelet/volumemanager/cache/actual_state_of_world.go

    	GetMountedVolumesForPod(podName volumetypes.UniquePodName) []MountedVolume
    
    	// GetPossiblyMountedVolumesForPod generates and returns a list of volumes for
    	// the specified pod that either are attached and mounted or are "uncertain",
    	// i.e. a volume plugin may be mounting the volume right now.
    	GetPossiblyMountedVolumesForPod(podName volumetypes.UniquePodName) []MountedVolume
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 09 07:34:33 UTC 2024
    - 45.8K bytes
    - Viewed (0)
  5. pkg/kubelet/volumemanager/reconciler/reconstruct_test.go

    				if len(allPods) != 2 {
    					return fmt.Errorf("expected 2 uncertain pods in asw got %d", len(allPods))
    				}
    				volumes := rcInstance.actualStateOfWorld.GetPossiblyMountedVolumesForPod("pod1")
    				if len(volumes) != 1 {
    					return fmt.Errorf("expected 1 uncertain volume in asw got %d", len(volumes))
    				}
    				// The volume should be marked as reconstructed in ASW
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  6. pkg/kubelet/kubelet_volumes.go

    // pods for the specified volume are mounted or are uncertain.
    func (kl *Kubelet) podVolumesExist(podUID types.UID) bool {
    	if mountedVolumes :=
    		kl.volumeManager.GetPossiblyMountedVolumesForPod(
    			volumetypes.UniquePodName(podUID)); len(mountedVolumes) > 0 {
    		return true
    	}
    	// TODO: This checks pod volume paths and whether they are mounted. If checking returns error, podVolumesExist will return true
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  7. pkg/kubelet/volumemanager/cache/actual_state_of_world_test.go

    	}
    
    	possiblyMountedVolumes := asw.GetPossiblyMountedVolumesForPod(podName1)
    	volumeFound = false
    	for _, volume := range possiblyMountedVolumes {
    		if volume.InnerVolumeSpecName == volumeSpec1.Name() {
    			volumeFound = true
    		}
    	}
    	if !volumeFound {
    		t.Fatalf("expected volume %s to be found in aws.GetPossiblyMountedVolumesForPod", volumeSpec1.Name())
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 46.3K bytes
    - Viewed (0)
Back to top