Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for allAdds (0.25 sec)

  1. pkg/kubelet/kubelet_pods.go

    // those pods during admission may still be in use. See
    // https://github.com/kubernetes/kubernetes/issues/104824
    func (kl *Kubelet) GetActivePods() []*v1.Pod {
    	allPods := kl.podManager.GetPods()
    	activePods := kl.filterOutInactivePods(allPods)
    	return activePods
    }
    
    // makeBlockVolumes maps the raw block devices specified in the path of the container
    // Experimental
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet.go

    // PodWorker which pods should be synced.
    func (kl *Kubelet) getPodsToSync() []*v1.Pod {
    	allPods := kl.podManager.GetPods()
    	podUIDs := kl.workQueue.GetWork()
    	podUIDSet := sets.New[string]()
    	for _, podUID := range podUIDs {
    		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
    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