driver

package

Go to main page

Versions in this module

v1

v1.2.4

Jan 14, 2025

v1.2.3

Jul 23, 2024

v1.2.2

Jul 18, 2024

v1.2.1

Jul 18, 2024

Changes in this version

+ func WithMaxVolumesPerNode(pmvpn int) func(*DriverOptions)

v1.2.0

Jul 1, 2024

Changes in this version

type CreateVolumeRequest

+ ReclaimPolicy string

+ func (s *CreateVolumeRequest) WithReclaimPolicy(ppolicy string) *CreateVolumeRequest

v1.1.4

Jun 20, 2024

v1.1.3

Jun 6, 2024

v1.1.2

Jun 6, 2024

v1.1.1

Jun 4, 2024

Changes in this version

+ var EncryptTypeSet = ljset.NewSet[lsdkVolumeV2.EncryptType](lsdkVolumeV2.AesXtsPlain64_128, lsdkVolumeV2.AesXtsPlain64_256)

+ var ErrDeleteVolumeHavingSnapshots = func(pvolId string) error

+ var ErrFailedToValidateVolumeSize = func(pvolumeID string, err error) error

+ var ErrVolumeSizeTooSmall = func(pvolumeID string, psize int64) error

+ func WithAlertChannel(alertChannel string) func(*DriverOptions)

+ func WithAlertChannelSize(alertChannelSize int) func(*DriverOptions)

+ func WithCacheUri(cacheUri string) func(*DriverOptions)

type CreateVolumeRequest

+ DriverOptions *DriverOptions

+ RetainPolicy string

+ func (s *CreateVolumeRequest) ToSdkCreateVolumeRequest() lsdkVolumeV2.ICreateBlockVolumeRequest

+ func (s *CreateVolumeRequest) WithDriverOptions(pdo *DriverOptions) *CreateVolumeRequest

v1.1.0

May 2, 2024

Changes in this version

+ const AesXtsPlain64_128

+ const AesXtsPlain64_256

+ const AgentNotReadyNodeTaintKey

+ const AnnotationModificationKeyVolumeType

+ const BlockSizeKey

+ const BytesPerInodeKey

+ const DefaultCSIEndpoint

+ const DefaultModifyVolumeRequestHandlerTimeout

+ const DefaultTimeoutModifyChannel

+ const DevicePathKey

+ const DriverName

+ const EncryptedKey

+ const Ext4BigAllocKey

+ const Ext4ClusterSizeKey

+ const FSTypeExt2

+ const FSTypeExt3

+ const FSTypeExt4

+ const FSTypeNtfs

+ const FSTypeXfs

+ const InodeSizeKey

+ const IsPoc

+ const MultiNodeMultiWriter

+ const NumberOfInodesKey

+ const PVCNameKey

+ const PVCNamespaceKey

+ const PVNameKey

+ const SingleNodeWriter

+ const VolumeAttributePartition

+ const VolumeTypeKey

+ const ZoneTopologyKey

+ var ErrAttachVolume = func(pvolumeID, pnodeID string) error

+ var ErrAttemptCreateResizeFs = func(perr error) error

+ var ErrCanNotCreateFile = func(ptarget string, perr error) error

+ var ErrCanNotCreateTargetDir = func(ptarget string, perr error) error

+ var ErrCanNotFormatAndMountVolume = func(psource, ptarget string, perr error) error

+ var ErrCanNotGetBlockCapacity = func(ppath string, perr error) error

+ var ErrCanNotMountAtTarget = func(psource, ptarget string, perr error) error

+ var ErrCanNotParseRequestArguments = func(pargument, pvalue string) error

+ var ErrCanNotRemoveMountTarget = func(ptarget string, perr error) error

+ var ErrCanNotResizeVolumeOnNode = func(pvolumeID, psource string, perr error) error

+ var ErrCanNotUnmountTarget = func(ptarget string, perr error) error

+ var ErrCanNotUseSpecifiedFstype = func(pkey, pfsType string) error

+ var ErrCapacityRangeNotProvided = lstt.Error(lcodes.InvalidArgument, "Capacity range is required")

+ var ErrCheckDiskIsMounted = func(ptarget string, perr error) error

+ var ErrDetachVolume = func(pvolumeID, pnodeID string) error

+ var ErrDetermineVolumeResize = func(pvolumeID, psource string, perr error) error

+ var ErrDeterminedBlockDevice = func(ppath string, perr error) error

+ var ErrDevicePathNotProvided = lstt.Error(lcodes.InvalidArgument, "Device path not provided")

+ var ErrFailedCheckTargetPathIsMountPoint = func(ptarget string, perr error) error

+ var ErrFailedToCheckPathExists = func(ppath string, perr error) error

+ var ErrFailedToCheckTargetPathExists = func(ptarget string, perr error) error

+ var ErrFailedToCheckVolumeMounted = func(perr error) error

+ var ErrFailedToDeleteSnapshot = func(psnapshotID string) error

+ var ErrFailedToDeleteVolume = func(pvolumeID string) error

+ var ErrFailedToExpandVolume = func(pvolumeID string, psize int64) error

+ var ErrFailedToFindTargetPath = func(pdevicePath string, perr error) error

+ var ErrFailedToGetDevicePath = func(pvolumeID, pnodeID string) error

+ var ErrFailedToGetFsInfo = func(ppath string, perr error) error

+ var ErrFailedToGetVolume = func(pvolumeID string) error

+ var ErrFailedToListSnapshot = func(pvolumeID string) error

+ var ErrFailedToListVolumeByName = func(pvolName string) error

+ var ErrFailedToModifyVolume = func(pvolumeID string) error

+ var ErrInvalidFormatParameter = func(pkey string, perr error) error

+ var ErrInvalidFstype = func(pfstype string) error

+ var ErrModifyMutableParam = lstt.Error(lcodes.InvalidArgument, "Invalid mutable parameters")

+ var ErrMountIsNil = lstt.Error(lcodes.InvalidArgument, "Mount is nil within volume capability")

+ var ErrNodeIdNotProvided = lstt.Error(lcodes.InvalidArgument, "Node ID not provided")

+ var ErrNotImplemented = func(pfeature string) error

+ var ErrOperationAlreadyExists = func(pvolumeID string) error

+ var ErrPathNotExists = func(ppath string) error

+ var ErrRequestExceedLimit = func(pvolSizeBytes, pmaxVolSize int64) error

+ var ErrSnapshotIsDeleting = func(psnapshotID string) error

+ var ErrSnapshotIsNil = lstt.Error(lcodes.InvalidArgument, ...)

+ var ErrSnapshotNameNotProvided = lstt.Error(lcodes.InvalidArgument, "Snapshot name not provided")

+ var ErrSnapshotSourceVolumeNotProvided = lstt.Error(lcodes.InvalidArgument, "Snapshot volume source ID not provided")

+ var ErrStagingTargetNotProvided = lstt.Error(lcodes.InvalidArgument, "Staging target not provided")

+ var ErrStagingTargetPathNotProvided = lstt.Error(lcodes.InvalidArgument, "Staging target not provided")

+ var ErrTargetPathNotProvided = lstt.Error(lcodes.InvalidArgument, "Target path not provided")

+ var ErrUnknownStatsOnPath = func(ppath string, perr error) error

+ var ErrVolumeAttributesInvalid = lstt.Error(lcodes.InvalidArgument, "Volume attributes are invalid")

+ var ErrVolumeCapabilitiesNotProvided = lstt.Error(lcodes.InvalidArgument, "Volume capabilities not provided")

+ var ErrVolumeCapabilitiesNotSupported = lstt.Error(lcodes.InvalidArgument, "Volume capabilities not supported")

+ var ErrVolumeCapabilityNotProvided = lstt.Error(lcodes.InvalidArgument, "Volume capability not provided")

+ var ErrVolumeCapabilityNotSupported = lstt.Error(lcodes.InvalidArgument, "Volume capability not supported")

+ var ErrVolumeContentSourceNotSupported = lstt.Error(lcodes.InvalidArgument, "Unsupported volumeContentSource type")

+ var ErrVolumeIDNotProvided = lstt.Error(lcodes.InvalidArgument, "Volume ID not provided")

+ var ErrVolumeIsCreating = func(pvolumeID string) error

+ var ErrVolumeNameNotProvided = lstt.Error(lcodes.InvalidArgument, "Volume name not provided")

+ var ErrVolumeNotFound = func(pvolumeID string) error

+ var ErrVolumePathNotProvided = lstt.Error(lcodes.InvalidArgument, "Volume path not provided")

+ var FileSystemConfigs = map[string]fileSystemConfig

+ var NewCloudFunc = lscloud.NewCloud

+ var NewMetadataFunc = lscloud.NewMetadataService

+ var ValidFSTypes = map[string]struct

+ func GetVersionJSON() (string, error)

+ func InitOtelTracing() (*otlptrace.Exporter, error)

+ func ValidateDriverOptions(options *DriverOptions) error

+ func WithClientID(clientID string) func(*DriverOptions)

+ func WithClientSecret(clientSecret string) func(*DriverOptions)

+ func WithClusterID(pclusterID string) func(*DriverOptions)

+ func WithEndpoint(endpoint string) func(*DriverOptions)

+ func WithIdentityURL(identityURL string) func(*DriverOptions)

+ func WithMode(mode Mode) func(*DriverOptions)

+ func WithModifyVolumeRequestHandlerTimeout(timeout time.Duration) func(*DriverOptions)

+ func WithOtelTracing(enableOtelTracing bool) func(*DriverOptions)

+ func WithTagKeyLength(ptkl int) func(*DriverOptions)

+ func WithTagValueLength(ptvl int) func(*DriverOptions)

+ func WithUserAgentExtra(userAgentExtra string) func(*DriverOptions)

+ func WithVServerURL(vServerURL string) func(*DriverOptions)

+ type CreateVolumeRequest struct

+ BlockSize string

+ BytesPerInode string

+ ClusterID string

+ CreateFrom lsdkVolV2.CreateOptsCreateFrom

+ EncryptedAlgorithm string

+ Ext4BigAlloc bool

+ Ext4ClusterSize string

+ InodeSize string

+ IsMultiAttach bool

+ IsPoc bool

+ NumberOfInodes string

+ PvNameTag string

+ PvcNameTag string

+ PvcNamespaceTag string

+ SnapshotID string

+ VolumeName string

+ VolumeSize uint64

+ VolumeTypeID string

+ func NewCreateVolumeRequest() *CreateVolumeRequest

+ func (s *CreateVolumeRequest) ToResponseContext(pvolCap []*lcsi.VolumeCapability) (map[string]string, error)

+ func (s *CreateVolumeRequest) ToSdkCreateVolumeOpts(pdo *DriverOptions) *lsdkVolV2.CreateOpts

+ func (s *CreateVolumeRequest) WithBlockSize(pblockSize string) *CreateVolumeRequest

+ func (s *CreateVolumeRequest) WithBytesPerInode(pbytesPerInode string) *CreateVolumeRequest

+ func (s *CreateVolumeRequest) WithClusterID(pclusterID string) *CreateVolumeRequest

+ func (s *CreateVolumeRequest) WithEncrypted(pencrypted string) *CreateVolumeRequest

+ func (s *CreateVolumeRequest) WithExt4BigAlloc(pext4BigAlloc bool) *CreateVolumeRequest

+ func (s *CreateVolumeRequest) WithExt4ClusterSize(pext4ClusterSize string) *CreateVolumeRequest

+ func (s *CreateVolumeRequest) WithInodeSize(pinodeSize string) *CreateVolumeRequest

+ func (s *CreateVolumeRequest) WithMultiAttach(pisMultiAttach bool) *CreateVolumeRequest

+ func (s *CreateVolumeRequest) WithNumberOfInodes(pnumberOfInodes string) *CreateVolumeRequest

+ func (s *CreateVolumeRequest) WithPoc(pisPoc bool) *CreateVolumeRequest

+ func (s *CreateVolumeRequest) WithPvNameTag(ppvNameTag string) *CreateVolumeRequest

+ func (s *CreateVolumeRequest) WithPvcNameTag(ppvcNameTag string) *CreateVolumeRequest

+ func (s *CreateVolumeRequest) WithPvcNamespaceTag(ppvcNamespaceTag string) *CreateVolumeRequest

+ func (s *CreateVolumeRequest) WithSnapshotID(psnapshotID string) *CreateVolumeRequest

+ func (s *CreateVolumeRequest) WithVolumeName(pvolumeName string) *CreateVolumeRequest

+ func (s *CreateVolumeRequest) WithVolumeSize(pvolumeSize uint64) *CreateVolumeRequest

+ func (s *CreateVolumeRequest) WithVolumeTypeID(pvolumeTypeID string) *CreateVolumeRequest

+ type DeviceIdentifier interface

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

+ Lstat func(name string) (os.FileInfo, error)

+ type Driver struct

+ func NewDriver(options ...func(*DriverOptions)) (*Driver, error)

+ func (s *Driver) ControllerExpandVolume(_ lctx.Context, preq *lcsi.ControllerExpandVolumeRequest) (*lcsi.ControllerExpandVolumeResponse, error)

+ func (s *Driver) ControllerGetCapabilities(ctx lctx.Context, req *lcsi.ControllerGetCapabilitiesRequest) (*lcsi.ControllerGetCapabilitiesResponse, error)

+ func (s *Driver) ControllerGetVolume(_ lctx.Context, preq *lcsi.ControllerGetVolumeRequest) (*lcsi.ControllerGetVolumeResponse, error)

+ func (s *Driver) ControllerModifyVolume(ctx lctx.Context, preq *lcsi.ControllerModifyVolumeRequest) (*lcsi.ControllerModifyVolumeResponse, error)

+ func (s *Driver) ControllerPublishVolume(pctx lctx.Context, preq *lcsi.ControllerPublishVolumeRequest) (result *lcsi.ControllerPublishVolumeResponse, err error)

+ func (s *Driver) ControllerUnpublishVolume(_ lctx.Context, preq *lcsi.ControllerUnpublishVolumeRequest) (*lcsi.ControllerUnpublishVolumeResponse, error)

+ func (s *Driver) CreateSnapshot(_ lctx.Context, preq *lcsi.CreateSnapshotRequest) (*lcsi.CreateSnapshotResponse, error)

+ func (s *Driver) CreateVolume(_ lctx.Context, preq *lcsi.CreateVolumeRequest) (*lcsi.CreateVolumeResponse, error)

+ func (s *Driver) DeleteSnapshot(_ lctx.Context, preq *lcsi.DeleteSnapshotRequest) (*lcsi.DeleteSnapshotResponse, error)

+ func (s *Driver) DeleteVolume(pctx lctx.Context, preq *lcsi.DeleteVolumeRequest) (*lcsi.DeleteVolumeResponse, error)

+ func (s *Driver) GetCSIDriverModificationCapability(_ lctx.Context, _ *lvmrpc.GetCSIDriverModificationCapabilityRequest) (*lvmrpc.GetCSIDriverModificationCapabilityResponse, error)

+ func (s *Driver) GetCapacity(ctx lctx.Context, req *lcsi.GetCapacityRequest) (*lcsi.GetCapacityResponse, error)

+ func (s *Driver) GetPluginCapabilities(_ lctx.Context, preq *lcsi.GetPluginCapabilitiesRequest) (*lcsi.GetPluginCapabilitiesResponse, error)

+ func (s *Driver) GetPluginInfo(_ lctx.Context, preq *lcsi.GetPluginInfoRequest) (*lcsi.GetPluginInfoResponse, error)

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

+ func (s *Driver) ListSnapshots(_ lctx.Context, preq *lcsi.ListSnapshotsRequest) (*lcsi.ListSnapshotsResponse, error)

+ func (s *Driver) ListVolumes(ctx lctx.Context, req *lcsi.ListVolumesRequest) (*lcsi.ListVolumesResponse, error)

+ func (s *Driver) ModifyVolumeProperties(pctx lctx.Context, preq *lvmrpc.ModifyVolumePropertiesRequest) (*lvmrpc.ModifyVolumePropertiesResponse, error)

+ func (s *Driver) NodeExpandVolume(_ lctx.Context, preq *lcsi.NodeExpandVolumeRequest) (*lcsi.NodeExpandVolumeResponse, error)

+ func (s *Driver) NodeGetCapabilities(_ lctx.Context, req *lcsi.NodeGetCapabilitiesRequest) (*lcsi.NodeGetCapabilitiesResponse, error)

+ func (s *Driver) NodeGetInfo(_ lctx.Context, _ *lcsi.NodeGetInfoRequest) (*lcsi.NodeGetInfoResponse, error)

+ func (s *Driver) NodeGetVolumeStats(_ lctx.Context, preq *lcsi.NodeGetVolumeStatsRequest) (*lcsi.NodeGetVolumeStatsResponse, error)

+ func (s *Driver) NodePublishVolume(_ lctx.Context, preq *lcsi.NodePublishVolumeRequest) (*lcsi.NodePublishVolumeResponse, error)

+ func (s *Driver) NodeStageVolume(_ lctx.Context, preq *lcsi.NodeStageVolumeRequest) (*lcsi.NodeStageVolumeResponse, error)

+ func (s *Driver) NodeUnpublishVolume(pctx lctx.Context, preq *lcsi.NodeUnpublishVolumeRequest) (*lcsi.NodeUnpublishVolumeResponse, error)

+ func (s *Driver) NodeUnstageVolume(ctx lctx.Context, preq *lcsi.NodeUnstageVolumeRequest) (*lcsi.NodeUnstageVolumeResponse, error)

+ func (s *Driver) Probe(_ lctx.Context, preq *lcsi.ProbeRequest) (*lcsi.ProbeResponse, error)

+ func (s *Driver) Run() error

+ func (s *Driver) ValidateVolumeCapabilities(pctx lctx.Context, preq *lcsi.ValidateVolumeCapabilitiesRequest) (*lcsi.ValidateVolumeCapabilitiesResponse, error)

+ type DriverOptions struct

+ func (s *DriverOptions) GetTagKeyLength() int

+ func (s *DriverOptions) GetTagValueLength() int

+ type JSONPatch struct

+ OP string

+ Path string

+ Value interface{}

+ type Mode string

+ const AllMode

+ const ControllerMode

+ const NodeMode

+ type Mounter interface

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

+ GetDeviceNameFromMount func(mountPath string) (string, int, error)

+ GetDevicePathBySerialID func(pvolId string) (string, error)

+ GetMountFs func(volumePath string) ([]byte, error)

+ IsCorruptedMnt func(err error) bool

+ MakeDir func(path string) error

+ MakeFile func(path string) error

+ NeedResize func(devicePath string, deviceMountPath string) (bool, error)

+ NewResizeFs func() (Resizefs, error)

+ PathExists func(path string) (bool, error)

+ Unpublish func(path string) error

+ Unstage func(path string) error

+ type NodeMounter struct

+ func (s *NodeMounter) GetDevicePathBySerialID(pvolId string) (string, error)

+ func (s *NodeMounter) GetMountFs(volumePath string) ([]byte, error)

+ func (s *NodeMounter) MakeDir(path string) error

+ func (s *NodeMounter) MakeFile(path string) error

+ func (s *NodeMounter) NeedResize(devicePath string, deviceMountPath string) (bool, error)

+ func (s *NodeMounter) NewResizeFs() (Resizefs, error)

+ func (s *NodeMounter) PathExists(path string) (bool, error)

+ func (s *NodeMounter) Unpublish(path string) error

+ func (s *NodeMounter) Unstage(path string) error

+ func (s NodeMounter) GetDeviceNameFromMount(mountPath string) (string, int, error)

+ func (s NodeMounter) IsCorruptedMnt(err error) bool

+ type Resizefs interface

+ Resize func(devicePath, deviceMountPath string) (bool, error)

+ type VersionInfo struct

+ BuildDate string

+ Compiler string

+ DriverVersion string

+ GitCommit string

+ GoVersion string

+ Platform string

+ func GetVersion() VersionInfo

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL