- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for attachability (0.21 sec)
-
pkg/controller/volume/attachdetach/populator/desired_state_of_world_populator.go
dswp.desiredStateOfWorld.DeletePod(dswPodUID, dswPodToAdd.VolumeName, dswPodToAdd.NodeName) } // check if the existing volumes changes its attachability for _, volumeToAttach := range dswp.desiredStateOfWorld.GetVolumesToAttach() { // IsAttachableVolume() will result in a fetch of CSIDriver object if the volume plugin type is CSI.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 7.7K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/populator/desired_state_of_world_populator_test.go
if !volumeExists { t.Fatalf( "VolumeExists(%q) failed. Expected: <true> Actual: <%v>", expectedVolumeName, volumeExists) } // Change the CSI volume plugin attachability fakeVolumePlugin.NonAttachable = true dswp.findAndRemoveDeletedPods(logger) // The volume should not exist after it becomes non-attachable
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 7.3K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/actual_state_of_world_test.go
if found { return fmt.Errorf("found unexpected volume in reconstructed map") } return nil }, }, { name: "uncertain attachability is resolved to attachable", opCallback: func(asw ActualStateOfWorld, volumeOpts operationexecutor.MarkVolumeOpts) error { asw.UpdateReconstructedVolumeAttachability(volumeOpts.VolumeName, true) return nil },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 46.3K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/actual_state_of_world.go
// been fixed by such an update. UpdateReconstructedDevicePath(volumeName v1.UniqueVolumeName, devicePath string) // UpdateReconstructedVolumeAttachability updates volume attachability from the API server. UpdateReconstructedVolumeAttachability(volumeName v1.UniqueVolumeName, volumeAttachable bool) } // MountedVolume represents a volume that has successfully been mounted to a pod.
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/populator/desired_state_of_world_populator.go
podsFromCache[volumetypes.UniquePodName(volumeToMount.Pod.UID)] = struct{}{} pod, podExists := dswp.podManager.GetPodByUID(volumeToMount.Pod.UID) if podExists { // check if the attachability has changed for this volume if volumeToMount.PluginIsAttachable { attachableVolumePlugin, err := dswp.volumePluginMgr.FindAttachablePluginBySpec(volumeToMount.VolumeSpec)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 23.8K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconciler_test.go
for _, vol := range attachedVolumes { if vol.VolumeName == volumeName1 { // devicePath + attachability must have been updated from node.status assert.True(t, vol.PluginIsAttachable) assert.Equal(t, vol.DevicePath, "fake/path") } if vol.VolumeName == volumeName2 { // only attachability was updated from node.status assert.False(t, vol.PluginIsAttachable)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 75.4K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/desired_state_of_world.go
PopPodErrors(podName types.UniquePodName) []string // GetPodsWithErrors returns names of pods that have stored errors. GetPodsWithErrors() []types.UniquePodName // MarkVolumeAttachability updates the volume's attachability for a given volume MarkVolumeAttachability(volumeName v1.UniqueVolumeName, attachable bool) // UpdatePersistentVolumeSize updates persistentVolumeSize in desired state of the world
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 27.1K bytes - Viewed (0)