- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for NonIndexedCompletion (0.2 sec)
-
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) -
pkg/api/job/warnings_test.go
}{ "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) -
pkg/controller/job/job_controller_test.go
jm.podStoreSynced = alwaysReady jm.jobStoreSynced = alwaysReady job1 := newJob(1, 1, 6, batch.NonIndexedCompletion) job1.Name = "job1" job2 := newJob(1, 1, 6, batch.NonIndexedCompletion) job2.Name = "job2" job3 := newJob(1, 1, 6, batch.NonIndexedCompletion) job3.Name = "job3" job3.Spec.Selector.MatchLabels = map[string]string{"other": "labels"}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0) -
pkg/apis/batch/fuzzer/fuzzer.go
backoffLimit := int32(c.Rand.Int31()) j.Completions = &completions j.Parallelism = ¶llelism j.BackoffLimit = &backoffLimit j.ManualSelector = pointer.Bool(c.RandBool()) mode := batch.NonIndexedCompletion if c.RandBool() { mode = batch.IndexedCompletion j.BackoffLimitPerIndex = pointer.Int32(c.Rand.Int31()) j.MaxFailedIndexes = pointer.Int32(c.Rand.Int31()) } if c.RandBool() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 05 17:25:15 UTC 2024 - 3K bytes - Viewed (0) -
pkg/apis/batch/v1/defaults.go
} } 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 { for _, rule := range obj.Spec.PodFailurePolicy.Rules {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 11 20:51:40 UTC 2023 - 3.1K bytes - Viewed (0) -
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) -
pkg/registry/batch/job/strategy_test.go
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) -
pkg/controller/job/indexed_job_utils.go
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) -
pkg/registry/batch/job/strategy.go
// below .spec.completions, however, this it is ok if the // status.completedIndexes go beyond completions just after a user scales // down a Job. isIndexed := ptr.Deref(newJob.Spec.CompletionMode, batch.NonIndexedCompletion) == batch.IndexedCompletion isJobFinishedChanged := batchvalidation.IsJobFinished(oldJob) != batchvalidation.IsJobFinished(newJob)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 16:43:24 UTC 2024 - 18.4K bytes - Viewed (0) -
pkg/apis/batch/types.go
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" // IndexedCompletion is a Job completion mode. In this mode, the Pods of a
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 12:01:28 UTC 2024 - 33K bytes - Viewed (0)