mountmanager

Documentation

Index

• func NewCustomFakeSafeMounter(mounter mount.Interface, exec exec.Interface) *mount.SafeFormatAndMount
• func NewDeviceUtils() *deviceUtils
• func NewFakeDeviceUtils() *fakeDeviceUtils
• func NewFakeSafeBlockingMounter(readyToExecute chan chan struct{}) *mount.SafeFormatAndMount
• func NewFakeSafeMounter() *mount.SafeFormatAndMount
• func NewFakeSafeMounterWithCustomExec(exec exec.Interface) *mount.SafeFormatAndMount
• func NewFakeStatter(mounter *mount.SafeFormatAndMount) *fakeStatter
• func NewSafeMounter() (*mount.SafeFormatAndMount, error)
• func NewStatter(mounter *mount.SafeFormatAndMount) *realStatter
• type CSIProxyMounter
  • func NewCSIProxyMounter() (*CSIProxyMounter, error)
  • func (mounter *CSIProxyMounter) ExistsPath(path string) (bool, error)
  • func (mounter *CSIProxyMounter) FormatAndMount(source string, target string, fstype string, options []string) error
  • func (mounter *CSIProxyMounter) GetBlockSizeBytes(diskId string) (int64, error)
  • func (mounter *CSIProxyMounter) GetDevicePath(deviceName string, partition string, volumeKey string) (string, error)
  • func (mounter *CSIProxyMounter) GetMountRefs(pathname string) ([]string, error)
  • func (mounter *CSIProxyMounter) IsLikelyNotMountPoint(file string) (bool, error)
  • func (mounter *CSIProxyMounter) IsMountPointMatch(mp mount.MountPoint, dir string) bool
  • func (mounter *CSIProxyMounter) List() ([]mount.MountPoint, 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) RemovePodDir(target string) error
  • func (mounter *CSIProxyMounter) Unmount(target string) error
  • func (mounter *CSIProxyMounter) UnmountDevice(target string) error
• type DeviceUtils
• type FakeBlockingMounter
  • func (mounter *FakeBlockingMounter) Mount(source string, target string, fstype string, options []string) error
• type Statter

Functions

func NewCustomFakeSafeMounter

func NewCustomFakeSafeMounter(mounter mount.Interface, exec exec.Interface) *mount.SafeFormatAndMount

func NewDeviceUtils

func NewDeviceUtils() *deviceUtils

func NewFakeDeviceUtils

func NewFakeDeviceUtils() *fakeDeviceUtils

func NewFakeSafeBlockingMounter

func NewFakeSafeBlockingMounter(readyToExecute chan chan struct{}) *mount.SafeFormatAndMount

func NewFakeSafeMounter

func NewFakeSafeMounter() *mount.SafeFormatAndMount

func NewFakeSafeMounterWithCustomExec

func NewFakeSafeMounterWithCustomExec(exec exec.Interface) *mount.SafeFormatAndMount

func NewFakeStatter

func NewFakeStatter(mounter *mount.SafeFormatAndMount) *fakeStatter

func NewSafeMounter

func NewSafeMounter() (*mount.SafeFormatAndMount, error)

func NewStatter

func NewStatter(mounter *mount.SafeFormatAndMount) *realStatter

Types

type CSIProxyMounter

type CSIProxyMounter struct {
	FsClient     *fsclient.Client
	DiskClient   *diskclient.Client
	VolumeClient *volumeclient.Client
}

func NewCSIProxyMounter

func NewCSIProxyMounter() (*CSIProxyMounter, error)

func (*CSIProxyMounter) ExistsPath

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

ExistsPath - Checks if a path exists. Unlike util ExistsPath, this call does not perform follow link.

func (*CSIProxyMounter) FormatAndMount

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

FormatAndMount accepts the source disk number, target path to mount, the fstype to format with and options to be used. After formatting, it will mount the disk to target path on the host

func (*CSIProxyMounter) GetBlockSizeBytes

func (mounter *CSIProxyMounter) GetBlockSizeBytes(diskId string) (int64, error)

func (*CSIProxyMounter) GetDevicePath

func (mounter *CSIProxyMounter) GetDevicePath(deviceName string, partition string, volumeKey string) (string, error)

func (*CSIProxyMounter) GetMountRefs

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

func (*CSIProxyMounter) IsLikelyNotMountPoint

func (mounter *CSIProxyMounter) IsLikelyNotMountPoint(file string) (bool, error)

func (*CSIProxyMounter) IsMountPointMatch

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

func (*CSIProxyMounter) List

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

func (*CSIProxyMounter) Mount

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

Mount just creates a soft link at target pointing to source.

func (*CSIProxyMounter) MountSensitive

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

MountSensitive is the same as Mount() but this method allows sensitiveOptions to be passed in a separate parameter from the normal mount options and ensures the sensitiveOptions are never logged. Since Mount here is just create a synlink, so options and sensitiveOptions are not used here

func (*CSIProxyMounter) RemovePodDir

func (mounter *CSIProxyMounter) RemovePodDir(target string) error

Delete the given directory with Pod context. CSI proxy does a check for path prefix based on context

func (*CSIProxyMounter) Unmount

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

func (*CSIProxyMounter) UnmountDevice

func (mounter *CSIProxyMounter) UnmountDevice(target string) error

UnmountDevice uses target path to find the volume id first, and then call DismountVolume through csi-proxy. If succeeded, it will delete the given path at last step. CSI proxy does a check for path prefix based on context

type DeviceUtils

type DeviceUtils interface {
	// GetDiskByIdPaths returns a list of all possible paths for a
	// given Persistent Disk
	GetDiskByIdPaths(deviceName string, partition string) []string

	// VerifyDevicePath returns the first of the list of device paths that
	// exists on the machine, or an empty string if none exists
	VerifyDevicePath(devicePaths []string, deviceName string) (string, error)
}

DeviceUtils are a collection of methods that act on the devices attached to a GCE Instance

type FakeBlockingMounter

type FakeBlockingMounter struct {
	*mount.FakeMounter
	ReadyToExecute chan chan struct{}
}

func (*FakeBlockingMounter) Mount

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

Mount is overridden and adds functionality to finely control the order of execution of FakeMounter's Mount calls. Upon starting a Mount, it passes a chan 'executeMount' into readyToExecute, then blocks on executeMount. The test calling this function can block on readyToExecute to ensure that the operation has started and allowed the Mount to continue by passing a struct into executeMount.

type Statter

type Statter interface {
	StatFS(path string) (int64, int64, int64, int64, int64, int64, error)
	IsBlockDevice(string) (bool, error)
}