- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for MarkVolumesReportedInUse (0.57 sec)
-
pkg/kubelet/volumemanager/cache/desired_state_of_world.go
AddPodToVolume(podName types.UniquePodName, pod *v1.Pod, volumeSpec *volume.Spec, outerVolumeSpecName string, volumeGidValue string, seLinuxContainerContexts []*v1.SELinuxOptions) (v1.UniqueVolumeName, error) // MarkVolumesReportedInUse sets the ReportedInUse value to true for the // reportedVolumes. For volumes not in the reportedVolumes list, the // ReportedInUse value is reset to false. The default ReportedInUse value
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 27.1K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/desired_state_of_world_test.go
if err != nil { t.Fatalf("AddPodToVolume failed. Expected: <no error> Actual: <%v>", err) } // Act volumesReportedInUse := []v1.UniqueVolumeName{generatedVolume2Name} dsw.MarkVolumesReportedInUse(volumesReportedInUse) // Assert verifyVolumeExistsDsw(t, generatedVolume1Name, "" /* SELinuxContext */, dsw) verifyVolumeExistsInVolumesToMount(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 34K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager.go
return vm.actualStateOfWorld.VolumeExists(volumeName) } func (vm *volumeManager) MarkVolumesAsReportedInUse( volumesReportedAsInUse []v1.UniqueVolumeName) { vm.desiredStateOfWorld.MarkVolumesReportedInUse(volumesReportedAsInUse) } func (vm *volumeManager) WaitForAttachAndMount(ctx context.Context, pod *v1.Pod) error { if pod == nil { return nil } expectedVolumes := getExpectedVolumes(pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 21.5K bytes - Viewed (0)