Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for podsToSync (1.25 sec)

  1. pkg/kubelet/kubelet_test.go

    	kubelet.workQueue.Enqueue(pods[4].UID, 2*time.Minute)
    
    	clock.Step(1 * time.Minute)
    
    	expected := []*v1.Pod{pods[2], pods[3], pods[0]}
    	podsToSync := kubelet.getPodsToSync()
    	sort.Sort(podsByUID(expected))
    	sort.Sort(podsByUID(podsToSync))
    	assert.Equal(t, expected, podsToSync)
    }
    
    func TestGenerateAPIPodStatusWithSortedContainers(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet.go

    		podUIDSet.Insert(string(podUID))
    	}
    	var podsToSync []*v1.Pod
    	for _, pod := range allPods {
    		if podUIDSet.Has(string(pod.UID)) {
    			// The work of the pod is ready
    			podsToSync = append(podsToSync, pod)
    			continue
    		}
    		for _, podSyncLoopHandler := range kl.PodSyncLoopHandlers {
    			if podSyncLoopHandler.ShouldSync(pod) {
    				podsToSync = append(podsToSync, pod)
    				break
    			}
    		}
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
Back to top