util

Oct 26, 2021

Changes in this version

+ const ControllerServiceName

+ const DefaultKubernetesTolerationKey

+ const DeviceDirectory

+ const DiskConfigFile

+ const HostProcPath

+ const MinimalVolumeSize

+ const ReplicaDirectory

+ const ReplicaServiceName

+ const SizeAlignment

+ const TemporaryMountPointDirectory

+ const VolumeStackPrefix

+ var APIRetryCounts = 10

+ var APIRetryInterval = 500 * time.Millisecond

+ var APIRetryJitterInterval = 50 * time.Millisecond

+ func AddFinalizer(name string, obj runtime.Object) error

+ func AutoCorrectName(name string, maxLength int) string

+ func Backoff(maxDuration time.Duration, timeoutMessage string, f func() (bool, error)) error

+ func CheckBackupType(backupTarget string) (string, error)

+ func CmdOutLines(cmd *exec.Cmd, cancel <-chan interface{}) (<-chan string, <-chan error)

+ func Contains(list []string, item string) bool

+ func ConvertSize(size interface{}) (int64, error)

+ func CopyHostDirectoryContent(src, dest string) (err error)

+ func CopyReq(req *http.Request) *http.Request

+ func CreateDiskPathReplicaSubdirectory(path string) error

+ func DeleteDiskPathReplicaSubdirectoryAndDiskCfgFile(nsExec *iscsi_util.NamespaceExecutor, path string) error

+ func DetectFileSystem(volumeName string) (string, error)

+ func Execute(envs []string, binary string, args ...string) (string, error)

+ func ExecuteWithTimeout(timeout time.Duration, envs []string, binary string, args ...string) (string, error)

+ func ExecuteWithoutTimeout(envs []string, binary string, args ...string) (string, error)

+ func ExpandFileSystem(volumeName string) (err error)

+ func FilteredLoggingHandler(filteredPaths map[string]struct{}, writer io.Writer, router http.Handler) http.Handler

+ func FinalizerExists(name string, obj runtime.Object) bool

+ func FormatLocalTime(t time.Time, loc *time.Location) string

+ func FormatTimeZ(t time.Time) string

+ func FromMillis(t int64) time.Time

+ func GetAnnotation(obj runtime.Object, annotationKey string) (string, error)

+ func GetBackupID(backupURL string) (string, error)

+ func GetChecksumSHA512(data []byte) string

+ func GetDistinctTolerations(tolerationList []v1.Toleration) []v1.Toleration

+ func GetLocalIPs() ([]string, error)

+ func GetRequiredEnv(key string) (string, error)

+ func GetSortedKeysFromMap(maps interface{}) []string

+ func GetStringChecksum(data string) string

+ func GetStringHash(data string) string

+ func GetTolerationChecksum(t v1.Toleration) string

+ func IsKubernetesDefaultToleration(toleration v1.Toleration) bool

+ func IsKubernetesVersionAtLeast(kubeClient clientset.Interface, vers string) (bool, error)

+ func IsSupportedFileSystem(fsType string) bool

+ func LimitToPeriod(p, t [2]time.Time) [2]time.Time

+ func MinInt(a, b int) int

+ func Now() string

+ func ParseLabels(labels []string) (map[string]string, error)

+ func ParseLocalTime(ts string, loc *time.Location) (time.Time, error)

+ func ParsePeriod(s string, loc *time.Location) ([2]time.Time, error)

+ func ParseTime(t string) (time.Time, error)

+ func ParseTimeZ(s string) (time.Time, error)

+ func RandomID() string

+ func RegisterShutdownChannel(done chan struct{})

+ func RemoveFinalizer(name string, obj runtime.Object) error

+ func RemoveHostDirectoryContent(directory string) (err error)

+ func RetryOnConflictCause(fn func() (interface{}, error)) (interface{}, error)

+ func RetryOnErrorCondition(fn func() (interface{}, error), predicate func(error) bool) (interface{}, error)

+ func RetryOnNotFoundCause(fn func() (interface{}, error)) (interface{}, error)

+ func RoundUpSize(size int64) int64

+ func RunAsync(wg *sync.WaitGroup, f func())

+ func SetAnnotation(obj runtime.Object, annotationKey, annotationValue string) error

+ func SplitStringToMap(str, separator string) map[string]struct

+ func TimestampAfterTimeout(ts string, timeout time.Duration) bool

+ func TimestampWithinLimit(latest time.Time, ts string, limit time.Duration) bool

+ func TolerationListToMap(tolerationList []v1.Toleration) map[string]v1.Toleration

+ func UUID() string

+ func ValidateName(name string) bool

+ func ValidateSnapshotLabels(labels map[string]string) (map[string]string, error)

+ func ValidateTags(inputTags []string) ([]string, error)

+ func WaitForAPI(url string, timeout int) error

+ func WaitForDevice(dev string, timeout int) error

+ type DiskConfig struct

+ DiskUUID string

+ func GenerateDiskConfig(path string) (*DiskConfig, error)

+ func GetDiskConfig(path string) (*DiskConfig, error)

+ type DiskInfo struct

+ BlockSize int64

+ FreeBlock int64

+ Fsid string

+ Path string

+ StorageAvailable int64

+ StorageMaximum int64

+ TotalBlock int64

+ Type string

+ func GetDiskInfo(directory string) (info *DiskInfo, err error)

+ type MetadataConfig struct

+ DriverContainerName string

+ DriverName string

+ Image string

+ OrcImage string