driver

Oct 13, 2023

Changes in this version

+ const DefaultISCSITimeout

type ISCSIVolumeContext

+ ISCSITimeout int

Apr 11, 2023

Changes in this version

type ControllerServer

+ func (s *ControllerServer) ControllerGetVolume(ctx context.Context, req *csi.ControllerGetVolumeRequest) (*csi.ControllerGetVolumeResponse, error)

Oct 18, 2022

Changes in this version

+ const DefaultFindMntTimeout

type NodeServer

+ func (s *NodeServer) FlushBufs(device string) (err error)

Jan 19, 2022

Changes in this version

+ type ISCSIVolumeContext struct

+ Address string

+ ChapSecret string

+ ChapUser string

+ DynamicTargetLunAllocation bool

+ HostGroup string

+ ISCSITarget string

+ ISCSITargetPrefix string

+ NumOfLunsPerTarget int

+ Port string

+ TargetGroup string

+ UseChapAuth bool

Sep 27, 2021

Changes in this version

+ const DefaultMountPointPermissions

type NodeServer

+ func (s *NodeServer) GetMountPointPermissions(volumeContext map[string]string) (os.FileMode, error)

Aug 16, 2021

Changes in this version

+ const DefaultSparseVolume

May 25, 2021

Changes in this version

type NodeServer

+ func (s *NodeServer) RescanDevice(devName string) error

Mar 25, 2021

Changes in this version

+ const DefaultDynamicTargetLunAllocation

+ const DefaultFsType

+ const DefaultISCSITargetPrefix

+ const DefaultNumOfLunsPerTarget

+ const DefaultUseChapAuth

+ type CreateTargetTgParams struct

+ Address string

+ ISCSITargetPrefix string

+ NumOfLunsPerTarget int

+ Port string

+ Target string

+ TargetGroup string

type NodeServer

+ func (s *NodeServer) CreateNewTargetTg(params CreateTargetTgParams, nsProvider ns.ProviderInterface) (target, targetGroup string, err error)

+ func (s *NodeServer) DeviceFromTargetPath(volumePath string) (deviceName string, err error)

+ func (s *NodeServer) ResolveTargetGroup(params CreateTargetTgParams, nsProvider ns.ProviderInterface) (target, targetGroup string, err error)

+ func (s *NodeServer) SetChapAuth(name, chapUser, chapSecret string, nsProvider ns.ProviderInterface) (err error)

Feb 23, 2021

Changes in this version

type NodeServer

+ func (s *NodeServer) ConstructDevByPath(portal, iSCSITarget string, lunNumber int) (devByPath string)

+ func (s *NodeServer) IsBlockDevice(fullPath string) (bool, error)

+ func (s *NodeServer) MountFromTargetPath(volumePath string) (deviceName string, err error)

+ func (s *NodeServer) ParseVolumeContext(volumeContext map[string]string, nsProvider ns.ProviderInterface, ...) (hostGroup, targetGroup, port, dataIP, iSCSITarget string, err error)

Sep 22, 2020

Changes in this version

+ const HostGroupPrefix

+ const PathToInitiatorName

type NodeServer

+ func (s *NodeServer) CreateUpdateHostGroup(nsProvider ns.ProviderInterface) (name string, err error)

+ func (s *NodeServer) GetNodeIQN() (initiatorName string, err error)

Jul 21, 2020

Changes in this version

type ControllerServer

+ func (s *ControllerServer) CreateSnapshotOnNS(nsProvider ns.ProviderInterface, volumePath, snapName string) (snapshot ns.Snapshot, err error)

+ type CreateMappingParams struct

+ Address string

+ HostGroup string

+ Port string

+ Target string

+ TargetGroup string

+ VolumePath string

type NodeServer

+ func (s *NodeServer) CreateISCSIMapping(params CreateMappingParams, nsProvider ns.ProviderInterface) error

Jun 8, 2020

Changes in this version

+ const DefaultHostGroup

+ const DefaultISCSIPort

+ const TopologyKeyZone

+ var Commit string

+ var DateTime string

+ var Name = "nexentastor-csi-driver-block.nexenta.com"

+ var Roles = []Role

+ var Version string

+ type Args struct

+ Config *config.Config

+ Endpoint string

+ Log *logrus.Entry

+ NodeID string

+ Role Role

+ type ControllerServer struct

+ func NewControllerServer(driver *Driver) (*ControllerServer, error)

+ func (s *ControllerServer) ControllerExpandVolume(ctx context.Context, req *csi.ControllerExpandVolumeRequest) (*csi.ControllerExpandVolumeResponse, error)

+ func (s *ControllerServer) ControllerGetCapabilities(ctx context.Context, req *csi.ControllerGetCapabilitiesRequest) (*csi.ControllerGetCapabilitiesResponse, error)

+ func (s *ControllerServer) ControllerPublishVolume(ctx context.Context, req *csi.ControllerPublishVolumeRequest) (*csi.ControllerPublishVolumeResponse, error)

+ func (s *ControllerServer) ControllerUnpublishVolume(ctx context.Context, req *csi.ControllerUnpublishVolumeRequest) (*csi.ControllerUnpublishVolumeResponse, error)

+ func (s *ControllerServer) CreateSnapshot(ctx context.Context, req *csi.CreateSnapshotRequest) (*csi.CreateSnapshotResponse, error)

+ func (s *ControllerServer) CreateVolume(ctx context.Context, req *csi.CreateVolumeRequest) (res *csi.CreateVolumeResponse, err error)

+ func (s *ControllerServer) DeleteSnapshot(ctx context.Context, req *csi.DeleteSnapshotRequest) (*csi.DeleteSnapshotResponse, error)

+ func (s *ControllerServer) DeleteVolume(ctx context.Context, req *csi.DeleteVolumeRequest) (*csi.DeleteVolumeResponse, error)

+ func (s *ControllerServer) GetCapacity(ctx context.Context, req *csi.GetCapacityRequest) (*csi.GetCapacityResponse, error)

+ func (s *ControllerServer) ListSnapshots(ctx context.Context, req *csi.ListSnapshotsRequest) (*csi.ListSnapshotsResponse, error)

+ func (s *ControllerServer) ListVolumes(ctx context.Context, req *csi.ListVolumesRequest) (*csi.ListVolumesResponse, error)

+ func (s *ControllerServer) ValidateVolumeCapabilities(ctx context.Context, req *csi.ValidateVolumeCapabilitiesRequest) (*csi.ValidateVolumeCapabilitiesResponse, error)

+ type Driver struct

+ func NewDriver(args Args) (*Driver, error)

+ func (d *Driver) Run() error

+ func (d *Driver) Validate() error

+ type IdentityServer struct

+ func NewIdentityServer(driver *Driver) *IdentityServer

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

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

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

+ type NodeServer struct

+ func NewNodeServer(driver *Driver) (*NodeServer, error)

+ func (s *NodeServer) GetRealDeviceName(symLink string) (string, error)

+ func (s *NodeServer) ISCSILogInRescan(target, portal string) error

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

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

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

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

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

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

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

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

+ func (s *NodeServer) RemoveDevice(devName string) error

+ type ResolveNSParams struct

+ type ResolveNSResponse struct

+ type Role string

+ const RoleAll

+ const RoleController

+ const RoleNode

+ func ParseRole(from string) (Role, error)

+ func (r Role) IsController() bool

+ func (r Role) IsNode() bool

+ func (r Role) String() string