package job

import "k8s.io/kubernetes/pkg/controller/job"

Package job contains logic for watching and synchronizing jobs.

Index ¶

• Variables
• func IsJobFinished(j *batch.Job) bool
• type Controller
• func NewController(podInformer coreinformers.PodInformer, jobInformer batchinformers.JobInformer, kubeClient clientset.Interface) *Controller
• func (jm *Controller) Run(workers int, stopCh <-chan struct{})

Package Files ¶

doc.go job_controller.go utils.go

Variables ¶

var (
    // DefaultJobBackOff is the default backoff period, exported for the e2e test
    DefaultJobBackOff = 10 * time.Second
    // MaxJobBackOff is the max backoff period, exported for the e2e test
    MaxJobBackOff = 360 * time.Second
)

func IsJobFinished ¶ Uses

func IsJobFinished(j *batch.Job) bool

IsJobFinished checks whether the given Job has finished execution. It does not discriminate between successful and failed terminations.

type Controller ¶ Uses

type Controller struct {
    // contains filtered or unexported fields
}

Controller ensures that all Job objects have corresponding pods to run their configured workload.

func NewController ¶ Uses

func NewController(podInformer coreinformers.PodInformer, jobInformer batchinformers.JobInformer, kubeClient clientset.Interface) *Controller

NewController creates a new Job controller that keeps the relevant pods in sync with their corresponding Job objects.

func (*Controller) Run ¶ Uses

func (jm *Controller) Run(workers int, stopCh <-chan struct{})

Run the main goroutine responsible for watching and syncing jobs.

Directories ¶