util

Oct 23, 2024

Changes in this version

+ func NumJobsByRestartAttempt(ctx context.Context, k8sClient client.Client, js *jobset.JobSet) (map[int]int, error)

Aug 19, 2024

Changes in this version

+ func JobSetDeleted(ctx context.Context, k8sClient client.Client, js *jobset.JobSet, ...)

+ func RemoveJobSetFinalizer(ctx context.Context, k8sClient client.Client, js *jobset.JobSet, ...)

Apr 15, 2024

Changes in this version

+ func ExpectJobsDeletionTimestamp(ctx context.Context, c client.Client, js *jobset.JobSet, numJobs int, ...)

Feb 20, 2024

Changes in this version

+ func JobSetStartupPolicyComplete(ctx context.Context, k8sClient client.Client, js *jobset.JobSet, ...)

+ func JobSetStartupPolicyNotFinished(ctx context.Context, k8sClient client.Client, js *jobset.JobSet, ...)

Jun 29, 2023

Changes in this version

+ func DeleteNamespace(ctx context.Context, c client.Client, ns *corev1.Namespace) error

+ func JobsFromReplicatedJob(jobList *batchv1.JobList, rjob string) []*batchv1.Job

May 7, 2023

Changes in this version

+ func JobSetActive(ctx context.Context, k8sClient client.Client, js *jobset.JobSet, ...)

+ func JobSetCompleted(ctx context.Context, k8sClient client.Client, js *jobset.JobSet, ...)

+ func JobSetFailed(ctx context.Context, k8sClient client.Client, js *jobset.JobSet, ...)

+ func JobSetResumed(ctx context.Context, k8sClient client.Client, js *jobset.JobSet, ...)

+ func JobSetSuspended(ctx context.Context, k8sClient client.Client, js *jobset.JobSet, ...)

+ func NumJobs(ctx context.Context, k8sClient client.Client, js *jobset.JobSet) (int, error)

May 2, 2023

Changes in this version

+ func CheckJobSetStatus(ctx context.Context, k8sClient client.Client, js *jobset.JobSet, ...) (bool, error)

+ func CheckNumJobs(ctx context.Context, k8sClient client.Client, js *jobset.JobSet) (int, error)

+ func NumExpectedJobs(js *jobset.JobSet) int