cronjob

Documentation

Overview

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, ...)
• 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.