- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for GetDeviceMountPath (0.31 sec)
-
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/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) -
pkg/controller/volume/attachdetach/testing/testvolumespec.go
return fakePath, nil } func (attacher *testPluginAttacher) GetDeviceMountPath(spec *volume.Spec) (string, error) { attacher.pluginLock.Lock() defer attacher.pluginLock.Unlock() if spec == nil { *attacher.ErrorEncountered = true return "", fmt.Errorf("GetDeviceMountPath called with nil volume spec") } return "", nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 17 08:48:30 UTC 2023 - 16.5K bytes - Viewed (0) -
pkg/volume/local/local_test.go
} pvSpec := getTestVolume(false, tmpBlockDir, false, nil) expectedGlobalPath := filepath.Join(tmpBlockDir, testBlockFormattingToFSGlobalPath) actualPath, err := dm.GetDeviceMountPath(pvSpec) if err != nil { t.Errorf("Failed to get device mount path: %v", err) } if expectedGlobalPath != actualPath { t.Fatalf("Expected device mount global path:%s, got: %s", expectedGlobalPath, actualPath)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 08 10:53:39 UTC 2023 - 22.5K bytes - Viewed (0) -
pkg/volume/local/local.go
// the persistent-claim volume used to mount the PV return spec.ReadOnly, nil } return false, fmt.Errorf("spec does not reference a Local volume type") } func (dm *deviceMounter) GetDeviceMountPath(spec *volume.Spec) (string, error) { return dm.plugin.getGlobalLocalPath(spec) } func (plugin *localVolumePlugin) NewDeviceUnmounter() (volume.DeviceUnmounter, error) { return &deviceMounter{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 22.2K bytes - Viewed (0)