Versions in this module Expand all Collapse all v1 v1.0.0 Jul 31, 2025 Changes in this version + const ControllerDriverType + const DefaultFileSystem + const DefaultProvisionName + const DefaultTimeFormat + const FEAT_MOUNTOPT_ENABLE + const FileSystemExt3 + const FileSystemExt4 + const FileSystemXfs + const Gib + const Int64Max + const Kib + const KubeletRootDir + const KubernetesPluginPathPrefix + const Mib + const NodeDriverType + const OperationPendingFmt + const Tib + const Version + const ZECVMID_LEN + const ZECVOLID_LEN + const ZECVOLSERIAL_LEN + const ZEC_PLATFORM + const ZEC_PRODUCT_FAMILY_PATH + const ZEC_PRODUCT_SERIAL_PATH + const ZEC_SYS_VENDOR_PATH + var DefaultResourceGroup string + var DefaultZone string + var FeatureGates []string + var MixDriver bool + func ByteCeilToGib(nByte int64) int + func EntryFunction(functionName string) (info string, hash string) + func ExitFunction(functionName, hash string) (info string) + func FormatAndMount(diskMounter *k8smount.SafeFormatAndMount, source string, target string, ...) error + func FormatNewDisk(readOnly bool, source, fstype, target string, ...) error + func GenCsiVolId(volid, serial string) (csivolId string) + func GenerateHashInEightBytes(input string) string + func GetDiskFStypePTtype(disk string) (fstype string, pttype string, err error) + func GetRequestSizeBytes(capRange *csi.CapacityRange) (int64, error) + func GetZecEnv() (vmid string, vm_zone string, err error) + func GetZecSecret(akpath string, skpath string) (ak string, pw string, err error) + func GibToByte(nGib int) int64 + func IsDirEmpty(name string) (bool, error) + func IsFileExisting(filename string) bool + func IsValidCapacityBytes(cur int64, capRange *csi.CapacityRange) bool + func NewSafeMounter() *mount.SafeFormatAndMount + func ParseCsiVolId(csivolId string) (volid string, serial string, err error) + func RetryOnError(backoff wait.Backoff, fn func() error) error + func VerifyEnv() (platform string, err error) + type ResourceLocks struct + func NewResourceLocks() *ResourceLocks + func (lock *ResourceLocks) Release(resourceID string) + func (lock *ResourceLocks) TryAcquire(resourceID string) bool + type RetryLimiter interface + Add func(id string) + GetCurrentRetryTimes func(id string) int + GetMaxRetryTimes func() int + Try func(id string) bool + func NewRetryLimiter(maxRetry int) RetryLimiter