util

func BucketCapacity(attrs *storage.BucketAttrs) (int64, error)

func BucketExists(ctx context.Context, bucket *storage.BucketHandle) (exists bool, err error)

func BucketName(volumeId string) string

func CleanupKey(keyFile string, keyStoragePath string)

func CreateDir(d string) error

func CreateFile(path, contents string) (string, error)

func DeletePod(ctx context.Context, namespace string, name string) (err error)

func DriverReadyLabel(driverName string) string

func DriverReadyLabelJSONPatchEscaped(driverName string) string

func GetKey(secrets map[string]string, keyStoragePath string) (string, error)

func GetPvcAnnotations(ctx context.Context, pvcName string, pvcNamespace string) (annotations map[string]string, err error)

func GetRegisteredMounts(ctx context.Context, node string) (list *v1beta1.PublishedVolumeList, err error)

func ParseEndpoint(endpoint string) (string, string, error)

func RegisterMount(ctx context.Context, volumeID string, targetPath string, node string, podNamespace string, podName string, options map[string]string) (err error)

func SetBucketCapacity(ctx context.Context, bucket *storage.BucketHandle, capacity int64) (attrs *storage.BucketAttrs, err error)

func SetDriverReadyLabel(ctx context.Context, driverName string, nodeName string, isReady bool) (err error)

func UnregisterMount(ctx context.Context, volumeID string, targetPath string, node string) (err error)