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