Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for getJobFromTemplate2 (0.25 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
Back to top