- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 40 for concurrencyPolicy (0.26 sec)
-
pkg/controller/cronjob/cronjob_controllerv2_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 70.8K bytes - Viewed (0) -
pkg/apis/batch/v1beta1/defaults_test.go
if !ok { t.Errorf("%s: unexpected object: %v", name, actual) t.FailNow() } if actual.Spec.ConcurrencyPolicy != expected.Spec.ConcurrencyPolicy { t.Errorf("%s: got different concurrencyPolicy than expected: %v %v", name, actual.Spec.ConcurrencyPolicy, expected.Spec.ConcurrencyPolicy) } if *actual.Spec.Suspend != *expected.Spec.Suspend {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 08 12:14:37 UTC 2023 - 3.9K bytes - Viewed (0) -
staging/src/k8s.io/api/batch/v1beta1/types.go
// - "Replace": cancels currently running job and replaces it with a new one // +optional ConcurrencyPolicy ConcurrencyPolicy `json:"concurrencyPolicy,omitempty" protobuf:"bytes,3,opt,name=concurrencyPolicy,casttype=ConcurrencyPolicy"` // This flag tells the controller to suspend subsequent executions, it does // not apply to already started executions. Defaults to false.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 11:58:57 UTC 2023 - 7.4K bytes - Viewed (0) -
pkg/registry/batch/cronjob/strategy_test.go
}, } validCronjobSpec = batch.CronJobSpec{ Schedule: "5 5 * * ?", ConcurrencyPolicy: batch.AllowConcurrent, TimeZone: ptr.To("Asia/Shanghai"), JobTemplate: batch.JobTemplateSpec{ Spec: batch.JobSpec{ Template: validPodTemplateSpec,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 15 14:34:53 UTC 2024 - 12.2K bytes - Viewed (0) -
pkg/apis/batch/v1/defaults_test.go
if !ok { t.Errorf("%s: unexpected object: %v", name, actual) t.FailNow() } if actual.Spec.ConcurrencyPolicy != expected.Spec.ConcurrencyPolicy { t.Errorf("%s: got different concurrencyPolicy than expected: %v %v", name, actual.Spec.ConcurrencyPolicy, expected.Spec.ConcurrencyPolicy) } if *actual.Spec.Suspend != *expected.Spec.Suspend {
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/apis/batch/v1beta1/zz_generated.conversion.go
out.Schedule = in.Schedule out.TimeZone = (*string)(unsafe.Pointer(in.TimeZone)) out.StartingDeadlineSeconds = (*int64)(unsafe.Pointer(in.StartingDeadlineSeconds)) out.ConcurrencyPolicy = batch.ConcurrencyPolicy(in.ConcurrencyPolicy) out.Suspend = (*bool)(unsafe.Pointer(in.Suspend)) if err := Convert_v1beta1_JobTemplateSpec_To_batch_JobTemplateSpec(&in.JobTemplate, &out.JobTemplate, s); err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 01 20:39:47 UTC 2023 - 11.6K bytes - Viewed (0) -
pkg/apis/batch/validation/validation_test.go
}, Spec: batch.CronJobSpec{ Schedule: "* * * * ?", ConcurrencyPolicy: batch.AllowConcurrent, FailedJobsHistoryLimit: &negative, JobTemplate: batch.JobTemplateSpec{ Spec: batch.JobSpec{ Template: validPodTemplateSpec, }, }, }, }, "spec.concurrencyPolicy: Required value": { ObjectMeta: metav1.ObjectMeta{ Name: "mycronjob",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 20:49:09 UTC 2024 - 124.3K bytes - Viewed (0) -
pkg/apis/batch/fuzzer/fuzzer.go
sj.SuccessfulJobsHistoryLimit = &successfulJobsHistoryLimit failedJobsHistoryLimit := int32(c.Rand.Int31()) sj.FailedJobsHistoryLimit = &failedJobsHistoryLimit }, func(cp *batch.ConcurrencyPolicy, c fuzz.Continue) { policies := []batch.ConcurrencyPolicy{batch.AllowConcurrent, batch.ForbidConcurrent, batch.ReplaceConcurrent} *cp = policies[c.Rand.Intn(len(policies))] },
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
} } } if obj.Spec.ManualSelector == nil { obj.Spec.ManualSelector = utilpointer.Bool(false) } } func SetDefaults_CronJob(obj *batchv1.CronJob) { if obj.Spec.ConcurrencyPolicy == "" { obj.Spec.ConcurrencyPolicy = batchv1.AllowConcurrent } if obj.Spec.Suspend == nil { obj.Spec.Suspend = utilpointer.Bool(false) } if obj.Spec.SuccessfulJobsHistoryLimit == 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) -
staging/src/k8s.io/api/batch/v1/types.go
// - "Replace": cancels currently running job and replaces it with a new one // +optional ConcurrencyPolicy ConcurrencyPolicy `json:"concurrencyPolicy,omitempty" protobuf:"bytes,3,opt,name=concurrencyPolicy,casttype=ConcurrencyPolicy"` // This flag tells the controller to suspend subsequent executions, it does // not apply to already started executions. Defaults to false.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 18:37:07 UTC 2024 - 40.6K bytes - Viewed (0)