Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for GetMountedVolumesForPod (0.43 sec)

  1. pkg/kubelet/kubelet_volumes_test.go

    	if actual := kubelet.volumeManager.GetMountedVolumesForPod(util.GetUniquePodName(pod)); len(actual) > 0 {
    		t.Fatalf("expected volume unmount to wait for no volumes: %v", actual)
    	}
    
    	// Verify volumes unmounted
    	podVolumes = kubelet.volumeManager.GetMountedVolumesForPod(
    		util.GetUniquePodName(pod))
    
    	assert.Len(t, podVolumes, 0,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 17 16:53:28 UTC 2023
    - 20.4K bytes
    - Viewed (0)
  2. pkg/kubelet/volumemanager/volume_manager_fake.go

    	return nil
    }
    
    // WaitForUnmount is not implemented
    func (f *FakeVolumeManager) WaitForUnmount(ctx context.Context, pod *v1.Pod) error {
    	return nil
    }
    
    // GetMountedVolumesForPod is not implemented
    func (f *FakeVolumeManager) GetMountedVolumesForPod(podName types.UniquePodName) container.VolumeMap {
    	return nil
    }
    
    // GetPossiblyMountedVolumesForPod 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)
  3. pkg/kubelet/volumemanager/volume_manager.go

    	WaitForUnmount(ctx context.Context, pod *v1.Pod) error
    
    	// GetMountedVolumesForPod returns a VolumeMap containing the volumes
    	// referenced by the specified pod that are successfully attached and
    	// mounted. The key in the map is the OuterVolumeSpecName (i.e.
    	// pod.Spec.Volumes[x].Name). It returns an empty VolumeMap if pod has no
    	// volumes.
    	GetMountedVolumesForPod(podName types.UniquePodName) container.VolumeMap
    
    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/kubelet_volumes.go

    func (kl *Kubelet) ListVolumesForPod(podUID types.UID) (map[string]volume.Volume, bool) {
    	volumesToReturn := make(map[string]volume.Volume)
    	podVolumes := kl.volumeManager.GetMountedVolumesForPod(
    		volumetypes.UniquePodName(podUID))
    	for outerVolumeSpecName, volume := range podVolumes {
    		// TODO: volume.Mounter could be nil if volume object is recovered
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  5. pkg/kubelet/volumemanager/cache/actual_state_of_world_test.go

    	}
    	mountedVolumes := asw.GetMountedVolumesForPod(podName1)
    	volumeFound := false
    	for _, volume := range mountedVolumes {
    		if volume.InnerVolumeSpecName == volumeSpec1.Name() {
    			volumeFound = true
    		}
    	}
    	if volumeFound {
    		t.Fatalf("expected volume %s to be not found in asw.GetMountedVolumesForPod", 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)
  6. pkg/kubelet/volumemanager/volume_manager_test.go

    			}
    			if err == nil && test.expectError {
    				t.Errorf("Expected error, got none")
    			}
    
    			expectedMounted := pod.Spec.Volumes[0].Name
    			actualMounted := manager.GetMountedVolumesForPod(types.UniquePodName(pod.ObjectMeta.UID))
    			if test.expectMount {
    				if _, ok := actualMounted[expectedMounted]; !ok || (len(actualMounted) != 1) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  7. pkg/kubelet/volumemanager/cache/actual_state_of_world.go

    	// those that are in VolumeMounted state and VolumeMountUncertain state.
    	GetAllMountedVolumes() []MountedVolume
    
    	// GetMountedVolumesForPod generates and returns a list of volumes that are
    	// successfully attached and mounted for the specified pod based on the
    	// current actual state of the world.
    	GetMountedVolumesForPod(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)
  8. pkg/kubelet/kubelet_test.go

    	var podVolumes kubecontainer.VolumeMap
    	err := retryWithExponentialBackOff(
    		time.Duration(50*time.Millisecond),
    		func() (bool, error) {
    			// Verify volumes detached
    			podVolumes = volumeManager.GetMountedVolumesForPod(
    				util.GetUniquePodName(pod))
    
    			if len(podVolumes) != 0 {
    				return false, nil
    			}
    
    			return true, nil
    		},
    	)
    
    	if err != nil {
    		return fmt.Errorf(
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  9. pkg/kubelet/kubelet_pods.go

    	if err != nil {
    		return nil, nil, err
    	}
    	opts.Hostname = nodename
    	podName := volumeutil.GetUniquePodName(pod)
    	volumes := kl.volumeManager.GetMountedVolumesForPod(podName)
    
    	blkutil := volumepathhandler.NewBlockVolumePathHandler()
    	blkVolumes, err := kl.makeBlockVolumes(pod, container, volumes, blkutil)
    	if err != nil {
    		return nil, nil, err
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
Back to top