resource

package

Go to main page

Versions in this module

v0

v0.26.4

Jan 26, 2025

v0.26.3

Jan 22, 2025

v0.26.2

Jan 21, 2025

v0.26.1

Jan 17, 2025

v0.26.0

Jan 9, 2025

Changes in this version

+ func CanUpgrade(pod corev1.Pod, recreate bool) (bool, string, error)

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

+ func CreateOrUpdateSecret(ctx context.Context, client *k8sclient.K8sClient, secret *corev1.Secret) error

+ func FilterPodsToUpgrade(podLists corev1.PodList, recreate bool) []corev1.Pod

+ func GetSecretNameByUniqueId(uniqueId string) string

+ func GetUpgradeUUID(pod *corev1.Pod) string

v0.25.2

Nov 4, 2024

Changes in this version

+ func FilterVars[T any](vars []T, excludeName string, getName func(T) string) []T

+ func MergeEnvs(pod *corev1.Pod, env []corev1.EnvVar)

+ func MergeMountOptions(pod *corev1.Pod, jfsSetting *config.JfsSetting)

+ func MergeVolumes(pod *corev1.Pod, jfsSetting *config.JfsSetting)

v0.25.1

Oct 21, 2024

Changes in this version

+ func GetUniqueId(pod corev1.Pod) string

v0.25.0

Sep 30, 2024

Changes in this version

+ func GetCommPath(basePath string, pod corev1.Pod) (string, error)

+ func IsPodComplete(pod *corev1.Pod) bool

+ func SmoothUpgrade(client kubernetes.Interface, cfg *rest.Config, h Handler, ...) error

+ func WaitForJobComplete(ctx context.Context, client *k8s.K8sClient, name string, timeout time.Duration) error

v0.24.7

Sep 4, 2024

v0.24.6

Aug 23, 2024

Changes in this version

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

+ func GetPVWithVolumeHandleOrAppInfo(ctx context.Context, client *k8s.K8sClient, volumeHandle string, ...) (*corev1.PersistentVolume, *corev1.PersistentVolumeClaim, error)

v0.24.5

Aug 7, 2024

Changes in this version

+ const EndOfText

+ const EndOfTransmission

+ func DownloadPodFile(client kubernetes.Interface, cfg *rest.Config, writer io.Writer, ...) error

+ func ExecInPod(client kubernetes.Interface, cfg *rest.Config, h Handler, ...) error

+ func NewTerminalSession(ctx context.Context, conn *websocket.Conn, endOfTransmission string) *terminalSession

+ type Handler interface

v0.24.4

Jul 18, 2024

v0.24.3

Jul 17, 2024

Changes in this version

+ 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 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

+ 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)

+ type VolumeLocks struct

+ func NewVolumeLocks() *VolumeLocks

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

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

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