package scheduledjob

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

Package scheduledjob contains the controller for ScheduledJob objects.

Index ¶

• Constants
• func SyncOne(sj batch.ScheduledJob, js []batch.Job, now time.Time, jc jobControlInterface, sjc sjControlInterface, pc podControlInterface, recorder record.EventRecorder)
• type ScheduledJobController
• func NewScheduledJobController(kubeClient *client.Client) *ScheduledJobController
• func NewScheduledJobControllerFromClient(kubeClient *client.Client) *ScheduledJobController
• func (jm *ScheduledJobController) Run(stopCh <-chan struct{})
• func (jm *ScheduledJobController) SyncAll()

Constants ¶

const (
	CreatedByAnnotation = "kubernetes.io/created-by"
)

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 *client.Client) *ScheduledJobController

func NewScheduledJobControllerFromClient ¶

func NewScheduledJobControllerFromClient(kubeClient *client.Client) *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.

Source Files ¶

controller.go doc.go injection.go utils.go