- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for getJobFromTemplate2 (0.25 sec)
-
pkg/controller/cronjob/utils.go
for k, v := range template.Annotations { a[k] = v } return a } // getJobFromTemplate2 makes a Job from a CronJob. It converts the unix time into minutes from // epoch time and concatenates that to the job name, because the cronjob_controller v2 has the lowest // granularity of 1 minute for scheduling job. func getJobFromTemplate2(cj *batchv1.CronJob, scheduledTime time.Time) (*batchv1.Job, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 10.7K bytes - Viewed (0) -
pkg/controller/cronjob/utils_test.go
featuregatetesting "k8s.io/component-base/featuregate/testing" "k8s.io/klog/v2/ktesting" "k8s.io/kubernetes/pkg/features" "k8s.io/utils/ptr" ) func TestGetJobFromTemplate2(t *testing.T) { // getJobFromTemplate2() needs to take the job template and copy the labels and annotations // and other fields, and add a created-by reference. var ( one int64 = 1 no bool timeZoneUTC = "UTC"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 22.8K bytes - Viewed (0) -
pkg/controller/cronjob/cronjob_controllerv2_test.go
cj.Status.LastScheduleTime = &metav1.Time{Time: justAfterThePriorHour()} if !tc.lastScheduleTime.IsZero() { cj.Status.LastScheduleTime = &metav1.Time{Time: tc.lastScheduleTime} } job, err = getJobFromTemplate2(&cj, tc.jobCreationTime) if err != nil { t.Fatalf("%s: unexpected error creating a job from template: %v", name, err) } job.UID = "1234" job.Namespace = cj.Namespace
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 70.8K bytes - Viewed (0) -
pkg/controller/cronjob/cronjob_controllerv2.go
return nil, updateStatus, fmt.Errorf("could not replace job %s/%s", job.Namespace, job.Name) } updateStatus = true } } jobAlreadyExists := false jobReq, err := getJobFromTemplate2(cronJob, *scheduledTime) if err != nil { logger.Error(err, "Unable to make Job from template", "cronjob", klog.KObj(cronJob)) return nil, updateStatus, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 29.2K bytes - Viewed (0)