node

Jan 28, 2026

Changes in this version

type FcConnector

+ DisconnectVolumeByWWN func(ctx context.Context, wwn string) error

Sep 16, 2025

Changes in this version

+ func ExtractPort(urlString string) (string, error)

type SCSIStager

+ func (s *SCSIStager) AddTargetsInfoToMap(targetMap map[string]string, volumeApplianceID string, ...) error

May 19, 2025

Changes in this version

+ type Interface interface

Sep 20, 2023

Changes in this version

type Opts

+ KubeConfigPath string

+ MaxVolumesPerNode int64

Mar 7, 2023

Changes in this version

+ var ReachableEndPoint = common.ReachableEndPoint

+ func MarshalSyncMapToJSON(m *sync.Map) ([]byte, error)

+ type FcConnector interface

+ ConnectVolume func(ctx context.Context, info gobrick.FCVolumeInfo) (gobrick.Device, error)

+ DisconnectVolumeByDeviceName func(ctx context.Context, name string) error

+ GetInitiatorPorts func(ctx context.Context) ([]string, error)

+ type ISCSIConnector interface

+ ConnectVolume func(ctx context.Context, info gobrick.ISCSIVolumeInfo) (gobrick.Device, error)

+ DisconnectVolumeByDeviceName func(ctx context.Context, name string) error

+ GetInitiatorName func(ctx context.Context) ([]string, error)

+ type NFSPublisher struct

+ func (np *NFSPublisher) Publish(ctx context.Context, logFields log.Fields, fs fs.Interface, ...) (*csi.NodePublishVolumeResponse, error)

+ type NFSStager struct

+ func (n *NFSStager) Stage(ctx context.Context, req *csi.NodeStageVolumeRequest, logFields log.Fields, ...) (*csi.NodeStageVolumeResponse, error)

+ type NFSv4ACLs struct

+ func (n *NFSv4ACLs) SetNfsv4Acls(acls string, dir string) error

+ type NFSv4ACLsInterface interface

+ SetNfsv4Acls func(acls string, dir string) error

+ type NVMEConnector interface

+ ConnectVolume func(ctx context.Context, info gobrick.NVMeVolumeInfo, useFC bool) (gobrick.Device, error)

+ DisconnectVolumeByDeviceName func(ctx context.Context, name string) error

+ GetInitiatorName func(ctx context.Context) ([]string, error)

+ type Opts struct

+ CHAPPassword string

+ CHAPUsername string

+ EnableCHAP bool

+ FCPortsFilterFilePath string

+ KubeNodeName string

+ NodeChrootPath string

+ NodeIDFilePath string

+ NodeNamePrefix string

+ TmpDir string

+ type SCSIPublisher struct

+ func (sp *SCSIPublisher) Publish(ctx context.Context, logFields log.Fields, fs fs.Interface, ...) (*csi.NodePublishVolumeResponse, error)

+ type SCSIStager struct

+ func (s *SCSIStager) Stage(ctx context.Context, req *csi.NodeStageVolumeRequest, logFields log.Fields, ...) (*csi.NodeStageVolumeResponse, error)

+ type Service struct

+ Fs fs.Interface

+ func (s *Service) Init() error

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

+ func (s *Service) NodeGetCapabilities(context context.Context, request *csi.NodeGetCapabilitiesRequest) (*csi.NodeGetCapabilitiesResponse, error)

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

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

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

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

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

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

+ type VolumePublisher interface

+ Publish func(ctx context.Context, logFields log.Fields, fs fs.Interface, ...) (*csi.NodePublishVolumeResponse, error)

+ type VolumeStager interface

+ Stage func(ctx context.Context, req *csi.NodeStageVolumeRequest, logFields log.Fields, ...) (*csi.NodeStageVolumeResponse, error)