resource

package

v0.24.3 Latest Latest Go to latest Published: Jul 17, 2024 License: Apache-2.0 Imports: 20 Imported by: 1

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/juicedata/juicefs-csi-driver

Links

Open Source Insights

Documentation ¶

Index ¶

func AddPodAnnotation(ctx context.Context, client *k8sclient.K8sClient, pod *corev1.Pod, ...) error
func AddPodLabel(ctx context.Context, client *k8sclient.K8sClient, pod *corev1.Pod, ...) error
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 CheckForSubPath(ctx context.Context, client *k8s.K8sClient, volume *v1.PersistentVolume, ...) (shouldDeleted bool, err error)
func DelPodAnnotation(ctx context.Context, client *k8sclient.K8sClient, pod *corev1.Pod, ...) error
func DeleteResourceOfPod(pod *corev1.Pod)
func GetAllRefKeys(pod corev1.Pod) map[string]string
func GetNamespace(ctx context.Context, client *k8sclient.K8sClient, pod *corev1.Pod) (namespace string, err error)
func IsJobCompleted(job *batchv1.Job) bool
func IsJobFailed(job *batchv1.Job) bool
func IsJobShouldBeRecycled(job *batchv1.Job) bool
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 RemoveFinalizer(ctx context.Context, client *k8sclient.K8sClient, pod *corev1.Pod, ...) error
func RemoveSecretFinalizer(ctx context.Context, client *k8s.K8sClient, secret *v1.Secret, ...) error
func ReplacePodAnnotation(ctx context.Context, client *k8sclient.K8sClient, pod *corev1.Pod, ...) error
func ShouldDelay(ctx context.Context, pod *corev1.Pod, Client *k8s.K8sClient) (shouldDelay bool, err error)
func WaitUtilMountReady(ctx context.Context, podName, mntPath string, timeout time.Duration) error
type ObjectMeta
- 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
type PVPair
- func GetVolumes(ctx context.Context, client *k8sclient.K8sClient, pod *corev1.Pod) (used bool, pvPairGot []PVPair, err error)
type VolumeLocks
- func NewVolumeLocks() *VolumeLocks
- func (vl *VolumeLocks) Release(volumeID string)
- func (vl *VolumeLocks) TryAcquire(volumeID string) bool

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AddPodAnnotation ¶

func AddPodAnnotation(ctx context.Context, client *k8sclient.K8sClient, pod *corev1.Pod, addAnnotations map[string]string) error

func AddPodLabel ¶

func AddPodLabel(ctx context.Context, client *k8sclient.K8sClient, pod *corev1.Pod, addLabels map[string]string) error

func AddSecretFinalizer ¶

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

func CheckForSecretFinalizer ¶

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

func CheckForSubPath ¶

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

func DelPodAnnotation ¶

func DelPodAnnotation(ctx context.Context, client *k8sclient.K8sClient, pod *corev1.Pod, delAnnotations []string) error

func DeleteResourceOfPod ¶

func DeleteResourceOfPod(pod *corev1.Pod)

func GetAllRefKeys ¶

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

func GetNamespace ¶

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

GetNamespace get juicefs pv & pvc from pod when pod namespace is empty

func IsJobCompleted ¶

func IsJobCompleted(job *batchv1.Job) bool

func IsJobFailed ¶

func IsJobFailed(job *batchv1.Job) bool

func IsJobShouldBeRecycled ¶

func IsJobShouldBeRecycled(job *batchv1.Job) bool

func IsPodError ¶

func IsPodError(pod *corev1.Pod) bool

func IsPodHasResource ¶

func IsPodHasResource(pod corev1.Pod) bool

func IsPodReady ¶

func IsPodReady(pod *corev1.Pod) bool

func IsPodResourceError ¶

func IsPodResourceError(pod *corev1.Pod) bool

func RemoveFinalizer ¶

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

func RemoveSecretFinalizer ¶

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

func ReplacePodAnnotation ¶

func ReplacePodAnnotation(ctx context.Context, client *k8sclient.K8sClient, pod *corev1.Pod, annotation map[string]string) error

func ShouldDelay ¶

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

func WaitUtilMountReady ¶

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

Types ¶

type ObjectMeta ¶

type ObjectMeta struct {
	// contains filtered or unexported fields
}

func NewObjectMeta ¶

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

func (*ObjectMeta) ResolveSecret ¶

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

func (*ObjectMeta) StringParser ¶

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

type PVPair ¶

type PVPair struct {
	PV  *corev1.PersistentVolume
	PVC *corev1.PersistentVolumeClaim
}

func GetVolumes ¶

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

GetVolumes get juicefs pv & pvc from pod

type VolumeLocks ¶

type VolumeLocks struct {
	// contains filtered or unexported fields
}

func NewVolumeLocks ¶

func NewVolumeLocks() *VolumeLocks

func (*VolumeLocks) Release ¶

func (vl *VolumeLocks) Release(volumeID string)

Release deletes the lock on volumeID.

func (*VolumeLocks) TryAcquire ¶

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

Source Files ¶

View all Source files

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