kubernetes/test/e2e/apps/ttl_after_finished.go

const dummyFinalizer …

const JobTimeout …

var _ …

func cleanupJob(ctx context.Context, f *framework.Framework, job *batchv1.Job) { … }

func testFinishedJob(ctx context.Context, f *framework.Framework) { … }

// finishTime returns finish time of the specified job.
func finishTime(finishedJob *batchv1.Job) metav1.Time { … }

// updateJobWithRetries updates job with retries.
func updateJobWithRetries(ctx context.Context, c clientset.Interface, namespace, name string, applyUpdate func(*batchv1.Job)) (job *batchv1.Job, err error) { … }

// waitForJobDeleting uses c to wait for the Job jobName in namespace ns to have
// a non-nil deletionTimestamp (i.e. being deleted).
func waitForJobDeleting(ctx context.Context, c clientset.Interface, ns, jobName string) error { … }