- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for getDeviceMountPath (0.25 sec)
-
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) -
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) -
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) -
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) -
pkg/kubelet/volumemanager/reconciler/reconstruct_common.go
return } } // getDeviceMountPath returns device mount path for block volume which // implements BlockVolumeMapper or filesystem volume which implements // DeviceMounter func getDeviceMountPath(gvi *globalVolumeInfo) (string, error) { if gvi.blockVolumeMapper != nil { // for block gvi, we return its global map path
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/volume/csi/csi_test.go
csiDevMounter := getCsiAttacherFromDeviceMounter(devMounter, test.watchTimeout) csiDevMounter.csiClient = csiClient devMountPath, err := csiDevMounter.GetDeviceMountPath(volSpec) if err != nil { t.Fatalf("csiTest.VolumeAll deviceMounter.GetdeviceMountPath failed %s", err) } if err := csiDevMounter.MountDevice(volSpec, devicePath, devMountPath, volume.DeviceMounterArgs{}); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 03 15:55:13 UTC 2022 - 21.1K bytes - Viewed (0) -
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) -
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) -
pkg/volume/volume.go
} // DeviceMounter can mount a block volume to a global path. type DeviceMounter interface { // GetDeviceMountPath returns a path where the device should // be mounted after it is attached. This is a global mount // point which should be bind mounted for individual volumes. GetDeviceMountPath(spec *Spec) (string, error) // MountDevice mounts the disk to a global path which // individual pods can then bind mount
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 11.8K bytes - Viewed (0) -
pkg/volume/csi/csi_attacher.go
return attached, nil } func (c *csiAttacher) GetDeviceMountPath(spec *volume.Spec) (string, error) { klog.V(4).Info(log("attacher.GetDeviceMountPath(%v)", spec)) deviceMountPath, err := makeDeviceMountPath(c.plugin, spec) if err != nil { return "", errors.New(log("attacher.GetDeviceMountPath failed to make device mount path: %v", err)) } klog.V(4).Infof("attacher.GetDeviceMountPath succeeded, deviceMountPath: %s", deviceMountPath)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 03 07:38:14 UTC 2023 - 25.9K bytes - Viewed (0)