driver

package
v0.12.4 Latest Latest
Warning

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

 Go to latest Published: Oct 29, 2026 License: BSD-3-Clause Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetMountOptions added in v0.12.0 

func GetMountOptions(volume *csi.VolumeCapability_MountVolume, accessMode *csi.VolumeCapability_AccessMode) []string

GetMountOptions returns mount options from VolumeCapability_MountVolume.

func MakeDir 

func MakeDir(path string) error

MakeDir creates path and its missing parents.

func MountBind added in v0.12.0 

func MountBind(mounter Mounter, sourcePath string, mntOptions []string, targetPath string) error

func PathExists 

func PathExists(path string) (bool, error)

PathExists returns true if path exists.

Types

type Driver 

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

Driver object contains configuration parameters, grpc server and mounter

func NewDriver 

func NewDriver(conf *commons.Config) (*Driver, error)

NewDriver returns new driver

func (*Driver) ControllerExpandVolume added in v0.2.0 

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

ControllerExpandVolume expands a volume

func (*Driver) ControllerGetCapabilities added in v0.2.0 

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

ControllerGetCapabilities returns capabilities

func (*Driver) ControllerPublishVolume added in v0.2.0 

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

ControllerPublishVolume handles persistent volume publish event in controller service

func (*Driver) ControllerUnpublishVolume added in v0.2.0 

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

ControllerUnpublishVolume handles persistent volume unpublish event in controller service

func (*Driver) CreateSnapshot added in v0.2.0 

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

CreateSnapshot creates a snapshot of a volume

func (*Driver) CreateVolume added in v0.2.0 

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

CreateVolume handles persistent volume creation event

func (*Driver) DeleteSnapshot added in v0.2.0 

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

DeleteSnapshot deletes a snapshot of a volume

func (*Driver) DeleteVolume added in v0.2.0 

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

DeleteVolume handles persistent volume deletion event

func (*Driver) GetCapacity added in v0.2.0 

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

GetCapacity returns volume capacity

func (*Driver) GetPluginCapabilities 

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

GetPluginCapabilities returns plugin capabilities

func (*Driver) GetPluginInfo 

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

GetPluginInfo returns plugin info

func (*Driver) ListSnapshots added in v0.2.0 

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

ListSnapshots returns a list of snapshots

func (*Driver) ListVolumes added in v0.2.0 

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

ListVolumes returns a list of volumes created

func (*Driver) NodeExpandVolume 

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

func (*Driver) NodeGetCapabilities 

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

func (*Driver) NodeGetInfo 

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

func (*Driver) NodeGetVolumeStats 

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

func (*Driver) NodePublishVolume 

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

func (*Driver) NodeStageVolume 

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

func (*Driver) NodeUnpublishVolume 

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

func (*Driver) NodeUnstageVolume 

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

func (*Driver) Probe 

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

Probe returns probe response

func (*Driver) Run 

func (driver *Driver) Run() error

Run runs the driver service

func (*Driver) Stop added in v0.2.0 

func (driver *Driver) Stop()

Stop stops the driver service

func (*Driver) ValidateVolumeCapabilities added in v0.2.0 

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

ValidateVolumeCapabilities checks validity of volume capabilities

type Mounter 

type Mounter interface {
	mount.Interface
}

Mounter is responsible only for local CSI bind mounts. Filesystem mounts are created and removed by irodsfsd.

func NewNodeMounter added in v0.12.0 

func NewNodeMounter() Mounter

NewNodeMounter returns the standard Kubernetes mounter for local bind mount operations in the node service.

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.
⌂ 换网址