- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 44 for ConcurrencyPolicy (0.53 sec)
-
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) -
staging/src/k8s.io/api/batch/v1beta1/generated.pb.go
if m.Suspend != nil { i-- if *m.Suspend { dAtA[i] = 1 } else { dAtA[i] = 0 } i-- dAtA[i] = 0x20 } i -= len(m.ConcurrencyPolicy) copy(dAtA[i:], m.ConcurrencyPolicy) i = encodeVarintGenerated(dAtA, i, uint64(len(m.ConcurrencyPolicy))) i-- dAtA[i] = 0x1a if m.StartingDeadlineSeconds != nil { i = encodeVarintGenerated(dAtA, i, uint64(*m.StartingDeadlineSeconds)) i--
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:37 UTC 2024 - 40.2K bytes - Viewed (0) -
pkg/apis/batch/v1/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_v1_JobTemplateSpec_To_batch_JobTemplateSpec(&in.JobTemplate, &out.JobTemplate, s); err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 20:49:09 UTC 2024 - 36.6K bytes - Viewed (0) -
pkg/apis/batch/types.go
FailedJobsHistoryLimit *int32 } // ConcurrencyPolicy describes how the job will be handled. // Only one of the following concurrent policies may be specified. // If none of the following policies is specified, the default one // is AllowConcurrent. type ConcurrencyPolicy string const ( // AllowConcurrent allows CronJobs to run concurrently. AllowConcurrent ConcurrencyPolicy = "Allow"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 12:01:28 UTC 2024 - 33K bytes - Viewed (0) -
pkg/registry/batch/cronjob/storage/storage_test.go
return &batch.CronJob{ ObjectMeta: metav1.ObjectMeta{ Name: "foo", Namespace: metav1.NamespaceDefault, }, Spec: batch.CronJobSpec{ Schedule: "* * * * ?", ConcurrencyPolicy: batch.AllowConcurrent, JobTemplate: batch.JobTemplateSpec{ Spec: batch.JobSpec{ Template: api.PodTemplateSpec{ Spec: api.PodSpec{ RestartPolicy: api.RestartPolicyOnFailure,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 12 20:55:35 UTC 2019 - 4.4K bytes - Viewed (0) -
pkg/apis/batch/validation/validation.go
} func validateConcurrencyPolicy(concurrencyPolicy *batch.ConcurrencyPolicy, fldPath *field.Path) field.ErrorList { allErrs := field.ErrorList{} switch *concurrencyPolicy { case batch.AllowConcurrent, batch.ForbidConcurrent, batch.ReplaceConcurrent: break case "": allErrs = append(allErrs, field.Required(fldPath, "")) default:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 16:43:24 UTC 2024 - 51.2K bytes - Viewed (0) -
staging/src/k8s.io/api/batch/v1beta1/generated.proto
// - "Forbid": forbids concurrent runs, skipping next run if previous run hasn't finished yet; // - "Replace": cancels currently running job and replaces it with a new one // +optional optional string concurrencyPolicy = 3; // This flag tells the controller to suspend subsequent executions, it does // not apply to already started executions. Defaults to false. // +optional optional bool suspend = 4;
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 28 15:34:11 UTC 2024 - 5.8K bytes - Viewed (0) -
common-protos/k8s.io/api/batch/v1beta1/generated.proto
// - "Forbid": forbids concurrent runs, skipping next run if previous run hasn't finished yet; // - "Replace": cancels currently running job and replaces it with a new one // +optional optional string concurrencyPolicy = 3; // This flag tells the controller to suspend subsequent executions, it does // not apply to already started executions. Defaults to false. // +optional optional bool suspend = 4;
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 5.7K bytes - Viewed (0)