Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for MountVolume (0.16 sec)

  1. pkg/kubelet/volumemanager/reconciler/reconciler_common.go

    	err := rc.operationExecutor.MountVolume(
    		rc.waitForAttachTimeout,
    		volumeToMount.VolumeToMount,
    		rc.actualStateOfWorld,
    		isRemount)
    	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)
  2. pkg/volume/csi/csi_client.go

    		}
    	} else {
    		mountVolume := &csipbv1.VolumeCapability_MountVolume{
    			FsType:     fsType,
    			MountFlags: mountOptions,
    		}
    		if fsGroup != nil {
    			mountVolume.VolumeMountGroup = strconv.FormatInt(*fsGroup, 10 /* base */)
    		}
    		req.VolumeCapability.AccessType = &csipbv1.VolumeCapability_Mount{
    			Mount: mountVolume,
    		}
    	}
    
    	_, err = nodeClient.NodePublishVolume(ctx, req)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Sep 20 10:15:36 UTC 2022
    - 22.1K bytes
    - Viewed (0)
  3. pkg/volume/csi/csi_client_test.go

    		}
    	} else {
    		mountVolume := &csipbv1.VolumeCapability_MountVolume{
    			FsType:     fsType,
    			MountFlags: mountOptions,
    		}
    		if fsGroup != nil {
    			mountVolume.VolumeMountGroup = strconv.FormatInt(*fsGroup, 10 /* base */)
    		}
    		req.VolumeCapability.AccessType = &csipbv1.VolumeCapability_Mount{
    			Mount: mountVolume,
    		}
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 33.9K bytes
    - Viewed (0)
  4. pkg/volume/util/operationexecutor/operation_executor_test.go

    			PluginIsDeviceMountable: false, // this field determines whether the plugin is devicemountable
    			ReportedInUse:           true,
    		}
    		oe.MountVolume(0 /* waitForAttachTimeOut */, volumesToMount[i], nil /* actualStateOfWorldMounterUpdater */, false /* isRemount */)
    	}
    
    	// Assert
    	if !isOperationRunConcurrently(ch, quit, numVolumesToMount) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 26.9K bytes
    - Viewed (0)
  5. pkg/volume/portworx/portworx.go

    	// 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
    	UnmountVolume(unmounter *portworxVolumeUnmounter, mountDir string) error
    	// Resize 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 detaching Portworx Volume (%v): %v", u.volName, err)
    		return err
    	}
    	return nil
    }
    
    // MountVolume mounts a Portworx Volume on the specified mountPath
    func (util *portworxVolumeUtil) MountVolume(m *portworxVolumeMounter, mountPath string) error {
    	driver, err := util.getLocalPortworxDriver(m.plugin.host)
    	if err != nil || driver == nil {
    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/util/operationexecutor/operation_executor.go

    	DetachVolume(logger klog.Logger, volumeToDetach AttachedVolume, verifySafeToDetach bool, actualStateOfWorld ActualStateOfWorldAttacherUpdater) error
    
    	// If a volume has 'Filesystem' volumeMode, MountVolume mounts the
    	// volume to the pod specified in volumeToMount.
    	// Specifically it will:
    	// * Wait for the device to finish attaching (for attachable volumes only).
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 42.6K bytes
    - Viewed (0)
  8. pkg/volume/csi/csi_block.go

     - TearDownDevice calls CSI's NodeUnstageVolume and unstage a volume from its staging path.
    
    These methods are called by below sequences:
     - operation_executor.MountVolume
       - csi.GetGlobalMapPath
       - csi.SetupDevice
         - NodeStageVolume
       - ASW.MarkDeviceAsMounted
       - csi.GetPodDeviceMapPath
       - csi.MapPodDevice
         - NodePublishVolume
       - util.MapBlockVolume
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Sep 11 06:07:40 UTC 2023
    - 20.1K bytes
    - Viewed (0)
  9. pkg/volume/csi/csi_plugin.go

    			},
    			VolumeMode: &fsMode,
    		},
    	}
    	return volume.NewSpecFromPersistentVolume(pv, false)
    }
    
    func (p *csiPlugin) SupportsMountOption() bool {
    	// TODO (vladimirvivien) use CSI VolumeCapability.MountVolume.mount_flags
    	// to probe for the result for this method
    	// (bswartz) Until the CSI spec supports probing, our only option is to
    	// make plugins register their support for mount options or lack thereof
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 29.2K bytes
    - Viewed (0)
Back to top