Versions in this module Expand all Collapse all v0 v0.1.1 Dec 13, 2022 v0.1.0 Nov 3, 2022 Changes in this version + const AnnoBucketName + const DriverName + const MetaDataCapacity + const MetaDataPrivisionType + const NamePrefix + const ParamBucketNameTag + const ParamPVCName + const ParamPVCNameSpace + const ParamPVName + const ParamProvisionTypeTag + const ParamQuotaType + const ProvisionTypeBucketOrCreate + const QuotaTypeFIFO + const QuotaTypeHard + const S3FSCmd + const S3FSPassWordFileName + const S3FSType + const SecretAK + const SecretMinIOHost + const SecretRegion + const SecretSK + var DefaultFeatureGate featuregate.FeatureGate = DefaultMutableFeatureGate + var DefaultMutableFeatureGate featuregate.MutableFeatureGate = featuregate.NewFeatureGate() + var Quota featuregate.Feature = "Quota" + func S3FSMount(url, bucket, mountpoint, AK, SK string) error + func S3FSUmount(mountpoint string) error + type MinIOClient struct + func NewMinIOClient(cfg *S3Config) (*MinIOClient, error) + func (driver *MinIOClient) CreateBucket(bucketName string, capacityBytes int64) error + func (driver *MinIOClient) DeleteBucket(bucketName string) error + func (driver *MinIOClient) EmptyBucket(bucketName string) error + func (driver *MinIOClient) FsInfo(bucketName string) (int64, int64, int64, int64, int64, int64, error) + func (driver *MinIOClient) GetBucketCapacity(bucketName string) (int64, error) + func (driver *MinIOClient) GetBucketMetadata(bucketName string) (map[string]string, error) + func (driver *MinIOClient) GetBucketUsage(bucketName string) (int64, error) + func (driver *MinIOClient) ListBucketObjects(bucketName string) ([]minio.ObjectInfo, error) + func (driver *MinIOClient) RemoveBucketMetadata(bucketName string) error + func (driver *MinIOClient) SetBucketMetadata(bucketName string, bucketMap map[string]string) error + func (driver *MinIOClient) SetBucketQuota(bucketName string, capacityBytes int64, qType madmin.QuotaType) error + type MinIODriver struct + func NewMinIODriver(cfg *S3Config) (*MinIODriver, error) + func (driver *MinIODriver) ControllerExpandVolume(ctx context.Context, req *csi.ControllerExpandVolumeRequest) (*csi.ControllerExpandVolumeResponse, error) + func (driver *MinIODriver) CreateVolume(ctx context.Context, req *csi.CreateVolumeRequest) (*csi.CreateVolumeResponse, error) + func (driver *MinIODriver) DeleteVolume(ctx context.Context, req *csi.DeleteVolumeRequest) (*csi.DeleteVolumeResponse, error) + func (driver *MinIODriver) NodeExpandVolume(ctx context.Context, req *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error) + func (driver *MinIODriver) NodeGetVolumeStats(ctx context.Context, req *csi.NodeGetVolumeStatsRequest) (*csi.NodeGetVolumeStatsResponse, error) + func (driver *MinIODriver) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error) + func (driver *MinIODriver) NodeStageVolume(ctx context.Context, req *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error) + func (driver *MinIODriver) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error) + func (driver *MinIODriver) NodeUnstageVolume(ctx context.Context, req *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error) + type ProvisionType string + type S3Config struct + AK string + Endpoint string + Region string + SK string
Go to main page