Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for canAdmitPod (0.3 sec)

  1. pkg/kubelet/runonce.go

    	ch := make(chan RunPodResult)
    	admitted := []*v1.Pod{}
    	for _, pod := range pods {
    		// Check if we can admit the pod.
    		if ok, reason, message := kl.canAdmitPod(admitted, pod); !ok {
    			kl.rejectPod(pod, reason, message)
    			results = append(results, RunPodResult{pod, nil})
    			continue
    		}
    
    		admitted = append(admitted, pod)
    		go func(pod *v1.Pod) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 04 06:56:50 UTC 2023
    - 5.9K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet.go

    }
    
    // canAdmitPod determines if a pod can be admitted, and gives a reason if it
    // cannot. "pod" is new pod, while "pods" are all admitted pods
    // The function returns a boolean value indicating whether the pod
    // can be admitted, a brief single-word reason and a message explaining why
    // the pod cannot be admitted.
    func (kl *Kubelet) canAdmitPod(pods []*v1.Pod, pod *v1.Pod) (bool, string, string) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  3. pkg/kubelet/kuberuntime/kuberuntime_manager.go

    			currentCPURequest = kubeContainerStatus.Resources.CPURequest.MilliValue()
    		}
    	}
    
    	// Note: cgroup doesn't support memory request today, so we don't compare that. If canAdmitPod called  during
    	// handlePodResourcesResize finds 'fit', then desiredMemoryRequest == currentMemoryRequest.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 22 02:01:31 UTC 2024
    - 64.7K bytes
    - Viewed (0)
Back to top