block_device_utils

Documentation

Index

• Constants
• type BlockDeviceUtils
  • func NewBlockDeviceUtils() BlockDeviceUtils
  • func NewBlockDeviceUtilsWithExecutor(executor utils.Executor) BlockDeviceUtils
• type CommandExecuteError
  • func (e *CommandExecuteError) Error() string
• type Protocol
• type VolumeNotFoundError
  • func (e *VolumeNotFoundError) Error() string

Constants

const (
	NotMountedErrorMessage                   = "not mounted" // Error while umount device that is already unmounted
	TimeoutMilisecondMountCmdIsDeviceMounted = 20 * 1000     // max to wait for mount command
	TimeoutMilisecondMountCmdMountFs         = 120 * 1000    // max to wait for mounting device
	TimeoutMilisecondUmountCmdUmountFs       = 30 * 1000     // max wait timeout for umount command
)

const CleanupTimeout = 30 * 1000

const DiscoverTimeout = 20 * 1000

const MultipathTimeout = 60 * 1000

Types

type BlockDeviceUtils

type BlockDeviceUtils interface {
	Rescan(protocol Protocol) error
	ReloadMultipath() error
	Discover(volumeWwn string, deepDiscovery bool) (string, error)
	GetWwnByScsiInq(dev string) (string, error)
	DiscoverBySgInq(mpathOutput string, volumeWwn string) (string, error)
	Cleanup(mpath string) error
	CheckFs(mpath string) (bool, error)
	MakeFs(mpath string, fsType string) error
	MountFs(mpath string, mpoint string) error
	UmountFs(mpoint string, volumeWwn string) error
	IsDeviceMounted(devPath string) (bool, []string, error)
	IsDirAMountPoint(dirPath string) (bool, []string, error)
}

func NewBlockDeviceUtils

func NewBlockDeviceUtils() BlockDeviceUtils

func NewBlockDeviceUtilsWithExecutor

func NewBlockDeviceUtilsWithExecutor(executor utils.Executor) BlockDeviceUtils

type CommandExecuteError

type CommandExecuteError struct {
	Cmd string
	Err error
}

func (*CommandExecuteError) Error

func (e *CommandExecuteError) Error() string

type Protocol

type Protocol int

const (
	SCSI Protocol = iota
	ISCSI
)

type VolumeNotFoundError

type VolumeNotFoundError struct {
	VolName string
}

func (*VolumeNotFoundError) Error

func (e *VolumeNotFoundError) Error() string