Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 40 for concurrencyPolicy (0.49 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. staging/src/k8s.io/api/batch/v1beta1/types_swagger_doc_generated.go

    	"startingDeadlineSeconds":    "Optional deadline in seconds for starting the job if it misses scheduled time for any reason.  Missed jobs executions will be counted as failed ones.",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 07 11:58:59 UTC 2023
    - 5.6K bytes
    - Viewed (0)
  8. pkg/controller/cronjob/utils_test.go

    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "mycronjob",
    			Namespace: "snazzycats",
    			UID:       types.UID("1a2b3c"),
    		},
    		Spec: batchv1.CronJobSpec{
    			Schedule:          "* * * * ?",
    			ConcurrencyPolicy: batchv1.AllowConcurrent,
    			JobTemplate: batchv1.JobTemplateSpec{
    				ObjectMeta: metav1.ObjectMeta{
    					CreationTimestamp: metav1.Time{Time: scheduledTime},
    					Labels:            map[string]string{"a": "b"},
    				},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 03:34:25 UTC 2024
    - 22.8K bytes
    - Viewed (0)
  9. staging/src/k8s.io/api/batch/v1/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: Thu Mar 07 20:49:09 UTC 2024
    - 133K bytes
    - Viewed (0)
  10. pkg/controller/cronjob/cronjob_controllerv2.go

    		t := nextScheduleTimeDuration(cronJob, now, sched)
    		return t, updateStatus, nil
    	}
    	if cronJob.Spec.ConcurrencyPolicy == batchv1.ForbidConcurrent && len(cronJob.Status.Active) > 0 {
    		// Regardless which source of information we use for the set of active jobs,
    		// there is some risk that we won't see an active job when there is one.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 03:34:25 UTC 2024
    - 29.2K bytes
    - Viewed (0)
Back to top