Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for failedIndexes (0.29 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/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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. pkg/controller/job/job_controller_test.go

    					UncountedTerminatedPods: &batch.UncountedTerminatedPods{
    						Failed: []types.UID{"a1"},
    					},
    					FailedIndexes: ptr.To(""),
    				},
    				{
    					Active:                  1,
    					Failed:                  1,
    					UncountedTerminatedPods: &batch.UncountedTerminatedPods{},
    					FailedIndexes:           ptr.To(""),
    				},
    			},
    			wantFailedPodsMetric: 1,
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
  10. 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)
Back to top