common

Apr 10, 2020

Changes in this version

+ 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

Nov 8, 2019

Changes in this version

+ const DefaultFileSystem

+ const DefaultTimeFormat

+ const FileSystemExt3

+ const FileSystemExt4

+ const FileSystemXfs

+ const Gib

+ const Gib100

+ const Int64Max

+ const Kib

+ const Mib

+ const OperationPendingFmt

+ const Tib

+ const Tib100

+ func ByteCeilToGib(nByte int64) int

+ func EntryFunction(functionName string) (info string, hash string)

+ func ExitFunction(functionName, hash string) (info string)

+ func GenerateHashInEightBytes(input string) string

+ func GetRequestSizeBytes(capRange *csi.CapacityRange) (int64, error)

+ func GibToByte(nGib int) int64

+ func IsValidCapacityBytes(cur int64, capRange *csi.CapacityRange) bool

+ func NewSafeMounter() *mount.SafeFormatAndMount

+ func ParseEndpoint(ep string) (string, string, error)

+ func RetryOnError(backoff wait.Backoff, fn func() error) error

+ type NonBlockingGRPCServer interface

+ ForceStop func()

+ Start func(endpoint string, ids csi.IdentityServer, cs csi.ControllerServer, ...)

+ Stop func()

+ Wait func()

+ func NewNonBlockingGRPCServer() NonBlockingGRPCServer

+ type ResourceLocks struct

+ func NewResourceLocks() *ResourceLocks

+ func (lock *ResourceLocks) Release(resourceID string)

+ func (lock *ResourceLocks) TryAcquire(resourceID string) bool