Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 26 for completion_mode (0.58 sec)

  1. 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)
  2. 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)
  3. 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)
  4. pkg/registry/batch/cronjob/strategy_test.go

    		JobTemplate: batch.JobTemplateSpec{
    			Spec: batch.JobSpec{
    				Template: validPodTemplateSpec,
    			},
    		},
    	}
    )
    
    func completionModePtr(m batch.CompletionMode) *batch.CompletionMode {
    	return &m
    }
    
    func TestCronJobStrategy(t *testing.T) {
    	ctx := genericapirequest.NewDefaultContext()
    	if !Strategy.NamespaceScoped() {
    		t.Errorf("CronJob must be namespace scoped")
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 15 14:34:53 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  5. staging/src/k8s.io/api/batch/v1/types.go

    	// is possible during upgrades due to version skew, the controller
    	// skips updates for the Job.
    	// +optional
    	CompletionMode *CompletionMode `json:"completionMode,omitempty" protobuf:"bytes,9,opt,name=completionMode,casttype=CompletionMode"`
    
    	// suspend specifies whether the Job controller should create Pods or not. If
    	// a Job is created with suspend set to true, no Pods are created by the Job
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 18:37:07 UTC 2024
    - 40.6K bytes
    - Viewed (0)
  6. pkg/apis/batch/types.go

    	// +optional
    	Spec JobSpec
    }
    
    // CompletionMode specifies how Pod completions of a Job are tracked.
    type CompletionMode string
    
    const (
    	// NonIndexedCompletion is a Job completion mode. In this mode, the Job is
    	// considered complete when there have been .spec.completions
    	// successfully completed Pods. Pod completions are homologous to each other.
    	NonIndexedCompletion CompletionMode = "NonIndexed"
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 12:01:28 UTC 2024
    - 33K bytes
    - Viewed (0)
  7. pkg/controller/job/job_controller.go

    		}
    		return nil
    	}
    
    	if job.Spec.CompletionMode != nil && *job.Spec.CompletionMode != batch.NonIndexedCompletion && *job.Spec.CompletionMode != batch.IndexedCompletion {
    		jm.recorder.Event(&job, v1.EventTypeWarning, "UnknownCompletionMode", "Skipped Job sync because completion mode is unknown")
    		return nil
    	}
    
    	completionMode := getCompletionMode(&job)
    	action := metrics.JobSyncActionReconciling
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
  8. staging/src/k8s.io/api/batch/v1/types_swagger_doc_generated.go

    	"completionMode":          "completionMode specifies how Pod completions are tracked. It can be `NonIndexed` (default) or `Indexed`.\n\n`NonIndexed` means that the Job is considered complete when there have been .spec.completions successfully completed Pods. Each Pod completion...
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 12:01:28 UTC 2024
    - 27.5K bytes
    - Viewed (0)
  9. staging/src/k8s.io/api/batch/v1/generated.proto

      // index before marking this index as failed. When enabled the number of
      // failures per index is kept in the pod's
      // batch.kubernetes.io/job-index-failure-count annotation. It can only
      // be set when Job's completionMode=Indexed, and the Pod's restart
      // policy is Never. The field is immutable.
      // This field is beta-level. It can be used when the `JobBackoffLimitPerIndex`
      // feature gate is enabled (enabled by default).
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 12:01:28 UTC 2024
    - 29.1K bytes
    - Viewed (0)
  10. staging/src/k8s.io/api/testdata/v1.30.0/batch.v1.Job.json

    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 08:52:25 UTC 2024
    - 55.3K bytes
    - Viewed (0)
Back to top