resource

package

Go to main page

Versions in this module

v0

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