- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for NewIOHandler (0.24 sec)
-
pkg/volume/util/io_util.go
ReadDir(dirname string) ([]os.FileInfo, error) Lstat(name string) (os.FileInfo, error) EvalSymlinks(path string) (string, error) } type osIOHandler struct{} // NewIOHandler Create a new IoHandler implementation func NewIOHandler() IoUtil { return &osIOHandler{} } func (handler *osIOHandler) ReadFile(filename string) ([]byte, error) { return os.ReadFile(filename) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 20 14:49:03 UTC 2023 - 1.4K bytes - Viewed (0) -
pkg/volume/iscsi/attacher.go
volumeMode: volumeMode, readOnly: readOnly, mounter: &mount.SafeFormatAndMount{Interface: host.GetMounter(iscsiPluginName), Exec: exec}, exec: exec, deviceUtil: volumeutil.NewDeviceHandler(volumeutil.NewIOHandler()), }, nil } func volumeSpecToUnmounter(mounter mount.Interface, host volume.VolumeHost, plugin *iscsiPlugin) *iscsiDiskUnmounter { exec := host.GetExec(iscsiPluginName) return &iscsiDiskUnmounter{
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/fc/fc_util_test.go
fakeMounter := fcDiskMounter{ fcDisk: &fcDisk{ wwns: test.wwns, lun: test.lun, io: &fakeIOHandler{}, }, deviceUtil: util.NewDeviceHandler(util.NewIOHandler()), } devicePath, err := searchDisk(fakeMounter) if test.expectError && err == nil { t.Errorf("expected error but got none") } if !test.expectError && err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 23 08:36:01 UTC 2022 - 6.5K bytes - Viewed (0) -
pkg/volume/fc/attacher.go
mountOptions: volumeutil.MountOptionFromSpec(spec), }, nil } func volumeSpecToUnmounter(mounter mount.Interface, host volume.VolumeHost) *fcDiskUnmounter { return &fcDiskUnmounter{ fcDisk: &fcDisk{ io: &osIOHandler{}, }, mounter: mounter, deviceUtil: volumeutil.NewDeviceHandler(volumeutil.NewIOHandler()), exec: host.GetExec(fcPluginName),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 31 12:02:51 UTC 2022 - 7.5K bytes - Viewed (0) -
pkg/volume/fc/fc.go
fsType: fc.FSType, volumeMode: volumeMode, readOnly: readOnly, mounter: &mount.SafeFormatAndMount{Interface: mounter, Exec: exec}, deviceUtil: util.NewDeviceHandler(util.NewIOHandler()), mountOptions: util.MountOptionFromSpec(spec), }, nil } func (plugin *fcPlugin) NewBlockVolumeMapper(spec *volume.Spec, pod *v1.Pod, _ volume.VolumeOptions) (volume.BlockVolumeMapper, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 17.4K bytes - Viewed (0) -
pkg/volume/iscsi/iscsi.go
fsType: fsType, readOnly: readOnly, mounter: &mount.SafeFormatAndMount{Interface: mounter, Exec: exec}, exec: exec, deviceUtil: ioutil.NewDeviceHandler(ioutil.NewIOHandler()), mountOptions: ioutil.MountOptionFromSpec(spec), }, nil } // NewBlockVolumeMapper creates a new volume.BlockVolumeMapper from an API specification.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 23.4K bytes - Viewed (0)