Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for failedIndexes (0.24 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. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. pkg/registry/batch/job/strategy.go

    		isCompletedIndexesChanged := oldJob.Status.CompletedIndexes != newJob.Status.CompletedIndexes
    		isFailedIndexesChanged := !ptr.Equal(oldJob.Status.FailedIndexes, newJob.Status.FailedIndexes)
    		isActiveChanged := oldJob.Status.Active != newJob.Status.Active
    		isStartTimeChanged := !ptr.Equal(oldJob.Status.StartTime, newJob.Status.StartTime)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 16:43:24 UTC 2024
    - 18.4K bytes
    - Viewed (0)
  8. staging/src/k8s.io/api/testdata/HEAD/batch.v1.Job.yaml

      - lastProbeTime: "2003-01-01T01:01:01Z"
        lastTransitionTime: "2004-01-01T01:01:01Z"
        message: messageValue
        reason: reasonValue
        status: statusValue
        type: typeValue
      failed: 6
      failedIndexes: failedIndexesValue
      ready: 9
      startTime: "2002-01-01T01:01:01Z"
      succeeded: 5
      terminating: 11
      uncountedTerminatedPods:
        failed:
        - failedValue
        succeeded:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 35.7K bytes
    - Viewed (0)
  9. staging/src/k8s.io/api/batch/v1/types_swagger_doc_generated.go

    	"failedIndexes":           "FailedIndexes holds the failed indexes when spec.backoffLimitPerIndex is set. The indexes are represented in the text format analogous as for the `completedIndexes` field, ie. they are kept as decimal integers separated by commas. The numbers are...
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 12:01:28 UTC 2024
    - 27.5K bytes
    - Viewed (0)
  10. staging/src/k8s.io/api/batch/v1/generated.proto

      // For example, if the completed indexes are 1, 3, 4, 5 and 7, they are
      // represented as "1,3-5,7".
      // +optional
      optional string completedIndexes = 7;
    
      // FailedIndexes holds the failed indexes when spec.backoffLimitPerIndex is set.
      // The indexes are represented in the text format analogous as for the
      // `completedIndexes` field, ie. they are kept as decimal integers
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 12:01:28 UTC 2024
    - 29.1K bytes
    - Viewed (0)
Back to top