Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for GetDeviceMountPath (0.33 sec)

  1. pkg/volume/flexvolume/attacher-defaults.go

    	return devicePath, nil
    }
    
    // GetDeviceMountPath is part of the volume.Attacher interface
    func (a *attacherDefaults) GetDeviceMountPath(spec *volume.Spec, mountsDir string) (string, error) {
    	return a.plugin.getDeviceMountPath(spec)
    }
    
    // MountDevice is part of the volume.Attacher interface
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Sep 17 04:51:24 UTC 2020
    - 2.4K bytes
    - Viewed (0)
  2. pkg/volume/flexvolume/attacher.go

    	} else if err != nil {
    		return "", err
    	}
    	return status.DevicePath, nil
    }
    
    // GetDeviceMountPath is part of the volume.Attacher interface
    func (a *flexVolumeAttacher) GetDeviceMountPath(spec *volume.Spec) (string, error) {
    	return a.plugin.getDeviceMountPath(spec)
    }
    
    // MountDevice is part of the volume.Attacher interface
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jul 03 23:29:42 UTC 2021
    - 3.6K bytes
    - Viewed (0)
  3. pkg/volume/flexvolume/expander.go

    	call := plugin.NewDriverCall(expandVolumeCmd)
    	call.AppendSpec(spec, plugin.host, nil)
    
    	devicePath, err := plugin.getDeviceMountPath(spec)
    	if err != nil {
    		return newSize, err
    	}
    	call.Append(devicePath)
    	call.Append(strconv.FormatInt(newSize.Value(), 10))
    	call.Append(strconv.FormatInt(oldSize.Value(), 10))
    
    	_, err = call.Run()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 14:21:44 UTC 2019
    - 2.2K bytes
    - Viewed (0)
  4. pkg/volume/flexvolume/mounter-defaults.go

    func (f *mounterDefaults) SetUpAt(dir string, mounterArgs volume.MounterArgs) error {
    	klog.Warning(logPrefix(f.plugin), "using default SetUpAt to ", dir)
    
    	src, err := f.plugin.getDeviceMountPath(f.spec)
    	if err != nil {
    		return err
    	}
    
    	if err := doMount(f.mounter, src, dir, "auto", []string{"bind"}); err != nil {
    		return err
    	}
    
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 24 15:56:30 UTC 2022
    - 1.5K bytes
    - Viewed (0)
  5. pkg/volume/flexvolume/plugin.go

    	return mounter.GetMountRefs(deviceMountPath)
    }
    
    func (plugin *flexVolumePlugin) getDeviceMountPath(spec *volume.Spec) (string, error) {
    	volumeName, err := plugin.GetVolumeName(spec)
    	if err != nil {
    		return "", fmt.Errorf("GetVolumeName failed from getDeviceMountPath: %s", err)
    	}
    
    	mountsDir := filepath.Join(plugin.host.GetPluginDir(flexVolumePluginName), plugin.driverName, "mounts")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  6. pkg/volume/iscsi/attacher.go

    	if err != nil {
    		klog.Warningf("failed to get iscsi mounter: %v", err)
    		return "", err
    	}
    	return attacher.manager.AttachDisk(*mounter)
    }
    
    func (attacher *iscsiAttacher) GetDeviceMountPath(
    	spec *volume.Spec) (string, error) {
    	mounter, err := volumeSpecToMounter(spec, attacher.host, attacher.targetLocks, nil)
    	if err != nil {
    		klog.Warningf("failed to get iscsi mounter: %v", err)
    		return "", err
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 04 08:51:31 UTC 2022
    - 6.8K bytes
    - Viewed (0)
  7. pkg/kubelet/volumemanager/reconciler/reconstruct.go

    		}
    		// If the volume has device to mount, we mark its device as uncertain.
    		if gvl.deviceMounter != nil || gvl.blockVolumeMapper != nil {
    			deviceMountPath, err := getDeviceMountPath(gvl)
    			if err != nil {
    				klog.ErrorS(err, "Could not find device mount path for volume", "volumeName", gvl.volumeName)
    				continue
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 10:23:12 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  8. pkg/volume/fc/attacher.go

    	if err != nil {
    		klog.Warningf("failed to get fc mounter: %v", err)
    		return "", err
    	}
    	return attacher.manager.AttachDisk(*mounter)
    }
    
    func (attacher *fcAttacher) GetDeviceMountPath(
    	spec *volume.Spec) (string, error) {
    	mounter, err := volumeSpecToMounter(spec, attacher.host)
    	if err != nil {
    		klog.Warningf("failed to get fc mounter: %v", err)
    		return "", err
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 31 12:02:51 UTC 2022
    - 7.5K bytes
    - Viewed (0)
Back to top