kubernetes: k8s.io/kubernetes/test/e2e/framework/job Index | Files

package job

import "k8s.io/kubernetes/test/e2e/framework/job"

Index

Package Files

const.go fixtures.go rest.go wait.go

Constants

❖
const (
    // JobTimeout is how long to wait for a job to finish.
    JobTimeout = 15 * time.Minute

    // JobSelectorKey is a job selector name
    JobSelectorKey = "job"
)

func CreateJob Uses

❖
func CreateJob(c clientset.Interface, ns string, job *batchv1.Job) (*batchv1.Job, error)

CreateJob uses c to create job in namespace ns. If the returned error is nil, the returned Job is valid and has been created.

func DeleteJob Uses

❖
func DeleteJob(c clientset.Interface, ns, name string) error

DeleteJob uses c to delete the Job named name in namespace ns. If the returned error is nil, the Job has been deleted.

func EnsureAllJobPodsRunning Uses

❖
func EnsureAllJobPodsRunning(c clientset.Interface, ns, jobName string, parallelism int32) error

EnsureAllJobPodsRunning uses c to check in the Job named jobName in ns is running, returning an error if the expected parallelism is not satisfied.

func FinishTime Uses

❖
func FinishTime(finishedJob *batchv1.Job) metav1.Time

FinishTime returns finish time of the specified job.

func GetJob Uses

❖
func GetJob(c clientset.Interface, ns, name string) (*batchv1.Job, error)

GetJob uses c to get the Job in namespace ns named name. If the returned error is nil, the returned Job is valid.

func GetJobPods Uses

❖
func GetJobPods(c clientset.Interface, ns, jobName string) (*v1.PodList, error)

GetJobPods returns a list of Pods belonging to a Job.

func NewTestJob Uses

❖
func NewTestJob(behavior, name string, rPol v1.RestartPolicy, parallelism, completions int32, activeDeadlineSeconds *int64, backoffLimit int32) *batchv1.Job

NewTestJob returns a Job which does one of several testing behaviors. notTerminate starts a Job that will run effectively forever. fail starts a Job that will fail immediately. succeed starts a Job that will succeed immediately. randomlySucceedOrFail starts a Job that will succeed or fail randomly. failOnce fails the Job the first time it is run and succeeds subsequently. name is the Name of the Job. RestartPolicy indicates the restart policy of the containers in which the Pod is running. Parallelism is the Job's parallelism, and completions is the Job's required number of completions.

func UpdateJob Uses

❖
func UpdateJob(c clientset.Interface, ns string, job *batchv1.Job) (*batchv1.Job, error)

UpdateJob uses c to updated job in namespace ns. If the returned error is nil, the returned Job is valid and has been updated.

func UpdateJobWithRetries Uses

❖
func UpdateJobWithRetries(c clientset.Interface, namespace, name string, applyUpdate func(*batchv1.Job)) (job *batchv1.Job, err error)

UpdateJobWithRetries updates job with retries.

func WaitForAllJobPodsGone Uses

❖
func WaitForAllJobPodsGone(c clientset.Interface, ns, jobName string) error

WaitForAllJobPodsGone waits for all pods for the Job named jobName in namespace ns to be deleted.

func WaitForAllJobPodsRunning Uses

❖
func WaitForAllJobPodsRunning(c clientset.Interface, ns, jobName string, parallelism int32) error

WaitForAllJobPodsRunning wait for all pods for the Job named JobName in namespace ns to become Running. Only use when pods will run for a long time, or it will be racy.

func WaitForJobComplete Uses

❖
func WaitForJobComplete(c clientset.Interface, ns, jobName string, completions int32) error

WaitForJobComplete uses c to wait for completions to complete for the Job jobName in namespace ns.

func WaitForJobDeleting Uses

❖
func WaitForJobDeleting(c clientset.Interface, ns, jobName string) error

WaitForJobDeleting uses c to wait for the Job jobName in namespace ns to have a non-nil deletionTimestamp (i.e. being deleted).

func WaitForJobFailure Uses

❖
func WaitForJobFailure(c clientset.Interface, ns, jobName string, timeout time.Duration, reason string) error

WaitForJobFailure uses c to wait for up to timeout for the Job named jobName in namespace ns to fail.

func WaitForJobFinish Uses

❖
func WaitForJobFinish(c clientset.Interface, ns, jobName string) error

WaitForJobFinish uses c to wait for the Job jobName in namespace ns to finish (either Failed or Complete).

func WaitForJobGone Uses

❖
func WaitForJobGone(c clientset.Interface, ns, jobName string, timeout time.Duration) error

WaitForJobGone uses c to wait for up to timeout for the Job named jobName in namespace ns to be removed.

Package job imports 12 packages (graph) and is imported by 126 packages. Updated 2019-09-30. Refresh now. Tools for package owners.