Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for concurrencyPolicy (0.28 sec)

  1. 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)
  2. staging/src/k8s.io/client-go/applyconfigurations/batch/v1/cronjobspec.go

    	TimeZone                   *string                            `json:"timeZone,omitempty"`
    	StartingDeadlineSeconds    *int64                             `json:"startingDeadlineSeconds,omitempty"`
    	ConcurrencyPolicy          *v1.ConcurrencyPolicy              `json:"concurrencyPolicy,omitempty"`
    	Suspend                    *bool                              `json:"suspend,omitempty"`
    	JobTemplate                *JobTemplateSpecApplyConfiguration `json:"jobTemplate,omitempty"`
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 29 16:40:46 UTC 2022
    - 5.3K bytes
    - Viewed (0)
  3. 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)
  4. staging/src/k8s.io/client-go/applyconfigurations/batch/v1beta1/cronjobspec.go

    	TimeZone                   *string                            `json:"timeZone,omitempty"`
    	StartingDeadlineSeconds    *int64                             `json:"startingDeadlineSeconds,omitempty"`
    	ConcurrencyPolicy          *v1beta1.ConcurrencyPolicy         `json:"concurrencyPolicy,omitempty"`
    	Suspend                    *bool                              `json:"suspend,omitempty"`
    	JobTemplate                *JobTemplateSpecApplyConfiguration `json:"jobTemplate,omitempty"`
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 29 16:40:46 UTC 2022
    - 5.3K bytes
    - Viewed (0)
  5. pkg/apis/batch/v1beta1/defaults.go

    )
    
    func addDefaultingFuncs(scheme *runtime.Scheme) error {
    	return RegisterDefaults(scheme)
    }
    
    func SetDefaults_CronJob(obj *batchv1beta1.CronJob) {
    	if obj.Spec.ConcurrencyPolicy == "" {
    		obj.Spec.ConcurrencyPolicy = batchv1beta1.AllowConcurrent
    	}
    	if obj.Spec.Suspend == nil {
    		obj.Spec.Suspend = new(bool)
    	}
    	if obj.Spec.SuccessfulJobsHistoryLimit == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 15 12:56:50 UTC 2017
    - 1.2K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top