- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for PluginIsAttachable (0.28 sec)
-
pkg/kubelet/volumemanager/cache/actual_state_of_world.go
pluginIsAttachable := volumeAttachabilityFalse if attachablePlugin, err := asw.volumePluginMgr.FindAttachablePluginBySpec(volumeSpec); err == nil && attachablePlugin != nil { pluginIsAttachable = volumeAttachabilityTrue } return asw.addVolume(volumeName, volumeSpec, devicePath, pluginIsAttachable) }
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/reconciler_common.go
func (rc *reconciler) waitForVolumeAttach(volumeToMount cache.VolumeToMount) { logger := klog.TODO() if rc.controllerAttachDetachEnabled || !volumeToMount.PluginIsAttachable { //// lets not spin a goroutine and unnecessarily trigger exponential backoff if this happens if volumeToMount.PluginIsAttachable && !volumeToMount.ReportedInUse {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:23:12 UTC 2024 - 14.8K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_executor_test.go
podName := "pod-" + strconv.Itoa(i+1) pod := getTestPodWithSecret(podName, secretName) volumesToMount[i] = VolumeToMount{ Pod: pod, VolumeName: volumeName, PluginIsAttachable: false, // this field determines whether the plugin is attachable PluginIsDeviceMountable: false, // this field determines whether the plugin is devicemountable ReportedInUse: true, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 26.9K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/desired_state_of_world.go
// the name of the pod and the value is a pod object containing more // information about the pod. podsToMount map[types.UniquePodName]podToMount // pluginIsAttachable indicates that the plugin for this volume implements // the volume.Attacher interface pluginIsAttachable bool // pluginIsDeviceMountable indicates that the plugin for this volume implements // the volume.DeviceMounter interface pluginIsDeviceMountable bool
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/volume/util/operationexecutor/operation_executor.go
OuterVolumeSpecName string // Pod to mount the volume to. Used to create NewMounter. Pod *v1.Pod // PluginIsAttachable indicates that the plugin for this volume implements // the volume.Attacher interface PluginIsAttachable bool // PluginIsDeviceMountable indicates that the plugin for this volume implements // the volume.DeviceMounter interface PluginIsDeviceMountable bool
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 42.6K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager.go
for _, volume := range desiredVolumes { if volume.PluginIsAttachable { if _, exists := desiredVolumesMap[volume.VolumeName]; !exists { desiredVolumesMap[volume.VolumeName] = true volumesToReportInUse = append(volumesToReportInUse, volume.VolumeName) } } } for _, volume := range allAttachedVolumes { if volume.PluginIsAttachable { if _, exists := desiredVolumesMap[volume.VolumeName]; !exists {
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/populator/desired_state_of_world_populator.go
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) // only this means the plugin is truly non-attachable if err == nil && attachableVolumePlugin == nil {
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/controller/volume/attachdetach/cache/actual_state_of_world.go
VolumeName: attachedVolume.volumeName, VolumeSpec: attachedVolume.spec, NodeName: nodeAttachedTo.nodeName, DevicePath: attachedVolume.devicePath, PluginIsAttachable: true, }, MountedByNode: asw.inUseVolumes[nodeAttachedTo.nodeName].Has(attachedVolume.volumeName), DetachRequestedTime: nodeAttachedTo.detachRequestedTime}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 07:35:17 UTC 2024 - 28.7K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconciler_test.go
// 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) assert.Equal(t, vol.DevicePath, "/dev/reconstructed") } }
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/volume/util/operationexecutor/operation_generator.go
// verify status of attached volume by directly reading from API server later on.This is necessarily // to ensure any race conditions because of cached state in the informer. if volumeToMount.PluginIsAttachable { cachedAttachedVolumes, _ := og.volumePluginMgr.Host.GetAttachedVolumesFromNodeStatus() if cachedAttachedVolumes != nil { _, volumeFound := cachedAttachedVolumes[volumeToMount.VolumeName]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 101.4K bytes - Viewed (0)