- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for GetPossiblyMountedVolumesForPod (0.41 sec)
-
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) -
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) -
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)