device_connectivity

Jan 24, 2023

Changes in this version

+ const DevMapperPath

+ var MultipathdWildcardsMpathNameAndVolumeId = []string

type OsDeviceConnectivityHelperGeneric

+ func (o OsDeviceConnectivityHelperGeneric) IsDmName(mpathDeviceName string) bool

type OsDeviceConnectivityHelperInterface

+ IsDmName func(mpathDeviceName string) bool

Jul 26, 2022

Changes in this version

+ var MultipathdWildcardsVolumeIdAndMpath = []string

type ErrorWrongDeviceFound

+ DevPath string

+ DmVolumeId string

+ SgInqVolumeId string

type GetDmsPathHelperGeneric

+ func (GetDmsPathHelperGeneric) GetFullDmPath(dms map[string]bool, volumeId string) (string, error)

+ func (GetDmsPathHelperGeneric) GetMpathDeviceNameFromProcMounts(procMounts string, volumePath string) (string, error)

+ func (o GetDmsPathHelperGeneric) ExtractDmFieldValues(dmFilterValues []string, mpathdOutput string) map[string]bool

+ func (o GetDmsPathHelperGeneric) ExtractVolumeId(mpathDeviceName string, mpathdOutput string) (string, error)

+ func (o GetDmsPathHelperGeneric) IsIndicatorMatchesFilterValues(dmFilterValues []string, indicatorValue string) bool

type GetDmsPathHelperInterface

+ ExtractDmFieldValues func(dmFilterValues []string, mpathdOutput string) map[string]bool

+ ExtractVolumeId func(mpathDeviceName string, mpathdOutput string) (string, error)

+ GetFullDmPath func(dms map[string]bool, volumeId string) (string, error)

+ GetMpathDeviceNameFromProcMounts func(procMounts string, volumePath string) (string, error)

+ IsIndicatorMatchesFilterValues func(dmFilterValues []string, dmFieldValue string) bool

+ type MultipathDeviceNotFoundForVolumePathError struct

+ VolumePath string

+ func (e *MultipathDeviceNotFoundForVolumePathError) Error() string

+ type MultipleDmFieldValuesError struct

+ DmFieldValues map[string]bool

+ Validator string

+ func (e *MultipleDmFieldValuesError) Error() string

type OsDeviceConnectivityHelperGeneric

+ func (OsDeviceConnectivityHelperGeneric) GetVolumeIdVariations(volumeUuid string) []string

+ func (o OsDeviceConnectivityHelperGeneric) GetMpathDeviceName(volumePath string) (string, error)

+ func (o OsDeviceConnectivityHelperGeneric) GetMpathVolumeId(mpathdOutput string, mpathDeviceName string) (string, error)

+ func (o OsDeviceConnectivityHelperGeneric) GetMpathdOutputForVolume(volumeIdVariations []string) (string, error)

+ func (o OsDeviceConnectivityHelperGeneric) IsAnyVariationInMpathVolumeId(mpathVolumeId string, volumeIdVariations []string) bool

type OsDeviceConnectivityHelperInterface

+ GetMpathDeviceName func(volumePath string) (string, error)

+ GetMpathVolumeId func(mpathdOutput string, mpathDeviceName string) (string, error)

+ GetMpathdOutputForVolume func(volumeIdVariations []string) (string, error)

+ GetVolumeIdVariations func(volumeUuid string) []string

+ IsAnyVariationInMpathVolumeId func(mpathVolumeId string, volumeIdVariations []string) bool

type OsDeviceConnectivityHelperScsiGeneric

+ func (r OsDeviceConnectivityHelperScsiGeneric) IsVolumePathMatchesVolumeId(volumeUuid string, volumePath string) (bool, error)

type OsDeviceConnectivityHelperScsiGenericInterface

+ IsVolumePathMatchesVolumeId func(volumeId string, volumePath string) (bool, error)

+ type VolumeIdNotFoundForMultipathDeviceNameError struct

+ func (e *VolumeIdNotFoundForMultipathDeviceNameError) Error() string

Mar 17, 2022

Changes in this version

+ const ISCSIErrNoObjsFound

+ const IscsiCmdTimeout

type OsDeviceConnectivityFc

+ func (r OsDeviceConnectivityFc) ValidateLun(lun int, sysDevices []string) error

type OsDeviceConnectivityHelperScsiGeneric

+ func (r OsDeviceConnectivityHelperScsiGeneric) ValidateLun(lun int, sysDevices []string) error

type OsDeviceConnectivityHelperScsiGenericInterface

+ ValidateLun func(lun int, sysDevices []string) error

type OsDeviceConnectivityInterface

+ ValidateLun func(lun int, sysDevices []string) error

type OsDeviceConnectivityIscsi

+ func (r OsDeviceConnectivityIscsi) ValidateLun(lun int, sysDevices []string) error

type OsDeviceConnectivityNvmeOFc

+ func (r OsDeviceConnectivityNvmeOFc) ValidateLun(_ int, _ []string) error

Dec 16, 2021

Changes in this version

+ const ConnectionTypeNVMEoFC

+ const FcHostSysfsPath

+ const WwnOuiEnd

+ const WwnVendorIdentifierEnd

+ var TimeOutBlockDevCmd = 10 * 1000

+ var TimeOutSgInqCmd = 3 * 1000

+ func ConvertScsiIdToNguid(scsiId string) string

type OsDeviceConnectivityInterface

+ func NewOsDeviceConnectivityNvmeOFc(executer executer.ExecuterInterface) OsDeviceConnectivityInterface

+ type OsDeviceConnectivityNvmeOFc struct

+ Executer executer.ExecuterInterface

+ HelperScsiGeneric OsDeviceConnectivityHelperScsiGenericInterface

+ func (r OsDeviceConnectivityNvmeOFc) EnsureLogin(_ map[string][]string)

+ func (r OsDeviceConnectivityNvmeOFc) FlushMultipathDevice(mpathDevice string) error

+ func (r OsDeviceConnectivityNvmeOFc) GetMpathDevice(volumeId string) (string, error)

+ func (r OsDeviceConnectivityNvmeOFc) RemovePhysicalDevice(sysDevices []string) error

+ func (r OsDeviceConnectivityNvmeOFc) RescanDevices(_ int, _ []string) error

Sep 30, 2021

Changes in this version

+ const VolumeStorageIdsDelimiter

Dec 17, 2020

Changes in this version

+ const VolumeIdDelimiter

Sep 16, 2020

Changes in this version

+ const MpathdSeparator

+ var TimeOutMultipathCmd = 60 * 1000

+ var TimeOutMultipathdCmd = 10 * 1000

+ type ErrorNoRegexWwnMatchInScsiInq struct

+ func (e *ErrorNoRegexWwnMatchInScsiInq) Error() string

+ type ErrorWrongDeviceFound struct

+ func (e *ErrorWrongDeviceFound) Error() string

+ type GetDmsPathHelperGeneric struct

+ func (o GetDmsPathHelperGeneric) WaitForDmToExist(volumeUuid string, maxRetries int, intervalSeconds int) (string, error)

+ type GetDmsPathHelperInterface interface

+ WaitForDmToExist func(volumeUuid string, maxRetries int, intervalSeconds int) (string, error)

+ func NewGetDmsPathHelperGeneric(executer executer.ExecuterInterface) GetDmsPathHelperInterface

+ type MultipathDeviceNotFoundForVolumeError struct

+ VolumeId string

+ func (e *MultipathDeviceNotFoundForVolumeError) Error() string

type MultipleDmDevicesError

+ MultipathDevices map[string]bool

type OsDeviceConnectivityHelperGeneric

+ Executer executer.ExecuterInterface

+ Helper GetDmsPathHelperInterface

+ func (o OsDeviceConnectivityHelperGeneric) GetDmsPath(volumeId string) (string, error)

+ func (o OsDeviceConnectivityHelperGeneric) GetWwnByScsiInq(dev string) (string, error)

+ func (o OsDeviceConnectivityHelperGeneric) ReloadMultipath() error

type OsDeviceConnectivityHelperInterface

+ GetDmsPath func(volumeId string) (string, error)

+ GetWwnByScsiInq func(dev string) (string, error)

+ ReloadMultipath func() error

Jun 30, 2020

Changes in this version

+ const GetMpahDevErrorsSep

+ const WaitForMpathRetries

+ const WaitForMpathWaitIntervalSec

+ type MultipathDeviceNotFoundForLunError struct

+ ArrayIqns []string

+ LunId int

+ VolumeId string

+ func (e *MultipathDeviceNotFoundForLunError) Error() string

+ type WaitForMpathResult struct

Mar 30, 2020

Changes in this version

+ const ConnectionTypeFC

+ const ConnectionTypeISCSI

type OsDeviceConnectivityFc

+ func (r OsDeviceConnectivityFc) EnsureLogin(_ map[string][]string)

type OsDeviceConnectivityInterface

+ EnsureLogin func(ipsByArrayIdentifier map[string][]string)

type OsDeviceConnectivityIscsi

+ func (r OsDeviceConnectivityIscsi) EnsureLogin(allPortalsByTarget map[string][]string)

Sep 24, 2019

Changes in this version

+ const DevPath

+ const FC_HOST_SYSFS_PATH

+ type ConnectivityIdentifierStorageTargetNotFoundError struct

+ DirectoryPath string

+ StorageTargetName string

+ func (e *ConnectivityIdentifierStorageTargetNotFoundError) Error() string

+ type ErrorNotFoundArrayIdentifiers struct

+ func (e *ErrorNotFoundArrayIdentifiers) Error() string

type MultipleDeviceNotFoundForLunError

+ ArrayIqns []string

type MultipleDmDevicesError

+ ArrayIqns []string

+ type OsDeviceConnectivityFc struct

+ Executer executer.ExecuterInterface

+ HelperScsiGeneric OsDeviceConnectivityHelperScsiGenericInterface

+ func (r OsDeviceConnectivityFc) FlushMultipathDevice(mpathDevice string) error

+ func (r OsDeviceConnectivityFc) GetMpathDevice(volumeId string, lunId int, arrayIdentifiers []string) (string, error)

+ func (r OsDeviceConnectivityFc) RemovePhysicalDevice(sysDevices []string) error

+ func (r OsDeviceConnectivityFc) RescanDevices(lunId int, arrayIdentifiers []string) error

+ type OsDeviceConnectivityHelperGeneric struct

+ func (o OsDeviceConnectivityHelperGeneric) GetHostsIdByArrayIdentifier(arrayIdentifier string) ([]int, error)

+ func (o OsDeviceConnectivityHelperGeneric) GetMultipathDisk(path string) (string, error)

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

+ type OsDeviceConnectivityHelperInterface interface

+ GetHostsIdByArrayIdentifier func(arrayIdentifier string) ([]int, error)

+ GetMultipathDisk func(path string) (string, error)

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

+ func NewOsDeviceConnectivityHelperGeneric(executer executer.ExecuterInterface) OsDeviceConnectivityHelperInterface

+ type OsDeviceConnectivityHelperScsiGeneric struct

+ Executer executer.ExecuterInterface

+ Helper OsDeviceConnectivityHelperInterface

+ MutexMultipathF *sync.Mutex

+ func (r OsDeviceConnectivityHelperScsiGeneric) FlushMultipathDevice(mpathDevice string) error

+ func (r OsDeviceConnectivityHelperScsiGeneric) GetMpathDevice(volumeId string, lunId int, arrayIdentifiers []string, connectivityType string) (string, error)

+ func (r OsDeviceConnectivityHelperScsiGeneric) RemovePhysicalDevice(sysDevices []string) error

+ func (r OsDeviceConnectivityHelperScsiGeneric) RescanDevices(lunId int, arrayIdentifiers []string) error

+ type OsDeviceConnectivityHelperScsiGenericInterface interface

+ FlushMultipathDevice func(mpathDevice string) error

+ GetMpathDevice func(volumeId string, lunId int, arrayIdentifiers []string, connectivityType string) (string, error)

+ RemovePhysicalDevice func(sysDevices []string) error

+ RescanDevices func(lunId int, arrayIdentifiers []string) error

+ func NewOsDeviceConnectivityHelperScsiGeneric(executer executer.ExecuterInterface) OsDeviceConnectivityHelperScsiGenericInterface

type OsDeviceConnectivityInterface

+ func NewOsDeviceConnectivityFc(executer executer.ExecuterInterface) OsDeviceConnectivityInterface

type OsDeviceConnectivityIscsi

+ HelperScsiGeneric OsDeviceConnectivityHelperScsiGenericInterface

Aug 14, 2019

Changes in this version

+ const IscsiHostRexExPath

+ var TimeOutMultipathFlashCmd = 4 * 1000

+ type ConnectivityIscsiStorageTargetNotFoundError struct

+ DirectoryPath string

+ StorageTargetName string

+ func (e *ConnectivityIscsiStorageTargetNotFoundError) Error() string

+ type ErrorNothingWasWrittenToScanFileError struct

+ func (e *ErrorNothingWasWrittenToScanFileError) Error() string

+ type MultipleDeviceNotFoundError struct

+ DiskByPathDevice string

+ LinkToPhysicalDevice string

+ func (e *MultipleDeviceNotFoundError) Error() string

+ type MultipleDeviceNotFoundForLunError struct

+ ArrayIqn string

+ LunId int

+ VolumeId string

+ func (e *MultipleDeviceNotFoundForLunError) Error() string

+ type MultipleDmDevicesError struct

+ ArrayIqn string

+ LunId int

+ MultipathDevicesMap map[string]bool

+ VolumeId string

+ func (e *MultipleDmDevicesError) Error() string

+ type OsDeviceConnectivityHelperIscsi struct

+ 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 interface

+ GetIscsiSessionHostsForArrayIQN func(arrayIdentifier string) ([]int, error)

+ GetMultipathDisk func(path string) (string, error)

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

+ func NewOsDeviceConnectivityHelperIscsi(executer executer.ExecuterInterface) OsDeviceConnectivityHelperIscsiInterface

+ type OsDeviceConnectivityInterface interface

+ FlushMultipathDevice func(mpathDevice string) error

+ GetMpathDevice func(volumeId string, lunId int, arrayIdentifier string) (string, error)

+ RemovePhysicalDevice func(sysDevices []string) error

+ RescanDevices func(lunId int, arrayIdentifier string) error

+ func NewOsDeviceConnectivityIscsi(executer executer.ExecuterInterface) OsDeviceConnectivityInterface

+ type OsDeviceConnectivityIscsi struct

+ Executer executer.ExecuterInterface

+ Helper OsDeviceConnectivityHelperIscsiInterface

+ MutexMultipathF *sync.Mutex

+ 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