Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for MarkVolumeAsDetached (0.31 sec)

  1. pkg/kubelet/volumemanager/cache/actual_state_of_world_test.go

    				err := asw.MarkVolumeAsUnmounted(volumeOpts.PodName, volumeOpts.VolumeName)
    				if err != nil {
    					return err
    				}
    				asw.MarkVolumeAsDetached(volumeOpts.VolumeName, "")
    				return nil
    			},
    			verifyCallback: func(asw ActualStateOfWorld, volumeOpts operationexecutor.MarkVolumeOpts) error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 46.3K bytes
    - Viewed (0)
  2. pkg/kubelet/volumemanager/reconciler/reconciler_common.go

    				// Kubelet not responsible for detaching or this volume has a non-attachable volume plugin.
    				if rc.controllerAttachDetachEnabled || !attachedVolume.PluginIsAttachable {
    					rc.actualStateOfWorld.MarkVolumeAsDetached(attachedVolume.VolumeName, attachedVolume.NodeName)
    					klog.InfoS(attachedVolume.GenerateMsgDetailed("Volume detached", fmt.Sprintf("DevicePath %q", attachedVolume.DevicePath)))
    				} else {
    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_generator.go

    	// to this type of plugin
    	volumesPerPlugin := make(map[string][]*volume.Spec)
    	// volumeSpecMap maps from a volume spec to its unique volumeName which will be used
    	// when calling MarkVolumeAsDetached
    	volumeSpecMap := make(map[*volume.Spec]v1.UniqueVolumeName)
    
    	// Iterate each volume spec and put them into a map index by the pluginName
    	for _, volumeAttached := range attachedVolumes {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 101.4K bytes
    - Viewed (0)
  4. pkg/controller/volume/attachdetach/cache/actual_state_of_world.go

    	_, err := asw.AddVolumeNode(logger, uniqueName, volumeSpec, nodeName, devicePath, true)
    	return err
    }
    
    func (asw *actualStateOfWorld) MarkVolumeAsDetached(
    	volumeName v1.UniqueVolumeName, nodeName types.NodeName) {
    	asw.DeleteVolumeNode(volumeName, nodeName)
    }
    
    func (asw *actualStateOfWorld) RemoveVolumeFromReportAsAttached(
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 11 07:35:17 UTC 2024
    - 28.7K bytes
    - Viewed (0)
  5. pkg/volume/util/operationexecutor/operation_executor.go

    	MarkVolumeAsUncertain(logger klog.Logger, volumeName v1.UniqueVolumeName, volumeSpec *volume.Spec, nodeName types.NodeName) error
    
    	// Marks the specified volume as detached from the specified node
    	MarkVolumeAsDetached(volumeName v1.UniqueVolumeName, nodeName types.NodeName)
    
    	// Marks desire to detach the specified volume (remove the volume from the node's
    	// volumesToReportAsAttached list)
    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/cache/actual_state_of_world.go

    func (asw *actualStateOfWorld) MarkVolumeAsUncertain(
    	logger klog.Logger, volumeName v1.UniqueVolumeName, volumeSpec *volume.Spec, _ types.NodeName) error {
    	return nil
    }
    
    func (asw *actualStateOfWorld) MarkVolumeAsDetached(
    	volumeName v1.UniqueVolumeName, nodeName types.NodeName) {
    	asw.DeleteVolume(volumeName)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 09 07:34:33 UTC 2024
    - 45.8K bytes
    - Viewed (0)
  7. pkg/kubelet/volumemanager/populator/desired_state_of_world_populator_test.go

    		if err != nil {
    			t.Fatalf("Unexpected error when MarkVolumeAsUnmounted: %v", err)
    		}
    	}
    	for _, volumeToMount := range dsw.GetVolumesToMount() {
    		asw.MarkVolumeAsDetached(volumeToMount.VolumeName, "")
    	}
    }
    
    func reprocess(dswp *desiredStateOfWorldPopulator, uniquePodName types.UniquePodName,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 51.4K bytes
    - Viewed (0)
Back to top