- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 26 for failedIndexes (0.12 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)