Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 26 for failedIndexes (0.12 sec)

  1. pkg/controller/job/indexed_job_utils_test.go

    			failedIndexes := calculateFailedIndexes(logger, &tc.job, tc.pods)
    			_, succeededIndexes := calculateSucceededIndexes(logger, &tc.job, tc.pods)
    			jobCtx := &syncJobCtx{
    				job:                  &tc.job,
    				pods:                 tc.pods,
    				activePods:           activePods,
    				succeededIndexes:     succeededIndexes,
    				failedIndexes:        failedIndexes,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 27.9K bytes
    - Viewed (0)
  2. staging/src/k8s.io/client-go/applyconfigurations/batch/v1/jobstatus.go

    }
    
    // WithFailedIndexes sets the FailedIndexes field in the declarative configuration to the given value
    // and returns the receiver, so that objects can be built by chaining "With" function invocations.
    // If called multiple times, the FailedIndexes field is set to the value of the last call.
    func (b *JobStatusApplyConfiguration) WithFailedIndexes(value string) *JobStatusApplyConfiguration {
    	b.FailedIndexes = &value
    	return b
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 19 16:34:38 UTC 2023
    - 6.8K bytes
    - Viewed (0)
  3. pkg/controller/job/indexed_job_utils.go

    // format (intervals). The list includes indexes already present in
    // .status.failedIndexes and indexes that failed since the last sync.
    func calculateFailedIndexes(logger klog.Logger, job *batch.Job, pods []*v1.Pod) *orderedIntervals {
    	var prevIntervals orderedIntervals
    	if job.Status.FailedIndexes != nil {
    		prevIntervals = parseIndexesFromString(logger, *job.Status.FailedIndexes, int(*job.Spec.Completions))
    	}
    	newFailed := sets.New[int]()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 21 00:44:53 UTC 2023
    - 17.5K bytes
    - Viewed (0)
  4. pkg/apis/batch/validation/validation.go

    		if job.Spec.Completions != nil && job.Spec.BackoffLimitPerIndex != nil && status.FailedIndexes != nil {
    			if _, err := validateIndexesFormat(*status.FailedIndexes, int32(*job.Spec.Completions)); err != nil {
    				allErrs = append(allErrs, field.Invalid(fldPath.Child("failedIndexes"), status.FailedIndexes, fmt.Sprintf("error parsing failedIndexes: %s", err.Error())))
    			}
    		}
    	}
    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. pkg/registry/batch/job/strategy_test.go

    					BackoffLimitPerIndex: ptr.To[int32](1),
    				},
    				Status: batch.JobStatus{
    					FailedIndexes: ptr.To("invalid format"),
    				},
    			},
    			wantErrs: field.ErrorList{
    				{Type: field.ErrorTypeInvalid, Field: "status.failedIndexes"},
    			},
    		},
    		"invalid format for FailedIndexes, but allowed": {
    			enableJobManagedBy: true,
    			job: &batch.Job{
    				ObjectMeta: validObjectMeta,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 101.5K bytes
    - Viewed (0)
  6. pkg/controller/job/job_controller.go

    		jobCtx.job.Status.CompletedIndexes = succeededIndexesStr
    		var failedIndexesStr *string
    		if jobCtx.failedIndexes != nil {
    			failedIndexesStr = ptr.To(jobCtx.failedIndexes.String())
    		}
    		if !ptr.Equal(jobCtx.job.Status.FailedIndexes, failedIndexesStr) {
    			jobCtx.job.Status.FailedIndexes = failedIndexesStr
    			needsFlush = true
    		}
    	}
    	if feature.DefaultFeatureGate.Enabled(features.JobPodFailurePolicy) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
  7. staging/src/k8s.io/api/batch/v1/zz_generated.deepcopy.go

    		*out = (*in).DeepCopy()
    	}
    	if in.Terminating != nil {
    		in, out := &in.Terminating, &out.Terminating
    		*out = new(int32)
    		**out = **in
    	}
    	if in.FailedIndexes != nil {
    		in, out := &in.FailedIndexes, &out.FailedIndexes
    		*out = new(string)
    		**out = **in
    	}
    	if in.UncountedTerminatedPods != nil {
    		in, out := &in.UncountedTerminatedPods, &out.UncountedTerminatedPods
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 20:49:09 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  8. pkg/apis/batch/zz_generated.deepcopy.go

    		*out = new(int32)
    		**out = **in
    	}
    	if in.Ready != nil {
    		in, out := &in.Ready, &out.Ready
    		*out = new(int32)
    		**out = **in
    	}
    	if in.FailedIndexes != nil {
    		in, out := &in.FailedIndexes, &out.FailedIndexes
    		*out = new(string)
    		**out = **in
    	}
    	if in.UncountedTerminatedPods != nil {
    		in, out := &in.UncountedTerminatedPods, &out.UncountedTerminatedPods
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 20:49:09 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  9. pkg/apis/batch/v1/zz_generated.conversion.go

    	out.Active = in.Active
    	out.Succeeded = in.Succeeded
    	out.Failed = in.Failed
    	out.Terminating = (*int32)(unsafe.Pointer(in.Terminating))
    	out.CompletedIndexes = in.CompletedIndexes
    	out.FailedIndexes = (*string)(unsafe.Pointer(in.FailedIndexes))
    	out.UncountedTerminatedPods = (*batch.UncountedTerminatedPods)(unsafe.Pointer(in.UncountedTerminatedPods))
    	out.Ready = (*int32)(unsafe.Pointer(in.Ready))
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 20:49:09 UTC 2024
    - 36.6K bytes
    - Viewed (0)
  10. staging/src/k8s.io/api/batch/v1/types.go

    	//
    	// This field is beta-level. It can be used when the `JobBackoffLimitPerIndex`
    	// feature gate is enabled (enabled by default).
    	// +optional
    	FailedIndexes *string `json:"failedIndexes,omitempty" protobuf:"bytes,10,opt,name=failedIndexes"`
    
    	// uncountedTerminatedPods holds the UIDs of Pods that have terminated but
    	// the job controller hasn't yet accounted for in the status counters.
    	//
    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