Versions in this module Expand all Collapse all v1 v1.6.0 Apr 29, 2024 v1.5.1 Apr 2, 2024 v1.5.0 Mar 28, 2024 v1.4.0 Mar 6, 2024 Changes in this version + const GiB + func ParseEndpoint(endpoint string) (string, string, error) type Driver + NodeServer *S3NodeServer + type FakeMounter struct + func (m *FakeMounter) IsMountPoint(target string) (bool, error) + func (m *FakeMounter) Mount(bucketName string, target string, credentials *MountCredentials, ...) error + func (m *FakeMounter) Unmount(target string) error + type Fs interface + MkdirAll func(path string, perm os.FileMode) error + Remove func(name string) error + Stat func(name string) (os.FileInfo, error) + type MountCredentials struct + AccessKeyID string + AwsRoleArn string + DefaultRegion string + Region string + SecretAccessKey string + StsEndpoints string + WebTokenPath string + func (mc *MountCredentials) Env() []string + type MountLister interface + ListMounts func() ([]mount.MountPoint, error) type Mounter + IsMountPoint func(target string) (bool, error) + Mount func(bucketName string, target string, credentials *MountCredentials, ...) error + Unmount func(target string) error + type OsFs struct + func (OsFs) MkdirAll(path string, perm os.FileMode) error + func (OsFs) Remove(path string) error + func (OsFs) Stat(name string) (os.FileInfo, error) + type ProcMountLister struct + ProcMountPath string + func (pml *ProcMountLister) ListMounts() ([]mount.MountPoint, error) type S3Mounter + Ctx context.Context + Fs Fs + MountLister MountLister + MountS3Path string + MpVersion string + Runner ServiceRunner + type S3NodeServer struct + BaseCredentials *MountCredentials + Mounter Mounter + NodeID string + func (ns *S3NodeServer) NodeExpandVolume(ctx context.Context, req *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error) + func (ns *S3NodeServer) NodeGetCapabilities(ctx context.Context, req *csi.NodeGetCapabilitiesRequest) (*csi.NodeGetCapabilitiesResponse, error) + func (ns *S3NodeServer) NodeGetInfo(ctx context.Context, req *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error) + func (ns *S3NodeServer) NodeGetVolumeStats(ctx context.Context, req *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error) + func (ns *S3NodeServer) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error) + func (ns *S3NodeServer) NodeStageVolume(ctx context.Context, req *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error) + func (ns *S3NodeServer) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error) + func (ns *S3NodeServer) NodeUnstageVolume(ctx context.Context, req *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error) + type ServiceRunner interface + RunOneshot func(ctx context.Context, config *system.ExecConfig) (string, error) + StartService func(ctx context.Context, config *system.ExecConfig) (string, error) + type Token struct + ExpirationTimestamp time.Time + Token string v1.3.1 Feb 16, 2024 v1.3.0 Feb 1, 2024 v1.2.0 Jan 17, 2024 v1.1.0 Dec 5, 2023 v1.0.0 Nov 16, 2023 Changes in this version + const MountS3PathEnv + func GetVersionJSON() (string, error) + func MountS3Path() string + func ReplaceFile(destPath string, sourcePath string, perm fs.FileMode) error + type Driver struct + Endpoint string + Mounter Mounter + NodeID string + Srv *grpc.Server + func NewDriver(endpoint string, mpVersion string, nodeID string) *Driver + func NewFakeDriver(endpoint string) *Driver + func (d *Driver) ControllerExpandVolume(ctx context.Context, req *csi.ControllerExpandVolumeRequest) (*csi.ControllerExpandVolumeResponse, error) + func (d *Driver) ControllerGetCapabilities(ctx context.Context, req *csi.ControllerGetCapabilitiesRequest) (*csi.ControllerGetCapabilitiesResponse, error) + func (d *Driver) ControllerGetVolume(ctx context.Context, req *csi.ControllerGetVolumeRequest) (*csi.ControllerGetVolumeResponse, error) + func (d *Driver) ControllerModifyVolume(context.Context, *csi.ControllerModifyVolumeRequest) (*csi.ControllerModifyVolumeResponse, error) + func (d *Driver) ControllerPublishVolume(ctx context.Context, req *csi.ControllerPublishVolumeRequest) (*csi.ControllerPublishVolumeResponse, error) + func (d *Driver) ControllerUnpublishVolume(ctx context.Context, req *csi.ControllerUnpublishVolumeRequest) (*csi.ControllerUnpublishVolumeResponse, error) + func (d *Driver) CreateSnapshot(ctx context.Context, req *csi.CreateSnapshotRequest) (*csi.CreateSnapshotResponse, error) + func (d *Driver) CreateVolume(ctx context.Context, req *csi.CreateVolumeRequest) (*csi.CreateVolumeResponse, error) + func (d *Driver) DeleteSnapshot(ctx context.Context, req *csi.DeleteSnapshotRequest) (*csi.DeleteSnapshotResponse, error) + func (d *Driver) DeleteVolume(ctx context.Context, req *csi.DeleteVolumeRequest) (*csi.DeleteVolumeResponse, error) + func (d *Driver) GetCapacity(ctx context.Context, req *csi.GetCapacityRequest) (*csi.GetCapacityResponse, error) + func (d *Driver) GetPluginCapabilities(ctx context.Context, req *csi.GetPluginCapabilitiesRequest) (*csi.GetPluginCapabilitiesResponse, error) + func (d *Driver) GetPluginInfo(ctx context.Context, req *csi.GetPluginInfoRequest) (*csi.GetPluginInfoResponse, error) + func (d *Driver) ListSnapshots(ctx context.Context, req *csi.ListSnapshotsRequest) (*csi.ListSnapshotsResponse, error) + func (d *Driver) ListVolumes(ctx context.Context, req *csi.ListVolumesRequest) (*csi.ListVolumesResponse, error) + func (d *Driver) NodeExpandVolume(ctx context.Context, req *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error) + func (d *Driver) NodeGetCapabilities(ctx context.Context, req *csi.NodeGetCapabilitiesRequest) (*csi.NodeGetCapabilitiesResponse, error) + func (d *Driver) NodeGetInfo(ctx context.Context, req *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error) + func (d *Driver) NodeGetVolumeStats(ctx context.Context, req *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error) + func (d *Driver) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error) + func (d *Driver) NodeStageVolume(ctx context.Context, req *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error) + func (d *Driver) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error) + func (d *Driver) NodeUnstageVolume(ctx context.Context, req *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error) + func (d *Driver) Probe(ctx context.Context, req *csi.ProbeRequest) (*csi.ProbeResponse, error) + func (d *Driver) Run() error + func (d *Driver) Stop() + func (d *Driver) ValidateVolumeCapabilities(ctx context.Context, req *csi.ValidateVolumeCapabilitiesRequest) (*csi.ValidateVolumeCapabilitiesResponse, error) + type Mounter interface + IsCorruptedMnt func(err error) bool + MakeDir func(pathname string) error + PathExists func(path string) (bool, error) + func NewFakeMounter() Mounter + type OsPts struct + func (p *OsPts) NewPts() (io.ReadCloser, int, error) + type Pts interface + NewPts func() (io.ReadCloser, int, error) + type S3Mounter struct + func NewS3Mounter(mpVersion string) (*S3Mounter, error) + func (m *S3Mounter) IsCorruptedMnt(err error) bool + func (m *S3Mounter) IsMountPoint(file string) (bool, error) + func (m *S3Mounter) List() ([]mount.MountPoint, error) + func (m *S3Mounter) MakeDir(pathname string) error + func (m *S3Mounter) Mount(source string, target string, _ string, options []string) error + func (m *S3Mounter) PathExists(path string) (bool, error) + func (m *S3Mounter) Unmount(target string) error + type SystemdConnection interface + Close func() + ListUnitsContext func(ctx context.Context) ([]systemd.UnitStatus, error) + ResetFailedUnitContext func(ctx context.Context, name string) error + StartTransientUnitContext func(ctx context.Context, name string, mode string, properties []systemd.Property, ...) (int, error) + func ConnectOsSystemd(ctx context.Context) (SystemdConnection, error) + type SystemdConnector interface + Connect func(ctx context.Context) (SystemdConnection, error) + func NewOsSystemd() SystemdConnector + type SystemdRunner struct + Connector SystemdConnector + Pts Pts + func NewSystemdRunner() SystemdRunner + func (sr *SystemdRunner) Run(ctx context.Context, cmd string, serviceTag string, serviceType string, ...) (string, error) + type VersionInfo struct + BuildDate string + Compiler string + DriverVersion string + GitCommit string + GoVersion string + Platform string + func GetVersion() VersionInfo
Go to main page