driver

package
v1.2.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 3, 2024 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	MaxNameLength int = 128
)

Variables

This section is empty.

Functions

func ConvertVolumeCapabilityFromv0Tov1 

func ConvertVolumeCapabilityFromv0Tov1(capability *csi_v0.VolumeCapability) (*csi.VolumeCapability, error)

func GetShareNameFromSnapshotId 

func GetShareNameFromSnapshotId(snapshotId string) (string, error)

func GetSnapshotIDFromSnapshotName 

func GetSnapshotIDFromSnapshotName(hsSnapName, sourceVolumeID string) string

generate snapshot ID to be stored by the CO <created snapshot name>|<sharepath or filepath>

func GetSnapshotNameFromSnapshotId 

func GetSnapshotNameFromSnapshotId(snapshotId string) (string, error)

func GetVolumeNameFromPath 

func GetVolumeNameFromPath(path string) string

func IsValueInList 

func IsValueInList(value string, list []string) bool

Types

type CSIDriver 

type CSIDriver struct {
	NodeID string
	// contains filtered or unexported fields
}

func NewCSIDriver 

func NewCSIDriver(endpoint, username, password, tlsVerifyStr string) *CSIDriver

func (*CSIDriver) Address 

func (c *CSIDriver) Address() string

func (*CSIDriver) Close 

func (c *CSIDriver) Close()

func (*CSIDriver) ControllerExpandVolume 

func (d *CSIDriver) ControllerExpandVolume(
	ctx context.Context,
	req *csi.ControllerExpandVolumeRequest) (
	*csi.ControllerExpandVolumeResponse, error)

func (*CSIDriver) ControllerGetCapabilities 

func (d *CSIDriver) ControllerGetCapabilities(
	ctx context.Context,
	req *csi.ControllerGetCapabilitiesRequest) (
	*csi.ControllerGetCapabilitiesResponse, error)

func (*CSIDriver) ControllerPublishVolume 

func (d *CSIDriver) ControllerPublishVolume(
	ctx context.Context,
	req *csi.ControllerPublishVolumeRequest) (
	*csi.ControllerPublishVolumeResponse, error)

func (*CSIDriver) ControllerUnpublishVolume 

func (d *CSIDriver) ControllerUnpublishVolume(
	ctx context.Context,
	req *csi.ControllerUnpublishVolumeRequest) (
	*csi.ControllerUnpublishVolumeResponse, error)

func (*CSIDriver) CreateSnapshot 

func (d *CSIDriver) CreateSnapshot(ctx context.Context,
	req *csi.CreateSnapshotRequest) (*csi.CreateSnapshotResponse, error)

func (*CSIDriver) CreateVolume 

func (d *CSIDriver) CreateVolume(
	ctx context.Context,
	req *csi.CreateVolumeRequest) (
	*csi.CreateVolumeResponse, error)

func (*CSIDriver) DeleteSnapshot 

func (d *CSIDriver) DeleteSnapshot(ctx context.Context,
	req *csi.DeleteSnapshotRequest) (*csi.DeleteSnapshotResponse, error)

func (*CSIDriver) DeleteVolume 

func (d *CSIDriver) DeleteVolume(
	ctx context.Context,
	req *csi.DeleteVolumeRequest) (
	*csi.DeleteVolumeResponse, error)

func (*CSIDriver) EnsureBackingShareMounted 

func (d *CSIDriver) EnsureBackingShareMounted(backingShareName string) error

func (*CSIDriver) GetCapacity 

func (d *CSIDriver) GetCapacity(
	ctx context.Context,
	req *csi.GetCapacityRequest) (
	*csi.GetCapacityResponse, error)

func (*CSIDriver) GetHammerspaceClient 

func (c *CSIDriver) GetHammerspaceClient() *client.HammerspaceClient

func (*CSIDriver) GetPluginCapabilities 

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

func (*CSIDriver) GetPluginInfo 

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

func (*CSIDriver) IsRunning 

func (c *CSIDriver) IsRunning() bool

func (*CSIDriver) ListSnapshots 

func (d *CSIDriver) ListSnapshots(ctx context.Context,
	req *csi.ListSnapshotsRequest) (*csi.ListSnapshotsResponse, error)

func (*CSIDriver) ListVolumes 

func (d *CSIDriver) ListVolumes(
	ctx context.Context,
	req *csi.ListVolumesRequest) (
	*csi.ListVolumesResponse, error)

func (*CSIDriver) MountShareAtBestDataportal 

func (d *CSIDriver) MountShareAtBestDataportal(shareExportPath, targetPath string, mountFlags []string) error

func (*CSIDriver) NodeExpandVolume 

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

func (*CSIDriver) NodeGetCapabilities 

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

func (*CSIDriver) NodeGetInfo 

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

func (*CSIDriver) NodeGetVolumeStats 

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

func (*CSIDriver) NodePublishVolume 

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

func (*CSIDriver) NodeStageVolume 

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

func (*CSIDriver) NodeUnpublishVolume 

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

func (*CSIDriver) NodeUnstageVolume 

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

func (*CSIDriver) Probe 

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

func (*CSIDriver) Start 

func (c *CSIDriver) Start(l net.Listener) error

func (*CSIDriver) Stop 

func (c *CSIDriver) Stop()

func (*CSIDriver) UnmountBackingShareIfUnused 

func (d *CSIDriver) UnmountBackingShareIfUnused(backingShareName string) (bool, error)

func (*CSIDriver) ValidateVolumeCapabilities 

func (d *CSIDriver) ValidateVolumeCapabilities(
	ctx context.Context,
	req *csi.ValidateVolumeCapabilitiesRequest) (
	*csi.ValidateVolumeCapabilitiesResponse, error)

type CSIDriver_v0Support 

type CSIDriver_v0Support struct {
	// contains filtered or unexported fields
}

func NewCSIDriver_v0Support 

func NewCSIDriver_v0Support(driver *CSIDriver) *CSIDriver_v0Support

func (*CSIDriver_v0Support) Address 

func (c *CSIDriver_v0Support) Address() string

func (*CSIDriver_v0Support) Close 

func (c *CSIDriver_v0Support) Close()

func (*CSIDriver_v0Support) ControllerGetCapabilities 

func (d *CSIDriver_v0Support) ControllerGetCapabilities(
	ctx context.Context,
	req *csi_v0.ControllerGetCapabilitiesRequest) (
	*csi_v0.ControllerGetCapabilitiesResponse, error)

func (*CSIDriver_v0Support) ControllerPublishVolume 

func (d *CSIDriver_v0Support) ControllerPublishVolume(
	ctx context.Context,
	req *csi_v0.ControllerPublishVolumeRequest) (
	*csi_v0.ControllerPublishVolumeResponse, error)

func (*CSIDriver_v0Support) ControllerUnpublishVolume 

func (d *CSIDriver_v0Support) ControllerUnpublishVolume(
	ctx context.Context,
	req *csi_v0.ControllerUnpublishVolumeRequest) (
	*csi_v0.ControllerUnpublishVolumeResponse, error)

func (*CSIDriver_v0Support) CreateSnapshot 

func (d *CSIDriver_v0Support) CreateSnapshot(ctx context.Context,
	req *csi_v0.CreateSnapshotRequest) (*csi_v0.CreateSnapshotResponse, error)

func (*CSIDriver_v0Support) CreateVolume 

func (d *CSIDriver_v0Support) CreateVolume(
	ctx context.Context,
	req *csi_v0.CreateVolumeRequest) (
	*csi_v0.CreateVolumeResponse, error)

func (*CSIDriver_v0Support) DeleteSnapshot 

func (d *CSIDriver_v0Support) DeleteSnapshot(ctx context.Context,
	req *csi_v0.DeleteSnapshotRequest) (*csi_v0.DeleteSnapshotResponse, error)

func (*CSIDriver_v0Support) DeleteVolume 

func (d *CSIDriver_v0Support) DeleteVolume(
	ctx context.Context,
	req *csi_v0.DeleteVolumeRequest) (
	*csi_v0.DeleteVolumeResponse, error)

func (*CSIDriver_v0Support) GetCapacity 

func (d *CSIDriver_v0Support) GetCapacity(
	ctx context.Context,
	req *csi_v0.GetCapacityRequest) (
	*csi_v0.GetCapacityResponse, error)

func (*CSIDriver_v0Support) GetPluginCapabilities 

func (d *CSIDriver_v0Support) GetPluginCapabilities(
	ctx context.Context,
	req *csi_v0.GetPluginCapabilitiesRequest) (
	*csi_v0.GetPluginCapabilitiesResponse, error)

func (*CSIDriver_v0Support) GetPluginInfo 

func (d *CSIDriver_v0Support) GetPluginInfo(
	ctx context.Context,
	req *csi_v0.GetPluginInfoRequest) (
	*csi_v0.GetPluginInfoResponse, error)

func (*CSIDriver_v0Support) IsRunning 

func (c *CSIDriver_v0Support) IsRunning() bool

func (*CSIDriver_v0Support) ListSnapshots 

func (d *CSIDriver_v0Support) ListSnapshots(ctx context.Context,
	req *csi_v0.ListSnapshotsRequest) (*csi_v0.ListSnapshotsResponse, error)

func (*CSIDriver_v0Support) ListVolumes 

func (d *CSIDriver_v0Support) ListVolumes(
	ctx context.Context,
	req *csi_v0.ListVolumesRequest) (
	*csi_v0.ListVolumesResponse, error)

func (*CSIDriver_v0Support) NodeGetCapabilities 

func (d *CSIDriver_v0Support) NodeGetCapabilities(
	ctx context.Context,
	req *csi_v0.NodeGetCapabilitiesRequest) (
	*csi_v0.NodeGetCapabilitiesResponse, error)

func (*CSIDriver_v0Support) NodeGetId 

func (d *CSIDriver_v0Support) NodeGetId(ctx context.Context,
	req *csi_v0.NodeGetIdRequest) (*csi_v0.NodeGetIdResponse, error)

func (*CSIDriver_v0Support) NodeGetInfo 

func (d *CSIDriver_v0Support) NodeGetInfo(ctx context.Context,
	req *csi_v0.NodeGetInfoRequest) (*csi_v0.NodeGetInfoResponse, error)

func (*CSIDriver_v0Support) NodePublishVolume 

func (d *CSIDriver_v0Support) NodePublishVolume(
	ctx context.Context,
	req *csi_v0.NodePublishVolumeRequest) (
	*csi_v0.NodePublishVolumeResponse, error)

func (*CSIDriver_v0Support) NodeStageVolume 

func (d *CSIDriver_v0Support) NodeStageVolume(
	ctx context.Context,
	req *csi_v0.NodeStageVolumeRequest) (
	*csi_v0.NodeStageVolumeResponse, error)

func (*CSIDriver_v0Support) NodeUnpublishVolume 

func (d *CSIDriver_v0Support) NodeUnpublishVolume(
	ctx context.Context,
	req *csi_v0.NodeUnpublishVolumeRequest) (
	*csi_v0.NodeUnpublishVolumeResponse, error)

func (*CSIDriver_v0Support) NodeUnstageVolume 

func (d *CSIDriver_v0Support) NodeUnstageVolume(
	ctx context.Context,
	req *csi_v0.NodeUnstageVolumeRequest) (
	*csi_v0.NodeUnstageVolumeResponse, error)

func (*CSIDriver_v0Support) Probe 

func (d *CSIDriver_v0Support) Probe(
	ctx context.Context,
	req *csi_v0.ProbeRequest) (
	*csi_v0.ProbeResponse, error)

func (*CSIDriver_v0Support) Start 

func (c *CSIDriver_v0Support) Start(l net.Listener) error

func (*CSIDriver_v0Support) Stop 

func (c *CSIDriver_v0Support) Stop()

func (*CSIDriver_v0Support) ValidateVolumeCapabilities 

func (d *CSIDriver_v0Support) ValidateVolumeCapabilities(
	ctx context.Context,
	req *csi_v0.ValidateVolumeCapabilitiesRequest) (
	*csi_v0.ValidateVolumeCapabilitiesResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.