package cronjob

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

Package cronjob contains the controller for CronJob objects.

Index ¶

• func IsJobFinished(j *batch.Job) bool
• func SyncOne(sj batch.CronJob, js []batch.Job, now time.Time, jc jobControlInterface, sjc sjControlInterface, pc podControlInterface, recorder record.EventRecorder)
• type CronJobController
• func NewCronJobController(kubeClient clientset.Interface) *CronJobController
• func NewCronJobControllerFromClient(kubeClient clientset.Interface) *CronJobController
• func (jm *CronJobController) Run(stopCh <-chan struct{})
• func (jm *CronJobController) SyncAll()

Functions ¶

func IsJobFinished ¶

func IsJobFinished(j *batch.Job) bool

func SyncOne ¶

func SyncOne(sj batch.CronJob, js []batch.Job, now time.Time, jc jobControlInterface, sjc sjControlInterface, pc podControlInterface, recorder record.EventRecorder)

SyncOne reconciles a CronJob with a list of any Jobs that it created. All known jobs created by "sj" should be included in "js". The current time is passed in to facilitate testing. It has no receiver, to facilitate testing.

Types ¶

type CronJobController ¶

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

func NewCronJobController ¶

func NewCronJobController(kubeClient clientset.Interface) *CronJobController

func NewCronJobControllerFromClient ¶

func NewCronJobControllerFromClient(kubeClient clientset.Interface) *CronJobController

func (*CronJobController) Run ¶

func (jm *CronJobController) Run(stopCh <-chan struct{})

Run the main goroutine responsible for watching and syncing jobs.

func (*CronJobController) SyncAll ¶

func (jm *CronJobController) SyncAll()

SyncAll lists all the CronJobs and Jobs and reconciles them.

Source Files ¶

cronjob_controller.go doc.go injection.go utils.go