Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for byCompletionIndex (0.16 sec)

  1. 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)
  2. 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)
Back to top