Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for HandlePodSyncs (0.71 sec)

  1. pkg/kubelet/kubelet.go

    				kl.containerDeletor.deleteContainersInPod("", podStatus, true)
    			}
    		}
    	}
    }
    
    // HandlePodSyncs is the callback in the syncHandler interface for pods
    // that should be dispatched to pod workers for sync.
    func (kl *Kubelet) HandlePodSyncs(pods []*v1.Pod) {
    	start := kl.clock.Now()
    	for _, pod := range pods {
    		pod, mirrorPod, wasMirror := kl.podManager.GetPodAndMirrorPod(pod)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet_test.go

    	pods := []*v1.Pod{
    		podWithUIDNameNsSpec("12345678", "foo", "new", v1.PodSpec{
    			Containers: []v1.Container{
    				{Name: "bar"},
    			},
    		}),
    	}
    	kubelet.podManager.SetPods(pods)
    	kubelet.HandlePodSyncs(pods)
    	fakeRuntime.AssertStartedPods([]string{string(pods[0].UID)})
    }
    
    func TestHandlePodCleanupsPerQOS(t *testing.T) {
    	ctx := context.Background()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
Back to top