Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for DetachVolume (0.24 sec)

  1. pkg/controller/volume/attachdetach/reconciler/reconciler.go

    			}
    			verifySafeToDetach := !(forceDetatchTimeoutExpired || hasOutOfServiceTaint)
    			err = rc.attacherDetacher.DetachVolume(logger, attachedVolume.AttachedVolume, verifySafeToDetach, rc.actualStateOfWorld)
    			if err == nil {
    				if verifySafeToDetach { // normal detach
    					logger.Info("attacherDetacher.DetachVolume started", "node", klog.KRef("", string(attachedVolume.NodeName)), "volumeName", attachedVolume.VolumeName)
    				} else { // force detach
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 22 21:02:38 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  2. pkg/kubelet/volumemanager/reconciler/reconciler_common.go

    					err := rc.operationExecutor.DetachVolume(
    						klog.TODO(), attachedVolume.AttachedVolume, false /* verifySafeToDetach */, rc.actualStateOfWorld)
    					if err != nil && !isExpectedError(err) {
    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

    					},
    				},
    			},
    		}
    		logger, _ := ktesting.NewTestContext(t)
    		oe.DetachVolume(logger, attachedVolumes[i], true /* verifySafeToDetach */, nil /* actualStateOfWorldAttacherUpdater */)
    	}
    
    	// Assert
    	if !isOperationRunSerially(ch, quit) {
    		t.Fatalf("DetachVolume operations should not run concurrently")
    	}
    }
    
    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/volume/util/operationexecutor/operation_generator.go

    			return volumetypes.GeneratedOperations{}, volumeToDetach.GenerateErrorDetailed("DetachVolume.findDetachablePluginBySpec failed", err)
    		}
    
    		volumeName, err =
    			attachableVolumePlugin.GetVolumeName(volumeToDetach.VolumeSpec)
    		if err != nil {
    			return volumetypes.GeneratedOperations{}, volumeToDetach.GenerateErrorDetailed("DetachVolume.GetVolumeName failed", err)
    		}
    	} else {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 101.4K bytes
    - Viewed (0)
  5. pkg/volume/portworx/portworx.go

    	// Deletes a volume
    	DeleteVolume(deleter *portworxVolumeDeleter) error
    	// Attach a volume
    	AttachVolume(mounter *portworxVolumeMounter, attachOptions map[string]string) (string, error)
    	// Detach a volume
    	DetachVolume(unmounter *portworxVolumeUnmounter) error
    	// Mount a volume
    	MountVolume(mounter *portworxVolumeMounter, mountDir string) error
    	// Unmount a volume
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  6. pkg/volume/portworx/portworx_util.go

    	if err != nil {
    		klog.Errorf("Error attaching Portworx Volume (%v): %v", m.volName, err)
    		return "", err
    	}
    	return devicePath, nil
    }
    
    // DetachVolume detaches a Portworx Volume
    func (util *portworxVolumeUtil) DetachVolume(u *portworxVolumeUnmounter) error {
    	driver, err := util.getLocalPortworxDriver(u.plugin.host)
    	if err != nil || driver == nil {
    		klog.Errorf("Failed to get portworx driver. Err: %v", err)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 16 11:12:06 UTC 2022
    - 12.2K bytes
    - Viewed (0)
  7. pkg/volume/portworx/portworx_test.go

    }
    
    func (fake *fakePortworxManager) AttachVolume(b *portworxVolumeMounter, attachOptions map[string]string) (string, error) {
    	fake.attachCalled = true
    	return "", nil
    }
    
    func (fake *fakePortworxManager) DetachVolume(c *portworxVolumeUnmounter) error {
    	return nil
    }
    
    func (fake *fakePortworxManager) MountVolume(b *portworxVolumeMounter, mountPath string) error {
    	fake.mountCalled = true
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 21 02:17:04 UTC 2021
    - 7.4K bytes
    - Viewed (0)
  8. pkg/volume/util/operationexecutor/operation_executor.go

    	// DetachVolume detaches the volume from the node specified in
    	// volumeToDetach, and updates the actual state of the world to reflect
    	// that. If verifySafeToDetach is set, a call is made to the fetch the node
    	// object and it is used to verify that the volume does not exist in Node's
    	// Status.VolumesInUse list (operation fails with error if it is).
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 42.6K bytes
    - Viewed (0)
Back to top