scheduledjob

Documentation

Overview

Package scheduledjob contains the controller for ScheduledJob objects.

Index

• func SyncOne(sj batch.ScheduledJob, js []batch.Job, now time.Time, jc jobControlInterface, ...)
• type ScheduledJobController
  • func NewScheduledJobController(kubeClient clientset.Interface) *ScheduledJobController
  • func NewScheduledJobControllerFromClient(kubeClient clientset.Interface) *ScheduledJobController
  • func (jm *ScheduledJobController) Run(stopCh <-chan struct{})
  • func (jm *ScheduledJobController) SyncAll()

Functions

func SyncOne

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

SyncOne reconciles a ScheduledJob 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 ScheduledJobController

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

func NewScheduledJobController

func NewScheduledJobController(kubeClient clientset.Interface) *ScheduledJobController

func NewScheduledJobControllerFromClient

func NewScheduledJobControllerFromClient(kubeClient clientset.Interface) *ScheduledJobController

func (*ScheduledJobController) Run

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

Run the main goroutine responsible for watching and syncing jobs.

func (*ScheduledJobController) SyncAll

func (jm *ScheduledJobController) SyncAll()

SyncAll lists all the ScheduledJobs and Jobs and reconciles them.