Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 52 for completion_mode (0.17 sec)

  1. pkg/controller/job/metrics/metrics.go

    			StabilityLevel: metrics.STABLE,
    			Buckets:        metrics.ExponentialBuckets(0.004, 2, 15),
    		},
    		[]string{"completion_mode", "result", "action"},
    	)
    	// JobSyncNum tracks the number of Job syncs. Possible label values:
    	//   completion_mode: Indexed, NonIndexed
    	//   result:          success, error
    	//   action:          reconciling, tracking, pods_created, pods_deleted
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 05 17:25:15 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  2. 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,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 14 14:38:42 UTC 2023
    - 3.6K bytes
    - Viewed (0)
  3. pkg/apis/batch/v1/defaults_test.go

    				} else {
    					t.Errorf("Unexpected equality: %v", actual.Labels)
    				}
    			}
    			if diff := cmp.Diff(expected.Spec.CompletionMode, actual.Spec.CompletionMode); diff != "" {
    				t.Errorf("Unexpected CompletionMode (-want,+got):\n%s", diff)
    			}
    			if diff := cmp.Diff(expected.Spec.PodReplacementPolicy, actual.Spec.PodReplacementPolicy); diff != "" {
    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

    				ObjectMeta: validObjectMeta,
    				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{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 101.5K bytes
    - Viewed (0)
  5. staging/src/k8s.io/client-go/applyconfigurations/batch/v1/jobspec.go

    	TTLSecondsAfterFinished *int32                                    `json:"ttlSecondsAfterFinished,omitempty"`
    	CompletionMode          *batchv1.CompletionMode                   `json:"completionMode,omitempty"`
    	Suspend                 *bool                                     `json:"suspend,omitempty"`
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 20:49:09 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  6. pkg/apis/batch/validation/validation_test.go

    					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,
    				Field: "spec.completionMode",
    			},
    		},
    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/api/job/warnings.go

    )
    
    // WarningsForJobSpec produces warnings for fields in the JobSpec.
    func WarningsForJobSpec(ctx context.Context, path *field.Path, spec, oldSpec *batch.JobSpec) []string {
    	var warnings []string
    	if spec.CompletionMode != nil && *spec.CompletionMode == batch.IndexedCompletion {
    		completions := ptr.Deref(spec.Completions, 0)
    		parallelism := ptr.Deref(spec.Parallelism, 0)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jan 24 11:44:07 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  8. pkg/apis/batch/validation/validation.go

    		}
    	}
    	if spec.CompletionMode != nil {
    		if *spec.CompletionMode != batch.NonIndexedCompletion && *spec.CompletionMode != batch.IndexedCompletion {
    			allErrs = append(allErrs, field.NotSupported(fldPath.Child("completionMode"), spec.CompletionMode, []batch.CompletionMode{batch.NonIndexedCompletion, batch.IndexedCompletion}))
    		}
    		if *spec.CompletionMode == batch.IndexedCompletion {
    			if spec.Completions == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 16:43:24 UTC 2024
    - 51.2K bytes
    - Viewed (0)
  9. pkg/apis/batch/v1/defaults.go

    			obj.Spec.BackoffLimit = utilpointer.Int32(6)
    		}
    	}
    	labels := obj.Spec.Template.Labels
    	if labels != nil && len(obj.Labels) == 0 {
    		obj.Labels = labels
    	}
    	if obj.Spec.CompletionMode == nil {
    		mode := batchv1.NonIndexedCompletion
    		obj.Spec.CompletionMode = &mode
    	}
    	if obj.Spec.Suspend == nil {
    		obj.Spec.Suspend = utilpointer.Bool(false)
    	}
    	if obj.Spec.PodFailurePolicy != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Oct 11 20:51:40 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  10. pkg/controller/job/job_controller_test.go

    						"foo": "bar",
    					},
    				},
    				Spec: v1.PodSpec{
    					Containers: []v1.Container{
    						{Image: "foo/bar"},
    					},
    				},
    			},
    		},
    	}
    	if completionMode != "" {
    		j.Spec.CompletionMode = &completionMode
    	}
    	// Special case: -1 for either completions or parallelism means leave nil (negative is not allowed
    	// in practice by validation.
    	if completions >= 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
Back to top