mounter

Nov 11, 2024

Changes in this version

+ func NewSafeMounterV2() (*mountutils.SafeFormatAndMount, error) — darwin/amd64

type NodeMounter — darwin/amd64

+ func (m *NodeMounter) FindDevicePath(devicePath, volumeID, partition, region string) (string, error)

+ func (m *NodeMounter) GetBlockSizeBytes(devicePath string) (int64, error)

+ func (m *NodeMounter) IsBlockDevice(fullPath string) (bool, error)

+ func (m *NodeMounter) MakeDir(path string) error

+ func (m *NodeMounter) MakeFile(path string) error

+ func (m *NodeMounter) NeedResize(devicePath string, deviceMountPath string) (bool, error)

+ func (m *NodeMounter) PathExists(path string) (bool, error)

+ func (m *NodeMounter) PreparePublishTarget(target string) error

+ func (m *NodeMounter) Resize(devicePath, deviceMountPath string) (bool, error)

+ func (m *NodeMounter) Unpublish(path string) error

+ func (m *NodeMounter) Unstage(path string) error

+ func (m NodeMounter) GetDeviceNameFromMount(mountPath string) (string, int, error)

+ func (m NodeMounter) IsCorruptedMnt(err error) bool

May 15, 2024

Changes in this version

+ var ErrUnsupportedMounter = fmt.Errorf("unsupported mounter type") — windows/amd64

+ func NewSafeMounterV2() (*mountutils.SafeFormatAndMount, error) — linux/amd64, windows/amd64

type CSIProxyMounter — windows/amd64

+ func (mounter *CSIProxyMounter) CanSafelySkipMountPointCheck() bool

+ func (mounter *CSIProxyMounter) FindDevicePath(devicePath, volumeID, _, _ string) (string, error)

+ type CSIProxyMounterV2 struct — windows/amd64

+ DiskClient diskv2.Interface

+ FsClient fsv2.Interface

+ VolumeClient volumev2.Interface

+ func (mounter *CSIProxyMounterV2) CanSafelySkipMountPointCheck() bool

+ func (mounter *CSIProxyMounterV2) DeviceOpened(pathname string) (bool, error)

+ func (mounter *CSIProxyMounterV2) EvalHostSymlinks(pathname string) (string, error)

+ func (mounter *CSIProxyMounterV2) ExistsPath(path string) (bool, error)

+ func (mounter *CSIProxyMounterV2) FindDevicePath(devicePath, volumeID, _, _ string) (string, error)

+ func (mounter *CSIProxyMounterV2) FindDiskByLun(lun string) (diskNum string, err error)

+ func (mounter *CSIProxyMounterV2) FormatAndMountSensitiveWithFormatOptions(source string, target string, fstype string, options []string, ...) error

+ func (mounter *CSIProxyMounterV2) GetDeviceNameFromMount(mountPath, _ string) (string, error)

+ func (mounter *CSIProxyMounterV2) GetDeviceSize(devicePath string) (int64, error)

+ func (mounter *CSIProxyMounterV2) GetFSGroup(pathname string) (int64, error)

+ func (mounter *CSIProxyMounterV2) GetMode(pathname string) (os.FileMode, error)

+ func (mounter *CSIProxyMounterV2) GetMountRefs(pathname string) ([]string, error)

+ func (mounter *CSIProxyMounterV2) GetSELinuxSupport(pathname string) (bool, error)

+ func (mounter *CSIProxyMounterV2) GetVolumeSizeInBytes(deviceMountPath string) (int64, error)

+ func (mounter *CSIProxyMounterV2) IsLikelyNotMountPoint(path string) (bool, error)

+ func (mounter *CSIProxyMounterV2) IsMountPoint(file string) (bool, error)

+ func (mounter *CSIProxyMounterV2) IsMountPointMatch(mp mountutils.MountPoint, dir string) bool

+ func (mounter *CSIProxyMounterV2) List() ([]mountutils.MountPoint, error)

+ func (mounter *CSIProxyMounterV2) MakeDir(pathname string) error

+ func (mounter *CSIProxyMounterV2) MakeFile(pathname string) error

+ func (mounter *CSIProxyMounterV2) MakeRShared(path string) error

+ func (mounter *CSIProxyMounterV2) Mount(source string, target string, fstype string, options []string) error

+ func (mounter *CSIProxyMounterV2) MountSensitive(source string, target string, fstype string, options []string, ...) error

+ func (mounter *CSIProxyMounterV2) MountSensitiveWithoutSystemd(source string, target string, fstype string, options []string, ...) error

+ func (mounter *CSIProxyMounterV2) MountSensitiveWithoutSystemdWithMountFlags(source string, target string, fstype string, options []string, ...) error

+ func (mounter *CSIProxyMounterV2) PathIsDevice(pathname string) (bool, error)

+ func (mounter *CSIProxyMounterV2) Rescan() error

+ func (mounter *CSIProxyMounterV2) ResizeVolume(deviceMountPath string) (bool, error)

+ func (mounter *CSIProxyMounterV2) Rmdir(path string) error

+ func (mounter *CSIProxyMounterV2) Unmount(target string) error

+ func (mounter *CSIProxyMounterV2) WriteVolumeCache(target string)

Apr 22, 2024

Changes in this version

+ const DefaultBlockSize — windows/amd64

+ type MockMounter struct

+ func NewMockMounter(ctrl *gomock.Controller) *MockMounter

+ func (m *MockMounter) CanSafelySkipMountPointCheck() bool

+ func (m *MockMounter) EXPECT() *MockMounterMockRecorder

+ func (m *MockMounter) FindDevicePath(devicePath, volumeID, partition, region string) (string, error)

+ func (m *MockMounter) FormatAndMountSensitiveWithFormatOptions(source, target, fstype string, ...) error

+ func (m *MockMounter) GetBlockSizeBytes(devicePath string) (int64, error)

+ func (m *MockMounter) GetDeviceNameFromMount(mountPath string) (string, int, error)

+ func (m *MockMounter) GetMountRefs(pathname string) ([]string, error)

+ func (m *MockMounter) IsBlockDevice(fullPath string) (bool, error)

+ func (m *MockMounter) IsCorruptedMnt(err error) bool

+ func (m *MockMounter) IsLikelyNotMountPoint(file string) (bool, error)

+ func (m *MockMounter) IsMountPoint(file string) (bool, error)

+ func (m *MockMounter) List() ([]mount.MountPoint, error)

+ func (m *MockMounter) MakeDir(path string) error

+ func (m *MockMounter) MakeFile(path string) error

+ func (m *MockMounter) Mount(source, target, fstype string, options []string) error

+ func (m *MockMounter) MountSensitive(source, target, fstype string, options, sensitiveOptions []string) error

+ func (m *MockMounter) MountSensitiveWithoutSystemd(source, target, fstype string, options, sensitiveOptions []string) error

+ func (m *MockMounter) MountSensitiveWithoutSystemdWithMountFlags(source, target, fstype string, options, sensitiveOptions, mountFlags []string) error

+ func (m *MockMounter) NeedResize(devicePath, deviceMountPath string) (bool, error)

+ func (m *MockMounter) PathExists(path string) (bool, error)

+ func (m *MockMounter) PreparePublishTarget(target string) error

+ func (m *MockMounter) Resize(devicePath, deviceMountPath string) (bool, error)

+ func (m *MockMounter) Unmount(target string) error

+ func (m *MockMounter) Unpublish(path string) error

+ func (m *MockMounter) Unstage(path string) error

+ type MockMounterMockRecorder struct

+ func (mr *MockMounterMockRecorder) CanSafelySkipMountPointCheck() *gomock.Call

+ func (mr *MockMounterMockRecorder) FindDevicePath(devicePath, volumeID, partition, region interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) FormatAndMountSensitiveWithFormatOptions(source, target, fstype, options, sensitiveOptions, formatOptions interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) GetBlockSizeBytes(devicePath interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) GetDeviceNameFromMount(mountPath interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) GetMountRefs(pathname interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) IsBlockDevice(fullPath interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) IsCorruptedMnt(err interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) IsLikelyNotMountPoint(file interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) IsMountPoint(file interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) List() *gomock.Call

+ func (mr *MockMounterMockRecorder) MakeDir(path interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) MakeFile(path interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) Mount(source, target, fstype, options interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) MountSensitive(source, target, fstype, options, sensitiveOptions interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) MountSensitiveWithoutSystemd(source, target, fstype, options, sensitiveOptions interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) MountSensitiveWithoutSystemdWithMountFlags(source, target, fstype, options, sensitiveOptions, mountFlags interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) NeedResize(devicePath, deviceMountPath interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) PathExists(path interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) PreparePublishTarget(target interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) Resize(devicePath, deviceMountPath interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) Unmount(target interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) Unpublish(path interface{}) *gomock.Call

+ func (mr *MockMounterMockRecorder) Unstage(path interface{}) *gomock.Call

+ type Mounter interface

+ FindDevicePath func(devicePath, volumeID, partition, region string) (string, error)

+ FormatAndMountSensitiveWithFormatOptions func(source string, target string, fstype string, options []string, ...) error

+ GetBlockSizeBytes func(devicePath string) (int64, error)

+ GetDeviceNameFromMount func(mountPath string) (string, int, error)

+ IsBlockDevice func(fullPath string) (bool, error)

+ IsCorruptedMnt func(err error) bool

+ MakeDir func(path string) error

+ MakeFile func(path string) error

+ NeedResize func(devicePath string, deviceMountPath string) (bool, error)

+ PathExists func(path string) (bool, error)

+ PreparePublishTarget func(target string) error

+ Resize func(devicePath, deviceMountPath string) (bool, error)

+ Unpublish func(path string) error

+ Unstage func(path string) error

+ func NewNodeMounter() (Mounter, error)

+ type NodeMounter struct

+ func (m *NodeMounter) FindDevicePath(devicePath, volumeID, partition, region string) (string, error)

+ func (m *NodeMounter) GetBlockSizeBytes(devicePath string) (int64, error)

+ func (m *NodeMounter) IsBlockDevice(fullPath string) (bool, error)

+ func (m *NodeMounter) MakeDir(path string) error

+ func (m *NodeMounter) MakeFile(path string) error

+ func (m *NodeMounter) NeedResize(devicePath string, deviceMountPath string) (bool, error)

+ func (m *NodeMounter) NeedResize(devicePath, deviceMountPath string) (bool, error)

+ func (m *NodeMounter) PathExists(path string) (bool, error)

+ func (m *NodeMounter) PreparePublishTarget(target string) error

+ func (m *NodeMounter) Resize(devicePath, deviceMountPath string) (bool, error)

+ func (m *NodeMounter) Unpublish(path string) error

+ func (m *NodeMounter) Unpublish(target string) error

+ func (m *NodeMounter) Unstage(path string) error

+ func (m *NodeMounter) Unstage(target string) error

+ func (m NodeMounter) FindDevicePath(devicePath, volumeID, _, _ string) (string, error)

+ func (m NodeMounter) FormatAndMountSensitiveWithFormatOptions(source string, target string, fstype string, options []string, ...) error

+ func (m NodeMounter) GetBlockSizeBytes(devicePath string) (int64, error)

+ func (m NodeMounter) GetDeviceNameFromMount(mountPath string) (string, int, error)

+ func (m NodeMounter) IsBlockDevice(fullPath string) (bool, error)

+ func (m NodeMounter) IsCorruptedMnt(err error) bool

+ func (m NodeMounter) PreparePublishTarget(target string) error

May 15, 2023

Changes in this version

type MockProxyMounter — windows/amd64

+ func (m *MockProxyMounter) CanSafelySkipMountPointCheck() bool

type MockProxyMounterMockRecorder — windows/amd64

+ func (mr *MockProxyMounterMockRecorder) CanSafelySkipMountPointCheck() *gomock.Call

Jan 12, 2023

Changes in this version

type CSIProxyMounter — windows/amd64

+ func (mounter *CSIProxyMounter) FormatAndMountSensitiveWithFormatOptions(source string, target string, fstype string, options []string, ...) error

type MockProxyMounter — windows/amd64

+ func (m *MockProxyMounter) FormatAndMountSensitiveWithFormatOptions(source, target, fstype string, ...) error

type MockProxyMounterMockRecorder — windows/amd64

+ func (mr *MockProxyMounterMockRecorder) FormatAndMountSensitiveWithFormatOptions(source, target, fstype, options, sensitiveOptions, formatOptions interface{}) *gomock.Call

type ProxyMounter — windows/amd64

+ FormatAndMountSensitiveWithFormatOptions func(source string, target string, fstype string, options []string, ...) error

Nov 2, 2022

Changes in this version

type CSIProxyMounter — windows/amd64

+ func (mounter *CSIProxyMounter) IsMountPoint(file string) (bool, error)

type MockProxyMounter — windows/amd64

+ func (m *MockProxyMounter) IsMountPoint(file string) (bool, error)

type MockProxyMounterMockRecorder — windows/amd64

+ func (mr *MockProxyMounterMockRecorder) IsMountPoint(file interface{}) *gomock.Call

type ProxyMounter — windows/amd64

+ IsMountPoint func(pathname string) (bool, error)

Jul 12, 2022

Changes in this version

type MockProxyMounter — windows/amd64

+ func (m *MockProxyMounter) MountSensitiveWithoutSystemdWithMountFlags(source, target, fstype string, options, sensitiveOptions, mountFlags []string) error

type MockProxyMounterMockRecorder — windows/amd64

+ func (mr *MockProxyMounterMockRecorder) MountSensitiveWithoutSystemdWithMountFlags(source, target, fstype, options, sensitiveOptions, mountFlags interface{}) *gomock.Call

Jun 21, 2022

Changes in this version

+ type MockProxyMounter struct — windows/amd64

+ func NewMockProxyMounter(ctrl *gomock.Controller) *MockProxyMounter

+ func (m *MockProxyMounter) EXPECT() *MockProxyMounterMockRecorder

+ func (m *MockProxyMounter) ExistsPath(path string) (bool, error)

+ func (m *MockProxyMounter) FindDiskByLun(lun string) (string, error)

+ func (m *MockProxyMounter) FormatAndMount(source, target, fstype string, options []string) error

+ func (m *MockProxyMounter) GetDeviceNameFromMount(mountPath, pluginMountDir string) (string, error)

+ func (m *MockProxyMounter) GetDeviceSize(devicePath string) (int64, error)

+ func (m *MockProxyMounter) GetMountRefs(pathname string) ([]string, error)

+ func (m *MockProxyMounter) GetVolumeSizeInBytes(deviceMountPath string) (int64, error)

+ func (m *MockProxyMounter) IsLikelyNotMountPoint(file string) (bool, error)

+ func (m *MockProxyMounter) IsMountPointMatch(mp mount.MountPoint, dir string) bool

+ func (m *MockProxyMounter) List() ([]mount.MountPoint, error)

+ func (m *MockProxyMounter) MakeFile(pathname string) error

+ func (m *MockProxyMounter) Mount(source, target, fstype string, options []string) error

+ func (m *MockProxyMounter) MountSensitive(source, target, fstype string, options, sensitiveOptions []string) error

+ func (m *MockProxyMounter) MountSensitiveWithoutSystemd(source, target, fstype string, options, sensitiveOptions []string) error

+ func (m *MockProxyMounter) Rescan() error

+ func (m *MockProxyMounter) ResizeVolume(deviceMountPath string) (bool, error)

+ func (m *MockProxyMounter) Rmdir(path string) error

+ func (m *MockProxyMounter) Unmount(target string) error

+ func (m *MockProxyMounter) WriteVolumeCache(target string)

+ type MockProxyMounterMockRecorder struct — windows/amd64

+ func (mr *MockProxyMounterMockRecorder) ExistsPath(path interface{}) *gomock.Call

+ func (mr *MockProxyMounterMockRecorder) FindDiskByLun(lun interface{}) *gomock.Call

+ func (mr *MockProxyMounterMockRecorder) FormatAndMount(source, target, fstype, options interface{}) *gomock.Call

+ func (mr *MockProxyMounterMockRecorder) GetDeviceNameFromMount(mountPath, pluginMountDir interface{}) *gomock.Call

+ func (mr *MockProxyMounterMockRecorder) GetDeviceSize(devicePath interface{}) *gomock.Call

+ func (mr *MockProxyMounterMockRecorder) GetMountRefs(pathname interface{}) *gomock.Call

+ func (mr *MockProxyMounterMockRecorder) GetVolumeSizeInBytes(deviceMountPath interface{}) *gomock.Call

+ func (mr *MockProxyMounterMockRecorder) IsLikelyNotMountPoint(file interface{}) *gomock.Call

+ func (mr *MockProxyMounterMockRecorder) IsMountPointMatch(mp, dir interface{}) *gomock.Call

+ func (mr *MockProxyMounterMockRecorder) List() *gomock.Call

+ func (mr *MockProxyMounterMockRecorder) MakeFile(pathname interface{}) *gomock.Call

+ func (mr *MockProxyMounterMockRecorder) Mount(source, target, fstype, options interface{}) *gomock.Call

+ func (mr *MockProxyMounterMockRecorder) MountSensitive(source, target, fstype, options, sensitiveOptions interface{}) *gomock.Call

+ func (mr *MockProxyMounterMockRecorder) MountSensitiveWithoutSystemd(source, target, fstype, options, sensitiveOptions interface{}) *gomock.Call

+ func (mr *MockProxyMounterMockRecorder) Rescan() *gomock.Call

+ func (mr *MockProxyMounterMockRecorder) ResizeVolume(deviceMountPath interface{}) *gomock.Call

+ func (mr *MockProxyMounterMockRecorder) Rmdir(path interface{}) *gomock.Call

+ func (mr *MockProxyMounterMockRecorder) Unmount(target interface{}) *gomock.Call

+ func (mr *MockProxyMounterMockRecorder) WriteVolumeCache(target interface{}) *gomock.Call

+ type ProxyMounter interface — windows/amd64

+ ExistsPath func(path string) (bool, error)

+ FindDiskByLun func(lun string) (diskNum string, err error)

+ FormatAndMount func(source, target, fstype string, options []string) error

+ GetDeviceNameFromMount func(mountPath, pluginMountDir string) (string, error)

+ GetDeviceSize func(devicePath string) (int64, error)

+ GetVolumeSizeInBytes func(deviceMountPath string) (int64, error)

+ IsMountPointMatch func(mp mount.MountPoint, dir string) bool

+ MakeFile func(pathname string) error

+ Rescan func() error

+ ResizeVolume func(deviceMountPath string) (bool, error)

+ Rmdir func(path string) error

+ WriteVolumeCache func(target string)

Apr 21, 2022

Changes in this version

type CSIProxyMounter — windows/amd64

+ func (mounter *CSIProxyMounter) GetDeviceSize(devicePath string) (int64, error)

+ func (mounter *CSIProxyMounter) WriteVolumeCache(target string)

Apr 13, 2022

Changes in this version

type CSIProxyMounter — windows/amd64

+ func (mounter *CSIProxyMounter) MountSensitiveWithoutSystemdWithMountFlags(source string, target string, fstype string, options []string, ...) error

Mar 29, 2021

Changes in this version

+ func NewSafeMounter() (*mount.SafeFormatAndMount, error) — darwin/amd64, linux/amd64, windows/amd64

+ type CSIProxyMounter struct — windows/amd64

+ DiskClient *diskclient.Client

+ FsClient *fsclient.Client

+ VolumeClient *volumeclient.Client

+ func NewCSIProxyMounter() (*CSIProxyMounter, error)

+ func (mounter *CSIProxyMounter) DeviceOpened(pathname string) (bool, error)

+ func (mounter *CSIProxyMounter) EvalHostSymlinks(pathname string) (string, error)

+ func (mounter *CSIProxyMounter) ExistsPath(path string) (bool, error)

+ func (mounter *CSIProxyMounter) FindDiskByLun(lun string) (diskNum string, err error)

+ func (mounter *CSIProxyMounter) FormatAndMount(source string, target string, fstype string, options []string) error

+ func (mounter *CSIProxyMounter) GetDeviceNameFromMount(mountPath, pluginMountDir string) (string, error)

+ func (mounter *CSIProxyMounter) GetFSGroup(pathname string) (int64, error)

+ func (mounter *CSIProxyMounter) GetMode(pathname string) (os.FileMode, error)

+ func (mounter *CSIProxyMounter) GetMountRefs(pathname string) ([]string, error)

+ func (mounter *CSIProxyMounter) GetSELinuxSupport(pathname string) (bool, error)

+ func (mounter *CSIProxyMounter) GetVolumeSizeInBytes(devicePath string) (int64, error)

+ func (mounter *CSIProxyMounter) IsLikelyNotMountPoint(path string) (bool, error)

+ func (mounter *CSIProxyMounter) IsMountPointMatch(mp mount.MountPoint, dir string) bool

+ func (mounter *CSIProxyMounter) List() ([]mount.MountPoint, error)

+ func (mounter *CSIProxyMounter) MakeDir(pathname string) error

+ func (mounter *CSIProxyMounter) MakeFile(pathname string) error

+ func (mounter *CSIProxyMounter) MakeRShared(path string) error

+ func (mounter *CSIProxyMounter) Mount(source string, target string, fstype string, options []string) error

+ func (mounter *CSIProxyMounter) MountSensitive(source string, target string, fstype string, options []string, ...) error

+ func (mounter *CSIProxyMounter) MountSensitiveWithoutSystemd(source string, target string, fstype string, options []string, ...) error

+ func (mounter *CSIProxyMounter) PathIsDevice(pathname string) (bool, error)

+ func (mounter *CSIProxyMounter) Rescan() error

+ func (mounter *CSIProxyMounter) ResizeVolume(devicePath string) error

+ func (mounter *CSIProxyMounter) Rmdir(path string) error

+ func (mounter *CSIProxyMounter) Unmount(target string) error