Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for completionModeStr (0.31 sec)

  1. pkg/controller/job/indexed_job_utils.go

    }
    
    func (bci byCompletionIndex) Swap(i, j int) {
    	bci[i], bci[j] = bci[j], bci[i]
    }
    
    func (bci byCompletionIndex) Len() int {
    	return len(bci)
    }
    
    func completionModeStr(job *batch.Job) string {
    	if job.Spec.CompletionMode != nil {
    		return string(*job.Spec.CompletionMode)
    	}
    	return string(batch.NonIndexedCompletion)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 21 00:44:53 UTC 2023
    - 17.5K bytes
    - Viewed (0)
  2. pkg/controller/job/job_controller.go

    		if list[i].Type == cType {
    			return &list[i]
    		}
    	}
    	return nil
    }
    
    func recordJobPodFinished(logger klog.Logger, job *batch.Job, oldCounters batch.JobStatus) {
    	completionMode := completionModeStr(job)
    	var diff int
    
    	// Updating succeeded metric must be handled differently
    	// for Indexed Jobs to handle the case where the job has
    	// been scaled down by reducing completions & parallelism
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
  3. pkg/controller/job/job_controller_test.go

    			if rmFinalizers != tc.wantRmFinalizers {
    				t.Errorf("Removed %d finalizers, want %d", rmFinalizers, tc.wantRmFinalizers)
    			}
    			if tc.wantErr == nil {
    				completionMode := completionModeStr(job)
    				v, err := metricstestutil.GetCounterMetricValue(metrics.JobPodsFinished.WithLabelValues(completionMode, metrics.Succeeded))
    				if err != nil {
    					t.Fatalf("Obtaining succeeded job_pods_finished_total: %v", err)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
  4. pkg/apis/batch/v1/defaults_test.go

    				},
    			},
    			expected: &batchv1.Job{
    				Spec: batchv1.JobSpec{
    					Completions:    pointer.Int32(1),
    					Parallelism:    pointer.Int32(1),
    					BackoffLimit:   pointer.Int32(6),
    					CompletionMode: completionModePtr(batchv1.NonIndexedCompletion),
    					Suspend:        pointer.Bool(false),
    					ManualSelector: pointer.Bool(false),
    					PodFailurePolicy: &batchv1.PodFailurePolicy{
    						Rules: []batchv1.PodFailurePolicyRule{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 20.8K bytes
    - Viewed (0)
  5. pkg/api/job/warnings_test.go

    		wantWarningsCount int
    	}{
    		"valid NonIndexed": {
    			spec: &batch.JobSpec{
    				CompletionMode: completionModePtr(batch.NonIndexedCompletion),
    				Template:       validPodTemplate,
    			},
    		},
    		"NondIndexed with high completions and parallelism": {
    			spec: &batch.JobSpec{
    				CompletionMode: completionModePtr(batch.NonIndexedCompletion),
    				Template:       validPodTemplate,
    				Parallelism:    pointer.Int32(1_000_000_000),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 14 14:38:42 UTC 2023
    - 3.6K bytes
    - Viewed (0)
  6. pkg/apis/batch/validation/validation_test.go

    					Selector:       validGeneratedSelector,
    					Template:       validPodTemplateSpecForGenerated,
    					CompletionMode: completionModePtr(batch.IndexedCompletion),
    					Completions:    pointer.Int32(2),
    				},
    			},
    			update: func(job *batch.Job) {
    				job.Spec.CompletionMode = completionModePtr(batch.NonIndexedCompletion)
    			},
    			err: &field.Error{
    				Type:  field.ErrorTypeInvalid,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 20:49:09 UTC 2024
    - 124.3K bytes
    - Viewed (0)
  7. pkg/registry/batch/job/strategy_test.go

    				Spec: batch.JobSpec{
    					Completions:    ptr.To[int32](5),
    					CompletionMode: completionModePtr(batch.NonIndexedCompletion),
    				},
    			},
    			newJob: &batch.Job{
    				ObjectMeta: validObjectMeta,
    				Spec: batch.JobSpec{
    					Completions:    ptr.To[int32](5),
    					CompletionMode: completionModePtr(batch.NonIndexedCompletion),
    				},
    				Status: batch.JobStatus{
    					StartTime:        &now,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 101.5K bytes
    - Viewed (0)
  8. pkg/registry/batch/cronjob/strategy_test.go

    		ConcurrencyPolicy: batch.AllowConcurrent,
    		TimeZone:          ptr.To("Asia/Shanghai"),
    		JobTemplate: batch.JobTemplateSpec{
    			Spec: batch.JobSpec{
    				Template:       validPodTemplateSpec,
    				CompletionMode: completionModePtr(batch.IndexedCompletion),
    				Completions:    ptr.To[int32](10),
    				Parallelism:    ptr.To[int32](10),
    			},
    		},
    	}
    	cronjobSpecWithTZinSchedule = batch.CronJobSpec{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 15 14:34:53 UTC 2024
    - 12.2K bytes
    - Viewed (0)
Back to top