AddRuntimesIfNotExist adds newRuntime to runtimes and return the updated runtime slice.

BytesSize returns a human-readable size in bytes, kibibytes, mebibytes, gibibytes, or tebibytes, but with a B, kB, MB unit style.

CalculateDuration generates a string of duration from creationTime and finishTime if finish time is zero, use current time as default.

ChangeNodeLabelWithPatchMode updates the input labels in PATCH mode.

ChangeNodeLabelWithUpdateMode updates the input labels in UPDATE mode.

ContainsAll checks if a map contains all the elements in a slice.

ContainsOwners Determine whether the slice of owners contains the owner of a Dataset return true if contains the owner and return false if not.

ContainsSelector Determine whether the labels contain the selector.

ContainsString Determine whether the string array contains a specific string return true if contains the string and return false if not.

ContainsSubString Determine whether the string array contains a sub string return true if contains the string and return false if not.

ConvertDashToUnderscore converts all dash "-" characters in a string to underscore "_" characters.

CreateRuntimeForReferenceDatasetIfNotExist creates runtime for ReferenceDataset.

DumpJSON returns the JSON encoding.

FillSliceWithString fills a slice with repeated given string.

FilterVolumesByVolumeMounts returns volumes that exists in the volumeMounts.

FromHumanSize returns an integer from a human-readable specification of a size with 1024 as multiplier e.g.: 1.

FromRawToObject is used to convert from raw to the runtime object.

FuseSidecarPrivileged decides if the injected fuse sidecar should be privileged, only used when fuse sidecar should be injected - sidecar is privileged only when setting serverless.fluid.io/inject=true without unprivileged.sidecar.fluid.io/inject=true.

FuseSidecarUnprivileged decides if the injected fuse sidecar should be unprivileged, only used when fuse sidecar should be injected - serverlessPlatform implies injecting unprivileged fuse sidecar - serverless.fluid.io/inject=true + unprivileged.sidecar.fluid.io/inject=true implies injecting unprivileged fuse sidecar,.

GetAddressOfMaster return the ip and port of engine master.

GetAlluxioRuntime gets Alluxio Runtime object with the given name and namespace.

GetBackupUserDir generate the temp dir of backup user.

GetChartsDirectory gets the directory of the charts.

GetDataBackup gets the DataBackup given its name and namespace.

GetDataBackupPodName returns DataBackup pod's name given the DataBackup's name.

GetDataBackupReleaseName returns DataBackup helm release's name given the DataBackup's name.

GetDataLoad gets the DataLoad given its name and namespace.

GetDataLoadJobName returns DataLoad job's name given the DataLoad helm release's name.

GetDataLoadReleaseName returns DataLoad helm release's name given the DataLoad's name.

GetDataMigrate gets the DataMigrate given its name and namespace.

GetDataMigrateJobName returns DataMigrate job(or cronjob)'s name given the DataMigrate helm release's name.

GetDataMigrateReleaseName returns DataMigrate helm release's name given the DataMigrate's name.

GetDataProcessReleaseName returns the helm release name given the DataProcess's name.

GetDataset gets the dataset.

GetDatasetCondition returns dataset condition according to a given dataset condition type.

GetEFCRuntime gets EFC Runtime object with the given name and namespace.

GetExclusiveKey gets exclusive key.

GetExclusiveValue gets exclusive value.

GetGooseFSRuntime gets GooseFS Runtime object with the given name and namespace.

GetJindoRuntime gets Jindo Runtime object with the given name and namespace.

GetJuiceFSRuntime gets JuiceFS Runtime object with the given name and namespace.

GetMountRoot gets the value of the env variable named MOUNT_ROOT.

GetOrDefault returns the default value unless there is a specified value.

GetParallelOperationWorkersName Get the workers statefulset name according the helm release name.

GetRuntimeCondition gets a runtime condition given a runtime condition type.

GetVineyardRuntime gets Vineyard Runtime object with the given name and namespace.

HasDeletionTimestamp method that makes logic easier to read.

Home returns the home directory for the executing user.

IgnoreAlreadyExists ignores already existes error.

IgnoreNotFound ignores not found.

InjectNodeSelectorRequirements injects(not append) a node selector term to affinity‘s nodeAffinity.

InjectRequiredSchedulingTerms inject the NodeSelectorTerms into a pod.

InjectPreferredSchedulingTerms inject the preferredSchedulingTerms into a pod.

IntersectIntegerSets returns the intersection of integer set 1 and set 2.

IsDatasetConditionExist checks if the given dataset condition exists in the given dataset condition array.

IsPodManagedByFluid checks if the given Pod is managed by Fluid.

checks the setup is done.

determine if subPath is a subdirectory of path.

IsTargetPathUnderFluidNativeMounts checks if targetPath is a subpath under some given native mount point.

ListDataOperationJobByCronjob gets the DataOperation(i.e.

LoggingErrorExceptConflict logs error except for updating operation violates with etcd concurrency control.

NewDatasetCondition creates a new Cache condition.

NewRuntimeCondition creates a new Cache condition.

NewRuntimeCondition creates a new Cache condition.

NewUFSToUpdate get UFSToUpdate according the given dataset.

NoRequeue returns the result of a reconcile invocation and no err The Object will not requeue.

Now returns the current time.

ParseBackupRestorePath parse the BackupPath in spec of DataBackup or the RestorePath in spec of Dataset.

PathExists returns the specified path is exists or not.

RandomAlphaNumberString returns a string of length l which is made up of runes randomly selected from [0-9a-z].

RandomString returns a string of length l which is made up of runes randomly selected from `source`.

RemoveDuplicateStr removes duplicate string.

RemoveNotFoundDatasetRef checks datasetRef existence and remove if reference dataset is not found.

RemoveString removes strings in a array, which is equal to a given string.

ReplacePrefix replaces the input with suffix string.

RequeueAfterInterval returns the result of a reconcile invocation with a given requeue interval and no err The Object will requeue after the given requeue interval.

RequeueIfError returns the result of a reconciler invocation and the err The Object will requeue when err is not nil.

RequeueImmediately returns the result of a reconciler invocation and no err The Object will requeue immediately whether the err is nil or not.

RequeueImmediatelyUnlessGenerationChanged requeues immediately if the object generation has not changed.

ServerfulFuseEnabled decides if FUSE CSI related optimization should be injected, e.g.

ServerlessEnabled decides if fuse sidecar should be injected, whether privileged or unprivileged - serverlessPlatform implies injecting unprivileged fuse sidecar - serverless.fluid.io/inject=true implies injecting (privileged/unprivileged) fuse sidecar, - [deprecated] fuse.sidecar.fluid.io/inject=true is the deprecated version of serverless.fluid.io/inject=true.

SetValueIfKeyAbsent sets value when key is not found in the map.

SplitSchemaAddr splits the address string into 2 parts: proto and addr.

SubtractString returns the subtraction between two string slice.

Timeleft return not nil remaining time if data operation has completion time and set ttlAfterFinished.

TimeTrack tracks the time cost for some process with some optional information.

ToYaml converts values from json format to yaml format and stores the values to the file.

TransformQuantityToUnits returns a human-readable size in bytes, kibibytes, mebibytes, gibibytes, or tebibytes (eg.

TransformQuantityToAlluxioUnit transform a given input quantity to another one that can be recognized by Alluxio.

TransformQuantityToEFCUnit transform a given input quantity to another one that can be recognized by EFC.

TransformQuantityToGooseFSUnit transform a given input quantity to another one that can be recognized by GooseFS.

TransfromQuantityToJindoUnit transform a given input quantity to another one that can be recognized by Jindo.

TrimVolumes trims the volumes.

UnionMapsWithOverride unions two maps into one.

SetDatasetCondition updates the dataset to include the provided condition.

UpdateMountStatus updates the mount status of the dataset according to the given phase.

UpdateRuntimeCondition updates the runtime to include the provided condition.

---- Utils functions to decide serverless platform ----.

---- Utils functions to decide serverless platform ----.

UFSToUpdate records the mountPath to change in virtual file system of dataset.