Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for PluginIsAttachable (0.28 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top