util

Nov 4, 2024

Changes in this version

+ func ContainsEnv(envs []corev1.EnvVar, key string) bool

+ func ContainsVolumeDevices(vds []corev1.VolumeDevice, name string) bool

+ func ContainsVolumeMounts(vms []corev1.VolumeMount, name string) bool

+ func ContainsVolumes(volumes []corev1.Volume, name string) bool

+ func GetMountOptionsOfPod(pod *corev1.Pod) []string

Oct 21, 2024

Changes in this version

+ func ImageSupportBinary(image string) bool

Sep 30, 2024

Changes in this version

+ const LogKey

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

+ func Exists(path string) bool

+ func GenLog(ctx context.Context, log klog.Logger, name string) klog.Logger

+ func SupportFusePass(image string) bool

+ func SupportUpgradeBinary(ce bool, version string) bool

+ func SupportUpgradeRecreate(ce bool, version string) bool

+ func WithLog(parentCtx context.Context, log klog.Logger) context.Context

+ type ClientVersion struct

+ Dev bool

+ IsCe bool

+ Major int

+ Minor int

+ Patch int

+ func (v ClientVersion) LessThan(o ClientVersion) bool

+ type JuiceConf struct

+ Meta struct{ ... }

+ PPid int

+ Pid int

+ func ParseConfig(conf []byte) (*JuiceConf, error)

+ type LoggerType string

Jul 17, 2024

Changes in this version

+ func DevMinorTableDelete(k any)

+ func DevMinorTableLoad(k any) (uint32, bool)

+ func DevMinorTableStore(k any, dev uint64)

May 23, 2024

Changes in this version

+ type VolumeLocks struct

+ func NewVolumeLocks() *VolumeLocks

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

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

Apr 16, 2024

Changes in this version

+ var MountPointDevMinorTable sync.Map

+ func DevMinor(dev uint64) uint32

+ func ParseToBytes(value string) (uint64, error)

+ func WaitUtilMountReady(ctx context.Context, podName, mntPath string, timeout time.Duration) error

Feb 29, 2024

Changes in this version

+ func GetDiskUsage(path string) (uint64, uint64, uint64, uint64)

+ func NewPrometheus(nodeName string) (prometheus.Registerer, *prometheus.Registry)

Jan 24, 2024

Changes in this version

+ type ObjectMeta struct

+ func NewObjectMeta(pvc v1.PersistentVolumeClaim, node *v1.Node) *ObjectMeta

+ func (meta *ObjectMeta) ResolveSecret(str string, pvName string) string

+ func (meta *ObjectMeta) StringParser(str string) string

Nov 15, 2023

Changes in this version

+ func GetNamespace(ctx context.Context, client *k8sclient.K8sClient, pod *corev1.Pod) (namespace string, err error)

+ type PVPair struct

+ PV *corev1.PersistentVolume

+ PVC *corev1.PersistentVolumeClaim

+ func GetVolumes(ctx context.Context, client *k8sclient.K8sClient, pod *corev1.Pod) (used bool, pvPairGot []PVPair, err error)

Sep 7, 2023

Changes in this version

+ func AddSecretFinalizer(ctx context.Context, client *k8s.K8sClient, secret *v1.Secret, ...) error

+ func CheckForSecretFinalizer(ctx context.Context, client *k8s.K8sClient, volume *v1.PersistentVolume) (shouldRemoveFinalizer bool, err error)

+ func RemoveSecretFinalizer(ctx context.Context, client *k8s.K8sClient, secret *v1.Secret, ...) error

type PVCMetadata

+ func (meta *PVCMetadata) ResolveSecret(str string, pvName string) string

Jul 13, 2023

Changes in this version

+ func AddPodLabel(ctx context.Context, client *k8sclient.K8sClient, pod *corev1.Pod, ...) error

Jun 12, 2023

Changes in this version

+ func IsJobShouldBeRecycled(job *batchv1.Job) bool

Apr 7, 2023

Changes in this version

+ func ImageResol(image string) (hasCE, hasEE bool)

Feb 13, 2023

Changes in this version

+ func CheckExpectValue(m map[string]string, key string, targetValue string) bool

+ func CheckForSubPath(ctx context.Context, client *k8s.K8sClient, volume *v1.PersistentVolume, ...) (shouldDeleted bool, err error)

Jan 3, 2023

Changes in this version

+ func GetAllRefKeys(pod corev1.Pod) map[string]string

Dec 23, 2022

Changes in this version

+ func AddPodAnnotation(ctx context.Context, client *k8sclient.K8sClient, pod *corev1.Pod, ...) error

+ func DelPodAnnotation(ctx context.Context, client *k8sclient.K8sClient, pod *corev1.Pod, ...) error

+ func ReplacePodAnnotation(ctx context.Context, client *k8sclient.K8sClient, pod *corev1.Pod, ...) error

+ func StripReadonlyOption(options []string) []string

Nov 15, 2022

Changes in this version

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

Sep 19, 2022

Changes in this version

+ func DoWithContext(ctx context.Context, f func() error) error

+ func DoWithTimeout(parent context.Context, timeout time.Duration, f func() error) error

+ func UmountPath(ctx context.Context, sourcePath string)

Jul 14, 2022

Changes in this version

+ func CheckDynamicPV(name string) (bool, error)

Jun 17, 2022

Changes in this version

+ func DoWithinTime(ctx context.Context, timeout time.Duration, cmd *exec.Cmd, f func() error) (out []byte, err error)

+ func RemoveFinalizer(client *k8sclient.K8sClient, pod *corev1.Pod, finalizer string) error

May 20, 2022

Changes in this version

+ func ConsistentRead(filename string, attempts int) ([]byte, error)

+ func RandStringRunes(n int) string

Apr 25, 2022

Changes in this version

+ type PVCMetadata struct

+ func NewPVCMeta(pvc v1.PersistentVolumeClaim) *PVCMetadata

+ func (meta *PVCMetadata) StringParser(str string) string

Apr 1, 2022

Changes in this version

+ func GetMountDeviceRefs(pathname string, corrupted bool) ([]string, error)

+ func PatchPodAnnotation(client *k8s.K8sClient, pod *corev1.Pod, annotation map[string]string) error

Feb 16, 2022

Changes in this version

+ func GetTime(str string) (time.Time, error)

+ func GetTimeAfterDelay(delayStr string) (string, error)

+ func IsJobCompleted(job *batchv1.Job) bool

+ func IsJobFailed(job *batchv1.Job) bool

+ func QuoteForShell(cmd string) string

+ func ShouldDelay(pod *corev1.Pod, Client *k8s.K8sClient) (shouldDelay bool, err error)

+ func StripPasswd(uri string) string

Nov 16, 2021

Changes in this version

+ func GetMountPathOfPod(pod corev1.Pod) (string, string, error)

+ func GetReferenceKey(target string) string

+ func ParseMntPath(cmd string) (string, string, error)

Jul 26, 2021

Changes in this version

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

+ func Copy(fromPath, toPath string) error

+ func DeleteResourceOfPod(pod *corev1.Pod)

+ func IsPodError(pod *corev1.Pod) bool

+ func IsPodHasResource(pod corev1.Pod) bool

+ func IsPodReady(pod *corev1.Pod) bool

+ func IsPodResourceError(pod *corev1.Pod) bool

+ func PathExist(path string) bool

Mar 16, 2020

Changes in this version

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