device_connectivity

Documentation

Index

• Constants
• Variables
• type ConnectivityIscsiStorageTargetNotFoundError
  • func (e *ConnectivityIscsiStorageTargetNotFoundError) Error() string
• type ErrorNothingWasWrittenToScanFileError
  • func (e *ErrorNothingWasWrittenToScanFileError) Error() string
• type MultipleDeviceNotFoundError
  • func (e *MultipleDeviceNotFoundError) Error() string
• type MultipleDeviceNotFoundForLunError
  • func (e *MultipleDeviceNotFoundForLunError) Error() string
• type MultipleDmDevicesError
  • func (e *MultipleDmDevicesError) Error() string
• type OsDeviceConnectivityHelperIscsi
  • func (o OsDeviceConnectivityHelperIscsi) GetIscsiSessionHostsForArrayIQN(arrayIdentifier string) ([]int, error)
  • func (o OsDeviceConnectivityHelperIscsi) GetMultipathDisk(path string) (string, error)
  • func (o OsDeviceConnectivityHelperIscsi) WaitForPathToExist(devicePath string, maxRetries int, intervalSeconds int) ([]string, bool, error)
• type OsDeviceConnectivityHelperIscsiInterface
  • func NewOsDeviceConnectivityHelperIscsi(executer executer.ExecuterInterface) OsDeviceConnectivityHelperIscsiInterface
• type OsDeviceConnectivityInterface
  • func NewOsDeviceConnectivityIscsi(executer executer.ExecuterInterface) OsDeviceConnectivityInterface
• type OsDeviceConnectivityIscsi
  • func (r OsDeviceConnectivityIscsi) FlushMultipathDevice(mpathDevice string) error
  • func (r OsDeviceConnectivityIscsi) GetMpathDevice(volumeId string, lunId int, arrayIdentifier string) (string, error)
  • func (r OsDeviceConnectivityIscsi) RemovePhysicalDevice(sysDevices []string) error
  • func (r OsDeviceConnectivityIscsi) RescanDevices(lunId int, arrayIdentifier string) error

Constants

const (
	IscsiHostRexExPath = "/sys/class/iscsi_host/host*/device/session*/iscsi_session/session*/targetname"
)

Variables

var (
	TimeOutMultipathFlashCmd = 4 * 1000
)

Types

type ConnectivityIscsiStorageTargetNotFoundError

type ConnectivityIscsiStorageTargetNotFoundError struct {
	StorageTargetName string
	DirectoryPath     string
}

func (*ConnectivityIscsiStorageTargetNotFoundError) Error

func (e *ConnectivityIscsiStorageTargetNotFoundError) Error() string

type ErrorNothingWasWrittenToScanFileError

type ErrorNothingWasWrittenToScanFileError struct {
	// contains filtered or unexported fields
}

func (*ErrorNothingWasWrittenToScanFileError) Error

func (e *ErrorNothingWasWrittenToScanFileError) Error() string

type MultipleDeviceNotFoundError

type MultipleDeviceNotFoundError struct {
	DiskByPathDevice     string
	LinkToPhysicalDevice string
}

func (*MultipleDeviceNotFoundError) Error

func (e *MultipleDeviceNotFoundError) Error() string

type MultipleDeviceNotFoundForLunError

type MultipleDeviceNotFoundForLunError struct {
	VolumeId string
	LunId    int
	ArrayIqn string
}

func (*MultipleDeviceNotFoundForLunError) Error

func (e *MultipleDeviceNotFoundForLunError) Error() string

type MultipleDmDevicesError

type MultipleDmDevicesError struct {
	VolumeId            string
	LunId               int
	ArrayIqn            string
	MultipathDevicesMap map[string]bool
}

func (*MultipleDmDevicesError) Error

func (e *MultipleDmDevicesError) Error() string

type OsDeviceConnectivityHelperIscsi

type OsDeviceConnectivityHelperIscsi struct {
	// contains filtered or unexported fields
}

func (OsDeviceConnectivityHelperIscsi) GetIscsiSessionHostsForArrayIQN

func (o OsDeviceConnectivityHelperIscsi) GetIscsiSessionHostsForArrayIQN(arrayIdentifier string) ([]int, error)

func (OsDeviceConnectivityHelperIscsi) GetMultipathDisk

func (o OsDeviceConnectivityHelperIscsi) GetMultipathDisk(path string) (string, error)

func (OsDeviceConnectivityHelperIscsi) WaitForPathToExist

func (o OsDeviceConnectivityHelperIscsi) WaitForPathToExist(devicePath string, maxRetries int, intervalSeconds int) ([]string, bool, error)

type OsDeviceConnectivityHelperIscsiInterface

type OsDeviceConnectivityHelperIscsiInterface interface {
	/*
		This is helper interface for OsDeviceConnectivityIscsi.
		Mainly for writting clean unit testing, so we can Mock this interface in order to unit test OsDeviceConnectivityIscsi logic.
	*/
	WaitForPathToExist(devicePath string, maxRetries int, intervalSeconds int) ([]string, bool, error)
	GetMultipathDisk(path string) (string, error)
	GetIscsiSessionHostsForArrayIQN(arrayIdentifier string) ([]int, error)
}

func NewOsDeviceConnectivityHelperIscsi

func NewOsDeviceConnectivityHelperIscsi(executer executer.ExecuterInterface) OsDeviceConnectivityHelperIscsiInterface

type OsDeviceConnectivityInterface

type OsDeviceConnectivityInterface interface {
	RescanDevices(lunId int, arrayIdentifier string) error // For NVME lunID will be namespace ID.
	GetMpathDevice(volumeId string, lunId int, arrayIdentifier string) (string, error)
	FlushMultipathDevice(mpathDevice string) error
	RemovePhysicalDevice(sysDevices []string) error
}

func NewOsDeviceConnectivityIscsi

func NewOsDeviceConnectivityIscsi(executer executer.ExecuterInterface) OsDeviceConnectivityInterface

type OsDeviceConnectivityIscsi

type OsDeviceConnectivityIscsi struct {
	Executer        executer.ExecuterInterface
	MutexMultipathF *sync.Mutex
	Helper          OsDeviceConnectivityHelperIscsiInterface
}

func (OsDeviceConnectivityIscsi) FlushMultipathDevice

func (r OsDeviceConnectivityIscsi) FlushMultipathDevice(mpathDevice string) error

func (OsDeviceConnectivityIscsi) GetMpathDevice

func (r OsDeviceConnectivityIscsi) GetMpathDevice(volumeId string, lunId int, arrayIdentifier string) (string, error)

func (OsDeviceConnectivityIscsi) RemovePhysicalDevice

func (r OsDeviceConnectivityIscsi) RemovePhysicalDevice(sysDevices []string) error

func (OsDeviceConnectivityIscsi) RescanDevices

func (r OsDeviceConnectivityIscsi) RescanDevices(lunId int, arrayIdentifier string) error