import "k8s.io/kubernetes/pkg/controller/job"
Package job contains logic for watching and synchronizing jobs.
doc.go job_controller.go utils.go
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 )
IsJobFinished checks whether the given Job has finished execution. It does not discriminate between successful and failed terminations.
type Controller struct {
// contains filtered or unexported fields
}
Controller ensures that all Job objects have corresponding pods to run their configured workload.
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 (jm *Controller) Run(workers int, stopCh <-chan struct{})
Run the main goroutine responsible for watching and syncing jobs.
Path | Synopsis |
---|---|
config | |
config/v1alpha1 |
Package job imports 28 packages (graph) and is imported by 242 packages. Updated 2021-01-19. Refresh now. Tools for package owners.