util

func DeleteNamespace ¶ added in v0.2.0

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 ¶ added in v0.5.0

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 ¶ added in v0.1.3

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

func JobSetCompleted ¶ added in v0.1.3

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

func JobSetFailed ¶ added in v0.1.3

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

func JobSetResumed ¶ added in v0.1.3

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

func JobSetStartupPolicyComplete ¶ added in v0.4.0

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

func JobSetStartupPolicyNotFinished ¶ added in v0.4.0

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

func JobSetSuspended ¶ added in v0.1.3

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

func JobsFromReplicatedJob ¶ added in v0.2.0

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

func NumExpectedJobs ¶

func NumExpectedJobs(js *jobset.JobSet) int

func NumJobs ¶ added in v0.1.3

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