- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for byCompletionIndex (0.16 sec)
-
pkg/controller/job/indexed_job_utils.go
} return generateNamePrefix } type byCompletionIndex []*v1.Pod func (bci byCompletionIndex) Less(i, j int) bool { return getCompletionIndex(bci[i].Annotations) < getCompletionIndex(bci[j].Annotations) } func (bci byCompletionIndex) Swap(i, j int) { bci[i], bci[j] = bci[j], bci[i] } func (bci byCompletionIndex) Len() int { return len(bci) }
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/controller/job/job_controller.go
var podsToRemoveFinalizer []*v1.Pod uncountedStatus := jobCtx.job.Status.UncountedTerminatedPods var newSucceededIndexes []int if isIndexed { // Sort to introduce completed Indexes in order. sort.Sort(byCompletionIndex(jobCtx.pods)) } uidsWithFinalizer := make(sets.Set[string], len(jobCtx.pods)) for _, p := range jobCtx.pods { uid := string(p.UID) if hasJobTrackingFinalizer(p) && !jobCtx.expectedRmFinalizers.Has(uid) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0)