Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for DeletePodFromVolume (0.21 sec)

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

    	// attached volumes, an error is returned.
    	SetDeviceMountState(volumeName v1.UniqueVolumeName, deviceMountState operationexecutor.DeviceMountState, devicePath, deviceMountPath, seLinuxMountContext string) error
    
    	// DeletePodFromVolume removes the given pod from the given volume in the
    	// cache indicating the volume has been successfully unmounted from the pod.
    	// If a pod with the same unique name does not exist under the specified
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 09 07:34:33 UTC 2024
    - 45.8K bytes
    - Viewed (0)
  2. pkg/kubelet/volumemanager/reconciler/reconciler_test.go

    		1 /* expectedSetUpCallCount */, fakePlugin))
    	assert.NoError(t, volumetesting.VerifyZeroTearDownCallCount(fakePlugin))
    	assert.NoError(t, volumetesting.VerifyZeroDetachCallCount(fakePlugin))
    
    	// Act
    	dsw.DeletePodFromVolume(podName, generatedVolumeName)
    	waitForDetach(t, generatedVolumeName, asw)
    
    	// Assert
    	assert.NoError(t, volumetesting.VerifyTearDownCallCount(
    		1 /* expectedTearDownCallCount */, fakePlugin))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 09 07:34:33 UTC 2024
    - 75.4K bytes
    - Viewed (0)
  3. pkg/kubelet/volumemanager/cache/desired_state_of_world.go

    	// If a volume in the reportedVolumes list does not exist in the list of
    	// volumes that should be attached to this node, it is skipped without error.
    	MarkVolumesReportedInUse(reportedVolumes []v1.UniqueVolumeName)
    
    	// DeletePodFromVolume removes the given pod from the given volume in the
    	// cache indicating the specified pod no longer requires the specified
    	// volume.
    	// If a pod with the same unique name does not exist under the specified
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 27.1K bytes
    - Viewed (0)
  4. pkg/kubelet/volumemanager/cache/desired_state_of_world_test.go

    			}
    		}
    	}
    
    }
    
    // Populates data struct with a new volume/pod
    // Calls DeletePodFromVolume() to removes the pod
    // Verifies newly added pod/volume are deleted
    func Test_DeletePodFromVolume_Positive_PodExistsVolumeExists(t *testing.T) {
    	// Arrange
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 34K bytes
    - Viewed (0)
  5. pkg/kubelet/volumemanager/populator/desired_state_of_world_populator.go

    			continue
    		}
    		klog.V(4).InfoS("Removing volume from desired state", "pod", klog.KObj(volumeToMount.Pod), "podUID", volumeToMount.Pod.UID, "volumeName", volumeToMountSpecName)
    		dswp.desiredStateOfWorld.DeletePodFromVolume(
    			volumeToMount.PodName, volumeToMount.VolumeName)
    		dswp.deleteProcessedPod(volumeToMount.PodName)
    	}
    
    	// Cleanup orphanded entries from processedPods
    	dswp.pods.Lock()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 11 09:02:45 UTC 2024
    - 23.8K bytes
    - Viewed (0)
Back to top