driver

package

Go to main page

Versions in this module

v1

v1.4.0

Jan 6, 2021

v1.3.0

Aug 28, 2020

Changes in this version

type Driver

+ func (driver *Driver) ControllerGetVolume(ctx context.Context, request *csi.ControllerGetVolumeRequest) (*csi.ControllerGetVolumeResponse, error)

v1.2.0

Jun 12, 2020

Changes in this version

type Driver

+ func (driver *Driver) ScrubEphemeralPods(podsDirPath string) error

+ func (driver *Driver) ScrubberTask(t time.Time, podsDirPath string) error

+ func (driver *Driver) StartScrubber(nodeService bool) chan bool

+ func (driver *Driver) StopScrubber(nodeService bool, chanDone chan<- bool) error

+ type Ephemeral struct

+ PodData *POD

+ SecretRef *Secret

+ VolumeHandle string

+ VolumeID string

+ type VolumeHandleTargetPath struct

+ TargetPath string

+ VolumeHandle string

v1.1.0

Mar 13, 2020

Changes in this version

type Driver

+ func (driver *Driver) GenerateStorageProviderCacheKey(credentials *storageprovider.Credentials) string

v1.0.0

Dec 11, 2019

Changes in this version

+ const Pending

+ func NewControllerServiceCapability(cap csi.ControllerServiceCapability_RPC_Type) *csi.ControllerServiceCapability

+ func NewNodeServiceCapability(cap csi.NodeServiceCapability_RPC_Type) *csi.NodeServiceCapability

+ func NewPluginCapabilityVolumeExpansion(cap csi.PluginCapability_VolumeExpansion_Type) *csi.PluginCapability_VolumeExpansion

+ func NewVolumeCapabilityAccessMode(mode csi.VolumeCapability_AccessMode_Mode) *csi.VolumeCapability_AccessMode

+ func ParseEndpoint(ep string) (string, string, error)

+ type Driver struct

+ DBService dbservice.DBService

+ func NewDriver(name, version, endpoint, flavorName string, nodeService bool, dbServer string, ...) (*Driver, error)

+ func (driver *Driver) AddControllerServiceCapabilities(capabilities []csi.ControllerServiceCapability_RPC_Type)

+ func (driver *Driver) AddNodeServiceCapabilities(capabilities []csi.NodeServiceCapability_RPC_Type)

+ func (driver *Driver) AddPluginCapabilityVolumeExpansion(expansionTypes []csi.PluginCapability_VolumeExpansion_Type)

+ func (driver *Driver) AddRequest(key string, value interface{})

+ func (driver *Driver) AddStorageProvider(credentials *storageprovider.Credentials) error

+ func (driver *Driver) AddToDB(key string, value interface{}) error

+ func (driver *Driver) AddVolumeCapabilityAccessModes(accessModes []csi.VolumeCapability_AccessMode_Mode)

+ func (driver *Driver) AreVolumeCapabilitiesSupported(volCapabilities []*csi.VolumeCapability) (bool, error)

+ func (driver *Driver) ClearRequest(key string)

+ func (driver *Driver) ControllerExpandVolume(ctx context.Context, request *csi.ControllerExpandVolumeRequest) (*csi.ControllerExpandVolumeResponse, error)

+ func (driver *Driver) ControllerGetCapabilities(ctx context.Context, request *csi.ControllerGetCapabilitiesRequest) (*csi.ControllerGetCapabilitiesResponse, error)

+ func (driver *Driver) ControllerPublishVolume(ctx context.Context, request *csi.ControllerPublishVolumeRequest) (*csi.ControllerPublishVolumeResponse, error)

+ func (driver *Driver) ControllerUnpublishVolume(ctx context.Context, request *csi.ControllerUnpublishVolumeRequest) (*csi.ControllerUnpublishVolumeResponse, error)

+ func (driver *Driver) CreateSnapshot(ctx context.Context, request *csi.CreateSnapshotRequest) (*csi.CreateSnapshotResponse, error)

+ func (driver *Driver) CreateVolume(ctx context.Context, request *csi.CreateVolumeRequest) (*csi.CreateVolumeResponse, error)

+ func (driver *Driver) DeleteSnapshot(ctx context.Context, request *csi.DeleteSnapshotRequest) (*csi.DeleteSnapshotResponse, error)

+ func (driver *Driver) DeleteVolume(ctx context.Context, request *csi.DeleteVolumeRequest) (*csi.DeleteVolumeResponse, error)

+ func (driver *Driver) DeleteVolumeByName(name string, secrets map[string]string, force bool) error

+ func (driver *Driver) GetCapacity(ctx context.Context, request *csi.GetCapacityRequest) (*csi.GetCapacityResponse, error)

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

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

+ func (driver *Driver) GetRequest(key string) interface{}

+ func (driver *Driver) GetStorageProvider(secrets map[string]string) (storageprovider.StorageProvider, error)

+ func (driver *Driver) GetVolumeByID(id string, secrets map[string]string) (*model.Volume, error)

+ func (driver *Driver) GetVolumeByName(name string, secrets map[string]string) (*model.Volume, error)

+ func (driver *Driver) HandleDuplicateRequest(key string) error

+ func (driver *Driver) IsNFSResourceRequest(parameters map[string]string) bool

+ func (driver *Driver) IsReadOnlyAccessMode(capabilities []*csi.VolumeCapability) bool

+ func (driver *Driver) IsSupportedControllerCapability(capType csi.ControllerServiceCapability_RPC_Type) bool

+ func (driver *Driver) IsSupportedMultiNodeAccessMode(capabilities []*csi.VolumeCapability) bool

+ func (driver *Driver) IsSupportedNodeCapability(capType csi.NodeServiceCapability_RPC_Type) bool

+ func (driver *Driver) IsSupportedPluginVolumeExpansionCapability(capType csi.PluginCapability_VolumeExpansion_Type) bool

+ func (driver *Driver) IsValidVolumeCapability(volCap *csi.VolumeCapability) (bool, error)

+ func (driver *Driver) ListSnapshots(ctx context.Context, request *csi.ListSnapshotsRequest) (*csi.ListSnapshotsResponse, error)

+ func (driver *Driver) ListVolumes(ctx context.Context, request *csi.ListVolumesRequest) (*csi.ListVolumesResponse, error)

+ func (driver *Driver) NodeExpandVolume(ctx context.Context, request *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error)

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

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

+ func (driver *Driver) NodeGetVolumeStats(ctx context.Context, in *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error)

+ func (driver *Driver) NodePublishVolume(ctx context.Context, request *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error)

+ func (driver *Driver) NodeStageVolume(ctx context.Context, request *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error)

+ func (driver *Driver) NodeUnpublishVolume(ctx context.Context, request *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error)

+ func (driver *Driver) NodeUnstageVolume(ctx context.Context, request *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error)

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

+ func (driver *Driver) RemoveFromDB(key string) error

+ func (driver *Driver) RemoveFromDBIfPending(key string) error

+ func (driver *Driver) RemoveStorageProvider(ipAddress string)

+ func (driver *Driver) Start(nodeService bool) error

+ func (driver *Driver) Stop(nodeService bool) error

+ func (driver *Driver) UpdateDB(key string, value interface{}) error

+ func (driver *Driver) ValidateAndGetVolumeAccessType(volCaps []*csi.VolumeCapability) (model.VolumeAccessType, error)

+ func (driver *Driver) ValidateVolumeCapabilities(ctx context.Context, request *csi.ValidateVolumeCapabilitiesRequest) (*csi.ValidateVolumeCapabilitiesResponse, error)

+ type Mount struct

+ FilesystemOptions *model.FilesystemOpts

+ MountOptions []string

+ MountPoint string

+ type NonBlockingGRPCServer interface

+ GracefulStop func()

+ Start func(endpoint string, ids csi.IdentityServer, cs csi.ControllerServer, ...)

+ Stop func()

+ func NewNonBlockingGRPCServer() NonBlockingGRPCServer

+ type POD struct

+ Name string

+ Namespace string

+ UID string

+ type Secret struct

+ Name string

+ Namespace string

+ type StagingDevice struct

+ Device *model.Device

+ MountInfo *Mount

+ POD *POD

+ Secret *Secret

+ VolumeAccessMode model.VolumeAccessType

+ VolumeID string

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