driver

Jun 26, 2025

Changes in this version

+ type LunAlreadyProcessingError struct

+ func (e *LunAlreadyProcessingError) Error() string

type SyncLock

+ CleanScsiDevice bool

+ func (s SyncLock) AddVolumeAndLunLock(id string, lun int, msg string) error

+ func (s SyncLock) RemoveVolumeAndLunLock(id string, lun int, msg string)

type SyncLockInterface

+ AddVolumeAndLunLock func(id string, lun int, msg string) error

+ RemoveVolumeAndLunLock func(id string, lun int, msg string)

May 25, 2025

Changes in this version

type SyncLock

+ Tokens chan struct{}

+ type VolumeNoResources struct

+ func (e *VolumeNoResources) Error() string

Jul 26, 2022

Changes in this version

+ const BlockDevCmd

type ConfigFile

+ Connectivity_type Connectivity_type

+ Parameters Parameters

+ type Connectivity_type struct

+ Fc string

+ Iscsi string

+ Nvme_over_fc string

+ type Controller struct

+ Publish_context_array_iqn string

+ Publish_context_connectivity_parameter string

+ Publish_context_fc_initiators string

+ Publish_context_lun_parameter string

+ Publish_context_separator string

+ type Identity struct

+ Name string

+ Version string

type NodeUtils

+ ConfigYaml ConfigFile

+ func (d NodeUtils) GetVolumeUuid(volumeId string) string

type NodeUtilsInterface

+ GetVolumeUuid func(volumeId string) string

+ type Node_id_info struct

+ Delimiter string

+ Fcs_delimiter string

+ type Object_id_info struct

+ Delimiter string

+ Ids_delimiter string

+ type Parameters struct

+ Node_id_info Node_id_info

+ Object_id_info Object_id_info

Mar 17, 2022

Changes in this version

type NodeUtils

+ func (d NodeUtils) GetBlockVolumeStats(mpathDevice string) (VolumeStatistics, error)

+ func (d NodeUtils) GetFileSystemVolumeStats(path string) (VolumeStatistics, error)

+ func (n NodeUtils) IsBlock(devicePath string) (bool, error)

type NodeUtilsInterface

+ GetBlockVolumeStats func(mpathDevice string) (VolumeStatistics, error)

+ GetFileSystemVolumeStats func(path string) (VolumeStatistics, error)

+ IsBlock func(devicePath string) (bool, error)

+ type VolumeStatistics struct

+ AvailableBytes int64

+ AvailableInodes int64

+ TotalBytes int64

+ TotalInodes int64

+ UsedBytes int64

+ UsedInodes int64

Dec 16, 2021

Changes in this version

+ const TimeOutGeneralCmd

+ const TimeOutNvmeCmd

+ var ErrorWhileTryingToReadPort = "Error while trying to get %s port from string: %v."

+ var NvmeFullPath = "/host/etc/nvme/hostnqn"

type NodeUtils

+ func (n NodeUtils) DevicesAreNvme(sysDevices []string) (bool, error)

+ func (n NodeUtils) ReadNvmeNqn() (string, error)

type NodeUtilsInterface

+ DevicesAreNvme func(sysDevices []string) (bool, error)

+ ReadNvmeNqn func() (string, error)

Sep 30, 2021

Changes in this version

type NodeUtils

+ func (n NodeUtils) IsFCExists() bool

type NodeUtilsInterface

+ IsFCExists func() bool

Jun 16, 2021

Changes in this version

type NodeUtils

+ func (n NodeUtils) GetTopologyLabels(ctx context.Context, nodeName string) (map[string]string, error)

type NodeUtilsInterface

+ GetTopologyLabels func(ctx context.Context, nodeName string) (map[string]string, error)

Dec 17, 2020

Changes in this version

+ const MaxNodeIdLength

+ const NodeIdDelimiter

+ const NodeIdFcDelimiter

+ const TimeOutMultipathdCmd

+ var ErrorNoPortsCouldFitInNodeId = "could not fit any ports in node id: %v, length limit: %d"

type NodeMounter

+ GetDiskFormat func(disk string) (string, error)

type NodeService

+ OsDeviceConnectivityHelper device_connectivity.OsDeviceConnectivityHelperScsiGenericInterface

type NodeUtils

+ func (n NodeUtils) ExpandFilesystem(devicePath string, fsType string) error

+ func (n NodeUtils) ExpandMpathDevice(mpathDevice string) error

+ func (n NodeUtils) FormatDevice(devicePath string, fsType string)

+ func (n NodeUtils) GenerateNodeID(hostName string, fcWWNs []string, iscsiIQN string) (string, error)

+ func (n NodeUtils) MakeDir(dirPath string) error

+ func (n NodeUtils) MakeFile(filePath string) error

+ func (n NodeUtils) RescanPhysicalDevices(sysDevices []string) error

type NodeUtilsInterface

+ ExpandFilesystem func(devicePath string, fsType string) error

+ ExpandMpathDevice func(mpathDevice string) error

+ FormatDevice func(devicePath string, fsType string)

+ GenerateNodeID func(hostName string, fcWWNs []string, iscsiIQN string) (string, error)

+ MakeDir func(dirPath string) error

+ MakeFile func(filePath string) error

+ RescanPhysicalDevices func(sysDevices []string) error

Mar 30, 2020

Changes in this version

+ const PublishContextSeparator

+ var StageInfoFilename = ".stageInfo.json"

+ type NodeMounter interface

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

type NodeService

+ Mounter NodeMounter

type NodeUtils

+ func (n NodeUtils) GetArrayInitiators(ipsByArrayInitiator map[string][]string) []string

+ func (n NodeUtils) GetPodPath(origPath string) string

+ func (n NodeUtils) IsDirectory(path string) bool

+ func (n NodeUtils) IsNotMountPoint(file string) (bool, error)

+ func (n NodeUtils) IsPathExists(path string) bool

+ func (n NodeUtils) RemoveFileOrDirectory(path string) error

type NodeUtilsInterface

+ GetArrayInitiators func(ipsByArrayInitiator map[string][]string) []string

+ GetPodPath func(filepath string) string

+ IsDirectory func(filePath string) bool

+ IsNotMountPoint func(file string) (bool, error)

+ IsPathExists func(filePath string) bool

+ RemoveFileOrDirectory func(filePath string) error

Sep 24, 2019

Changes in this version

+ const FCPath

+ const FCPortPath

+ var ErrorWhileTryingToReadFC = "Error while tring to get FC port from string: %v."

+ var IscsiFullPath = "/host/etc/iscsi/initiatorname.iscsi"

type NodeUtils

+ Executer executer.ExecuterInterface

+ func (n NodeUtils) Exists(path string) bool

+ func (n NodeUtils) ParseFCPorts() ([]string, error)

type NodeUtilsInterface

+ Exists func(filePath string) bool

+ ParseFCPorts func() ([]string, error)

Aug 14, 2019

Changes in this version

+ const DefualtConfigFile

+ const EnvNameDriverConfFile

+ const PrefixChrootOfHostRoot

+ var ErrorUnsupportedConnectivityType = "Unsupported connectivity type : {%v}"

+ var ErrorWhileTryingToReadIQN = "Error while trying to get iqn from string: %v."

+ func GetVersionJSON(configFilePath string) (string, error)

+ type ConfigFile struct

+ Controller struct{ ... }

+ Identity struct{ ... }

+ func ReadConfigFile(configFilePath string) (ConfigFile, error)

+ type ConfigYmlEmptyAttribute struct

+ Attr string

+ func (e *ConfigYmlEmptyAttribute) Error() string

+ type Driver struct

+ func NewDriver(endpoint string, configFilePath string, hostname string) (*Driver, error)

+ func (d *Driver) GetPluginCapabilities(ctx context.Context, req *csi.GetPluginCapabilitiesRequest) (*csi.GetPluginCapabilitiesResponse, error)

+ func (d *Driver) GetPluginInfo(ctx context.Context, req *csi.GetPluginInfoRequest) (*csi.GetPluginInfoResponse, error)

+ func (d *Driver) Probe(ctx context.Context, req *csi.ProbeRequest) (*csi.ProbeResponse, error)

+ func (d *Driver) Run() error

+ func (d *Driver) Stop()

+ type NodeService struct

+ ConfigYaml ConfigFile

+ Hostname string

+ NodeUtils NodeUtilsInterface

+ OsDeviceConnectivityMapping map[string]device_connectivity.OsDeviceConnectivityInterface

+ VolumeIdLocksMap SyncLockInterface

+ func NewNodeService(configYaml ConfigFile, hostname string, nodeUtils NodeUtilsInterface, ...) NodeService

+ func (d *NodeService) NodeExpandVolume(ctx context.Context, req *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)

+ func (d *NodeService) NodeGetCapabilities(ctx context.Context, req *csi.NodeGetCapabilitiesRequest) (*csi.NodeGetCapabilitiesResponse, error)

+ func (d *NodeService) NodeGetInfo(ctx context.Context, req *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error)

+ func (d *NodeService) NodeGetVolumeStats(ctx context.Context, req *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)

+ func (d *NodeService) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)

+ func (d *NodeService) NodeStageVolume(ctx context.Context, req *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)

+ func (d *NodeService) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)

+ func (d *NodeService) NodeUnstageVolume(ctx context.Context, req *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)

+ type NodeUtils struct

+ func NewNodeUtils() *NodeUtils

+ func (n NodeUtils) ClearStageInfoFile(filePath string) error

+ func (n NodeUtils) GetInfoFromPublishContext(publishContext map[string]string, configYaml ConfigFile) (string, int, string, error)

+ func (n NodeUtils) GetSysDevicesFromMpath(device string) (string, error)

+ func (n NodeUtils) ParseIscsiInitiators(path string) (string, error)

+ func (n NodeUtils) ReadFromStagingInfoFile(filePath string) (map[string]string, error)

+ func (n NodeUtils) StageInfoFileIsExist(filePath string) bool

+ func (n NodeUtils) WriteStageInfoToFile(filePath string, info map[string]string) error

+ type NodeUtilsInterface interface

+ ClearStageInfoFile func(filePath string) error

+ GetInfoFromPublishContext func(publishContext map[string]string, configYaml ConfigFile) (string, int, string, error)

+ GetSysDevicesFromMpath func(baseDevice string) (string, error)

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

+ ReadFromStagingInfoFile func(filePath string) (map[string]string, error)

+ StageInfoFileIsExist func(filePath string) bool

+ WriteStageInfoToFile func(path string, info map[string]string) error

+ type RequestValidationError struct

+ Msg string

+ func (e *RequestValidationError) Error() string

+ type SyncLock struct

+ SyncMap *sync.Map

+ func (s SyncLock) AddVolumeLock(id string, msg string) error

+ func (s SyncLock) GetSyncMap() *sync.Map

+ func (s SyncLock) RemoveVolumeLock(id string, msg string)

+ type SyncLockInterface interface

+ AddVolumeLock func(id string, msg string) error

+ GetSyncMap func() *sync.Map

+ RemoveVolumeLock func(id string, msg string)

+ func NewSyncLock() SyncLockInterface

+ type VersionInfo struct

+ BuildDate string

+ Compiler string

+ DriverVersion string

+ GitCommit string

+ GoVersion string

+ Platform string

+ func GetVersion(configFilePath string) (VersionInfo, error)

+ type VolumeAlreadyProcessingError struct

+ func (e *VolumeAlreadyProcessingError) Error() string