Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for NewIOHandler (0.17 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to top