job

Documentation

Overview

Package job contains logic for watching and synchronizing jobs.

Index

• func IsJobFinished(j *batch.Job) bool
• type JobController
  • func NewJobController(podInformer cache.SharedIndexInformer, kubeClient clientset.Interface) *JobController
  • func NewJobControllerFromClient(kubeClient clientset.Interface, resyncPeriod controller.ResyncPeriodFunc) *JobController
  • func (jm *JobController) Run(workers int, stopCh <-chan struct{})

Functions

func IsJobFinished

func IsJobFinished(j *batch.Job) bool

Types

type JobController

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

func NewJobController

func NewJobController(podInformer cache.SharedIndexInformer, kubeClient clientset.Interface) *JobController

func NewJobControllerFromClient

func NewJobControllerFromClient(kubeClient clientset.Interface, resyncPeriod controller.ResyncPeriodFunc) *JobController

func (*JobController) Run

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

Run the main goroutine responsible for watching and syncing jobs.