Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for appendDuplicatedIndexPodsForRemoval (1.47 sec)

  1. pkg/controller/job/indexed_job_utils_test.go

    				{"1", v1.PodRunning},
    			},
    			completions: 6,
    		},
    	}
    	for name, tc := range cases {
    		t.Run(name, func(t *testing.T) {
    			pods := hollowPodsWithIndexPhase(tc.pods)
    			rm, left := appendDuplicatedIndexPodsForRemoval(nil, nil, pods, int(tc.completions))
    			rmInt := toIndexPhases(rm)
    			leftInt := toIndexPhases(left)
    			if diff := cmp.Diff(tc.wantRm, rmInt); diff != "" {
    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/job_controller.go

    	var rm, left []*v1.Pod
    
    	if isIndexedJob(job) {
    		rm = make([]*v1.Pod, 0, rmAtLeast)
    		left = make([]*v1.Pod, 0, len(pods)-rmAtLeast)
    		rm, left = appendDuplicatedIndexPodsForRemoval(rm, left, pods, int(*job.Spec.Completions))
    	} else {
    		left = pods
    	}
    
    	if len(rm) < rmAtLeast {
    		sort.Sort(controller.ActivePods(left))
    		rm = append(rm, left[:rmAtLeast-len(rm)]...)
    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