Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 40 for concurrencyPolicy (0.31 sec)

  1. pkg/controller/cronjob/cronjob_controllerv2_test.go

    	}
    
    	if longDead/60/60/24 < 10 {
    		t.Errorf("longDead should be at least ten days")
    	}
    
    	testCases := map[string]struct {
    		// cj spec
    		concurrencyPolicy batchv1.ConcurrencyPolicy
    		suspend           bool
    		schedule          string
    		timeZone          *string
    		deadline          int64
    
    		// cj status
    		ranPreviously bool
    		stillActive   bool
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 70.8K bytes
    - Viewed (0)
  2. 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)
  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. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top