Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for completionModeStr (0.23 sec)

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