utils

package

Go to main page

Versions in this module

v1

v1.0.0

Apr 18, 2024

Changes in this version

+ const PlatformDefault

+ const PlatformUnprivileged

+ func CheckValidateEnvName(key string) (err error)

+ func ConvertDashToUnderscore(s string) string

+ func CreateSymlink(targetPath, mountPath string) error

+ func GetDataProcess(client client.Client, name, namespace string) (*datav1alpha1.DataProcess, error)

+ func GetDataProcessJobName(releaseName string) string

+ func GetDataProcessReleaseName(name string) string

+ func GetOperationStatus(obj client.Object) (*datav1alpha1.OperationStatus, error)

+ func GetParallelOperationWorkersName(releaseName string) string

+ func GetPrecedingOperationStatus(client client.Client, opRef *datav1alpha1.OperationRef, opRefNamespace string) (*datav1alpha1.OperationStatus, error)

+ func GetServerlessPlatfrom(infos map[string]string) (platform string)

+ func GetVineyardRuntime(client client.Client, name, namespace string) (*datav1alpha1.VineyardRuntime, error)

+ func IntersectIntegerSets(map1 map[int]bool, map2 map[int]bool) map[int]bool

+ func ListDataOperationJobByCronjob(c client.Client, cronjobNamespacedName types.NamespacedName) ([]batchv1.Job, error)

+ func NeedCleanUp(opStatus *datav1alpha1.OperationStatus, ...) bool

+ func RemoveNotFoundDatasetRef(client client.Client, dataset datav1alpha1.Dataset, log logr.Logger) ([]string, error)

+ func RemoveSymlink(targetPath string) (bool, error)

+ func SkipSidecarPostStartInject(infos map[string]string) (match bool)

+ func Timeleft(opStatus *datav1alpha1.OperationStatus, ...) (*time.Duration, error)

v0

v0.9.3

Mar 13, 2024

v0.9.2

Sep 19, 2023

Changes in this version

+ func GetBoolValueFromEnv(key string, defaultValue bool) (value bool)

+ func GetIntValueFromEnv(key string) (value int, found bool)

+ type VolumeLocks struct

+ func NewVolumeLocks() *VolumeLocks

+ func (lock *VolumeLocks) Release(volumeID string)

+ func (lock *VolumeLocks) TryAcquire(volumeID string) bool

v0.9.1

Jun 15, 2023

v0.9.0

May 24, 2023

Changes in this version

+ func AppendOrOverrideVolume(volumes []corev1.Volume, vol corev1.Volume) []corev1.Volume

+ func AppendOrOverrideVolumeMounts(volumeMounts []corev1.VolumeMount, vm corev1.VolumeMount) []corev1.VolumeMount

+ func CheckMountReadyAndSubPathExist(fluidPath string, mountType string, subPath string) error

+ func CreateRuntimeForReferenceDatasetIfNotExist(client client.Client, dataset *datav1alpha1.Dataset) (err error)

+ func FilterVolumesByVolumeMounts(volumes []corev1.Volume, volumeMounts []corev1.VolumeMount) []corev1.Volume

+ func FindVolumeByVolumeMount(volumeMount corev1.VolumeMount, volumes []corev1.Volume) *corev1.Volume

+ func GetDataMigrate(client client.Client, name, namespace string) (*datav1alpha1.DataMigrate, error)

+ func GetDataMigrateJob(client client.Client, name, namespace string) (*batchv1.Job, error)

+ func GetDataMigrateJobName(releaseName string) string

+ func GetDataMigrateRef(name, namespace string) string

+ func GetDataMigrateReleaseName(name string) string

+ func GetEFCRuntime(client client.Client, name, namespace string) (*data.EFCRuntime, error)

+ func GetObjectMeta(object client.Object) (objectMeta metav1.Object, err error)

+ func GetTargetDatasetOfMigrate(client client.Client, dataMigrate datav1alpha1.DataMigrate) (targetDataset *datav1alpha1.Dataset, err error)

+ func GetThinRuntime(client client.Client, name, namespace string) (*data.ThinRuntime, error)

+ func GetThinRuntimeProfile(client client.Client, name string) (*data.ThinRuntimeProfile, error)

+ func IgnoreNoKindMatchError(err error) error

+ func IsPodManagedByFluid(pod *corev1.Pod) bool

+ func PatchLabels(cli client.Client, obj client.Object, labelsToModify common.LabelsToModify) (modifiedLabels []string, err error)

+ func ServerfulFuseEnabled(infos map[string]string) (match bool)

+ func SortIpAddresses(ips []string) (orderedIps []string)

+ func TransformEFCUnitToQuantity(value string) (q *resource.Quantity)

+ func TransformQuantityToEFCUnit(q *resource.Quantity) (value string)

v0.8.7

Jul 24, 2023

v0.8.6

May 8, 2023

v0.8.5

Mar 27, 2023

v0.8.4

Feb 18, 2023

v0.8.3

Jan 7, 2023

v0.8.2

Nov 8, 2022

v0.8.1

Oct 3, 2022

v0.8.0

Sep 3, 2022

Changes in this version

+ var ServerlessPlatformKey string = ""

+ var ServerlessPlatformVal string = ""

+ func AppContainerPostStartInjectEnabled(infos map[string]string) (match bool)

+ func AppControllerDisabled(info map[string]string) (match bool)

+ func CheckObject(client client.Client, key types.NamespacedName, obj client.Object) (found bool, err error)

+ func ContainsSubString(slice []string, s string) bool

+ func DumpJSON(o interface{}) string

+ func FuseSidecarUnprivileged(infos map[string]string) (match bool)

+ func GetBoolValueFormEnv(key string, defaultValue bool) (value bool)

+ func GetDurationValueFromEnv(key string, defaultValue time.Duration) (value time.Duration)

+ func GetIntValueFormEnv(key string) (value int, found bool)

+ func GetStringValueFromEnv(key string, defaultValue string) (value string)

+ func IgnoreAlreadyExists(err error) error

+ func IsTimeTrackerDebugEnabled() bool

+ func IsTimeTrackerEnabled() bool

+ func ResourceRequirementsEqual(source corev1.ResourceRequirements, target corev1.ResourceRequirements) bool

+ func ServerlessPlatformMatched(infos map[string]string) (match bool)

+ func TrimCapabilities(inputs []corev1.Capability, excludeNames []string) (outputs []corev1.Capability)

+ func UnionMapsWithOverride(map1 map[string]string, map2 map[string]string) map[string]string

v0.7.0

Mar 2, 2022

Changes in this version

+ func CheckMountPointBroken(mountPath string) (broken bool, err error)

+ func CheckMountReady(fluidPath string, mountType string) error

+ func FromRawToObject(raw []byte) (obj runtime.Object, err error)

+ func FuseSidecarEnabled(infos map[string]string) (match bool)

+ func GetJuiceFSRuntime(client client.Client, name, namespace string) (*data.JuiceFSRuntime, error)

+ func GetRuntimeNameFromFusePod(pod corev1.Pod) (runtimeName string, err error)

+ func InjectCacheDirEnabled(infos map[string]string) (match bool)

+ func InjectMountPropagation(runtimeNames []string, pod *corev1.Pod)

+ func InjectSidecarDone(infos map[string]string) (match bool)

+ func IsFusePod(pod corev1.Pod) bool

+ func IsMounted(absPath string) (bool, error)

+ func LoggingErrorExceptConflict(logging logr.Logger, err error, info string, ...) (result error)

+ func NewPprofServer(setupLog logr.Logger, pprofAddr string)

+ func RandomReplacePrefix(input string, l int) (output string)

+ func RemoveDuplicateStr(strSlice []string) []string

+ func ReplacePrefix(input, suffix string) (output string)

+ func ServerlessEnabled(infos map[string]string) (match bool)

+ func TrimVolumeMounts(inputs []corev1.VolumeMount, excludeNames []string) (outputs []corev1.VolumeMount)

+ func TrimVolumes(inputs []corev1.Volume, excludeNames []string) (outputs []corev1.Volume)

+ func WorkerSidecarEnabled(infos map[string]string) (match bool)

type UFSToUpdate

+ func (u *UFSToUpdate) AddMountPaths(mountPaths []string)

v0.6.0

Aug 11, 2021

Changes in this version

+ const EiB

+ const GiB

+ const KiB

+ const MiB

+ const PiB

+ const TiB

+ func CalculateDuration(creationTime time.Time, finishTime time.Time) string

+ func ChangeNodeLabelWithPatchMode(cli client.Client, node *v1.Node, labelsToModify common.LabelsToModify) (modifiedLabels []string, err error)

+ func ChangeNodeLabelWithUpdateMode(client client.Client, node *v1.Node, labelsToModify common.LabelsToModify) (modifiedLabels []string, err error)

+ func ContainsAll(m map[string]string, slice []string) bool

+ func GetBackupUserDir(namespace string, name string) string

+ func GetEnvByKey(k string) (string, error)

+ func GetGooseFSRuntime(client client.Client, name, namespace string) (*data.GooseFSRuntime, error)

+ func GetInitUserEnv(user *datav1alpha1.User) string

+ func GetInitUsersArgs(user *datav1alpha1.User) []string

+ func GetJindoRuntime(client client.Client, name, namespace string) (*data.JindoRuntime, error)

+ func GetRpcPortFromMasterContainer(container *v1.Container) (rpcPort int32)

+ func InjectNodeSelectorTerms(requiredSchedulingTerms []corev1.NodeSelectorTerm, pod *corev1.Pod)

+ func InjectPreferredSchedulingTerms(preferredSchedulingTerms []corev1.PreferredSchedulingTerm, pod *corev1.Pod)

+ func IsSubPath(path, subPath string) bool

+ func IsTargetPathUnderFluidNativeMounts(targetPath string, dataset datav1alpha1.Dataset) bool

+ func SubtractString(x []string, y []string) []string

+ func TimeTrack(start time.Time, processName string, keysAndValues ...interface{})

+ func TransformQuantityToAlluxioUnit(q *resource.Quantity) (value string)

+ func TransformQuantityToGooseFSUnit(q *resource.Quantity) (value string)

+ func TransformQuantityToJindoUnit(q *resource.Quantity) (value string)

+ func UpdateMountStatus(client client.Client, name string, namespace string, ...) error

+ type UFSPathBuilder struct

+ func (u UFSPathBuilder) GenAlluxioMountPath(curMount datav1alpha1.Mount, mounts []datav1alpha1.Mount) string

+ func (u UFSPathBuilder) GenAlluxioUFSRootPath(items []datav1alpha1.Mount) (string, *datav1alpha1.Mount)

+ func (u UFSPathBuilder) GenLocalStoragePath(curMount datav1alpha1.Mount) string

+ func (u UFSPathBuilder) GetLocalStorageRootDir() string

+ type UFSToUpdate struct

+ func NewUFSToUpdate(ds *datav1alpha1.Dataset) *UFSToUpdate

+ func (u *UFSToUpdate) AnalyzePathsDelta() (specMountPaths, mountedMountPaths []string)

+ func (u UFSToUpdate) ShouldUpdate() bool

+ func (u UFSToUpdate) ToAdd() []string

+ func (u UFSToUpdate) ToRemove() []string

v0.5.0

Mar 16, 2021

Changes in this version

+ func ContainsOwners(owners []metav1.OwnerReference, dataset *datav1alpha1.Dataset) bool

+ func ContainsSelector(labels map[string]string, selector map[string]string) bool

+ func FillSliceWithString(str string, num int) *[]string

+ func GetAccessModesOfDataset(client client.Client, name, namespace string) (accessModes []v1.PersistentVolumeAccessMode, err error)

+ func GetAddressOfMaster(pod *v1.Pod) (nodeName string, ip string, rpcPort int32)

+ func GetDataBackup(client client.Client, name, namespace string) (*datav1alpha1.DataBackup, error)

+ func GetDataBackupPodName(name string) string

+ func GetDataBackupRef(name, namespace string) string

+ func GetDataBackupReleaseName(name string) string

+ func GetExclusiveKey() string

+ func GetExclusiveValue(namespace, name string) string

+ func GetSecret(client client.Client, name, namespace string) (*v1.Secret, error)

+ func ParseBackupRestorePath(backupRestorePath string) (pvcName string, path string, err error)

+ func TranformQuantityToAlluxioUnit(q *resource.Quantity) (value string)

+ func TranformQuantityToJindoUnit(q *resource.Quantity) (value string)

+ func TranformQuantityToUnits(q *resource.Quantity) (value string)

v0.4.0

Nov 6, 2020

Changes in this version

+ const GB

+ const KB

+ const MB

+ const MountRoot

+ const PB

+ const TB

+ func BytesSize(size float64) string

+ func FromHumanSize(size string) (int64, error)

+ func GetDataLoadJob(client client.Client, name, namespace string) (*batchv1.Job, error)

+ func GetDataLoadJobName(releaseName string) string

+ func GetDataLoadRef(name, namespace string) string

+ func GetDataLoadReleaseName(name string) string

+ func GetMountRoot() string

+ func GetRuntimeByCategory(runtimes []datav1alpha1.Runtime, category common.Category) (index int, runtime *datav1alpha1.Runtime)

+ func IsSetupDone(dataset *datav1alpha1.Dataset) (done bool)

v0.3.0

Oct 1, 2020

v0.2.0

Sep 5, 2020

Changes in this version

+ func AddRuntimesIfNotExist(runtimes []data.Runtime, newRuntime data.Runtime) (updatedRuntimes []data.Runtime)

+ func ContainsString(slice []string, s string) bool

+ func FindDataLoadWithPredicate(c client.Client, namespace string, ...) (dataload *datav1alpha1.AlluxioDataLoad, err error)

+ func GetAlluxioRuntime(client client.Client, name, namespace string) (*data.AlluxioRuntime, error)

+ func GetChartsDirectory() string

+ func GetDataLoad(client client.Client, name, namespace string) (*datav1alpha1.AlluxioDataLoad, error)

+ func GetDataset(client client.Client, name, namespace string) (*datav1alpha1.Dataset, error)

+ func GetDatasetCondition(conditions []datav1alpha1.DatasetCondition, ...) (index int, condition *datav1alpha1.DatasetCondition)

+ func GetJobNameFromReleaseName(releaseName string) string

+ func GetOrDefault(str *string, defaultValue string) string

+ func GetRuntimeCondition(conditions []data.RuntimeCondition, condType data.RuntimeConditionType) (index int, condition *data.RuntimeCondition)

+ func HasDeletionTimestamp(obj metav1.ObjectMeta) bool

+ func Home() (string, error)

+ func IgnoreNotFound(err error) error

+ func IsDatasetConditionExist(conditions []datav1alpha1.DatasetCondition, cond datav1alpha1.DatasetCondition) (found bool)

+ func NewDatasetCondition(conditionType datav1alpha1.DatasetConditionType, reason, message string, ...) datav1alpha1.DatasetCondition

+ func NewReleaseName(datasetName string) string

+ func NewRuntime(name, namespace string, category common.Category, runtimeType string) data.Runtime

+ func NewRuntimeCondition(conditionType data.RuntimeConditionType, reason, message string, ...) data.RuntimeCondition

+ func NoRequeue() (ctrl.Result, error)

+ func Now() *metav1.Time

+ func PathExists(path string) bool

+ func RandomAlphaNumberString(l int32) string

+ func RandomString(source []rune, l int32) string

+ func RemoveString(slice []string, s string) (result []string)

+ func RequeueAfterInterval(interval time.Duration) (ctrl.Result, error)

+ func RequeueIfError(err error) (ctrl.Result, error)

+ func RequeueImmediately() (ctrl.Result, error)

+ func RequeueImmediatelyUnlessGenerationChanged(prevGeneration, curGeneration int64) (ctrl.Result, error)

+ func SplitSchemaAddr(addr string) (string, string)

+ func ToYaml(values interface{}, file *os.File) error

+ func TransformRequirementsToResources(res corev1.ResourceRequirements) (cRes common.Resources)

+ func UpdateDatasetCondition(conditions []datav1alpha1.DatasetCondition, ...) []datav1alpha1.DatasetCondition

+ func UpdateRuntimeCondition(conditions []data.RuntimeCondition, condition data.RuntimeCondition) []data.RuntimeCondition

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL