var controllerKind … var nextScheduleDelta … type ControllerV2 … // NewControllerV2 creates and initializes a new Controller. func NewControllerV2(ctx context.Context, jobInformer batchv1informers.JobInformer, cronJobsInformer batchv1informers.CronJobInformer, kubeClient clientset.Interface) (*ControllerV2, error) { … } // Run starts the main goroutine responsible for watching and syncing jobs. func (jm *ControllerV2) Run(ctx context.Context, workers int) { … } func (jm *ControllerV2) worker(ctx context.Context) { … } func (jm *ControllerV2) processNextWorkItem(ctx context.Context) bool { … } func (jm *ControllerV2) sync(ctx context.Context, cronJobKey string) (*time.Duration, error) { … } // resolveControllerRef returns the controller referenced by a ControllerRef, // or nil if the ControllerRef could not be resolved to a matching controller // of the correct Kind. func (jm *ControllerV2) resolveControllerRef(namespace string, controllerRef *metav1.OwnerReference) *batchv1.CronJob { … } func (jm *ControllerV2) getJobsToBeReconciled(cronJob *batchv1.CronJob) ([]*batchv1.Job, error) { … } // When a job is created, enqueue the controller that manages it and update it's expectations. func (jm *ControllerV2) addJob(obj interface{ … } // updateJob figures out what CronJob(s) manage a Job when the Job // is updated and wake them up. If the anything of the Job have changed, we need to // awaken both the old and new CronJob. old and cur must be *batchv1.Job // types. func (jm *ControllerV2) updateJob(old, cur interface{ … } func (jm *ControllerV2) deleteJob(obj interface{ … } func (jm *ControllerV2) enqueueController(obj interface{ … } func (jm *ControllerV2) enqueueControllerAfter(obj interface{ … } // updateCronJob re-queues the CronJob for next scheduled time if there is a // change in spec.schedule otherwise it re-queues it now func (jm *ControllerV2) updateCronJob(logger klog.Logger, old interface{ … } // syncCronJob reconciles a CronJob with a list of any Jobs that it created. // All known jobs created by "cronJob" should be included in "jobs". // The current time is passed in to facilitate testing. // It returns a bool to indicate an update to api-server is needed func (jm *ControllerV2) syncCronJob( ctx context.Context, cronJob *batchv1.CronJob, jobs []*batchv1.Job) (*time.Duration, bool, error) { … } func getJobName(cj *batchv1.CronJob, scheduledTime time.Time) string { … } // cleanupFinishedJobs cleanups finished jobs created by a CronJob // It returns a bool to indicate an update to api-server is needed func (jm *ControllerV2) cleanupFinishedJobs(ctx context.Context, cj *batchv1.CronJob, js []*batchv1.Job) bool { … } func (jm *ControllerV2) getFinishedStatus(j *batchv1.Job) (bool, batchv1.JobConditionType) { … } // removeOldestJobs removes the oldest jobs from a list of jobs func (jm *ControllerV2) removeOldestJobs(ctx context.Context, cj *batchv1.CronJob, js []*batchv1.Job, maxJobs int32) bool { … } // deleteJob reaps a job, deleting the job, the pods and the reference in the active list func deleteJob(logger klog.Logger, cj *batchv1.CronJob, job *batchv1.Job, jc jobControlInterface, recorder record.EventRecorder) bool { … } func getRef(object runtime.Object) (*corev1.ObjectReference, error) { … } func formatSchedule(cj *batchv1.CronJob, recorder record.EventRecorder) string { … }
Codebase Browser
kubernetes