util

Documentation

Index

• func DeleteNamespace(ctx context.Context, c client.Client, ns *corev1.Namespace) error
• func ExpectJobsDeletionTimestamp(ctx context.Context, c client.Client, js *jobset.JobSet, numJobs int, ...)
• func JobSetActive(ctx context.Context, k8sClient client.Client, js *jobset.JobSet, ...)
• func JobSetCompleted(ctx context.Context, k8sClient client.Client, js *jobset.JobSet, ...)
• func JobSetDeleted(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 JobSetStartupPolicyComplete(ctx context.Context, k8sClient client.Client, js *jobset.JobSet, ...)
• func JobSetStartupPolicyNotFinished(ctx context.Context, k8sClient client.Client, js *jobset.JobSet, ...)
• func JobSetSuspended(ctx context.Context, k8sClient client.Client, js *jobset.JobSet, ...)
• func JobsFromReplicatedJob(jobList *batchv1.JobList, rjob string) []*batchv1.Job
• func NumExpectedJobs(js *jobset.JobSet) int
• func NumJobs(ctx context.Context, k8sClient client.Client, js *jobset.JobSet) (int, error)
• func NumJobsByRestartAttempt(ctx context.Context, k8sClient client.Client, js *jobset.JobSet) (map[int]int, error)
• func RemoveJobSetFinalizer(ctx context.Context, k8sClient client.Client, js *jobset.JobSet, ...)

Functions

func DeleteNamespace

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

DeleteNamespace deletes all objects the tests typically create in the namespace.

func ExpectJobsDeletionTimestamp

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

ExpectJobsDeletionTimestamp checks that the jobs' deletion timestamp is set or not set for the provided number of jobs.

func JobSetActive

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

func JobSetCompleted

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

func JobSetDeleted

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

func JobSetFailed

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

func JobSetResumed

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

func JobSetStartupPolicyComplete

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

func JobSetStartupPolicyNotFinished

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

func JobSetSuspended

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

func JobsFromReplicatedJob

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

func NumExpectedJobs

func NumExpectedJobs(js *jobset.JobSet) int

func NumJobs

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

func NumJobsByRestartAttempt

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

func RemoveJobSetFinalizer

func RemoveJobSetFinalizer(ctx context.Context, k8sClient client.Client, js *jobset.JobSet, finalizer string, timeout time.Duration)

RemoveJobSetFinalizer removes the provided finalizer from the jobset and updates it.