- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for insufficientResources (0.39 sec)
-
pkg/scheduler/framework/plugins/noderesources/fit.go
return framework.AsStatus(err) } insufficientResources := fitsRequest(s, nodeInfo, f.ignoredResources, f.ignoredResourceGroups) if len(insufficientResources) != 0 { // We will keep all failure reasons. failureReasons := make([]string, 0, len(insufficientResources)) for i := range insufficientResources { failureReasons = append(failureReasons, insufficientResources[i].Reason) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 20.2K bytes - Viewed (0) -
pkg/kubelet/preemption/preemption_test.go
allPods[guaranteed], allPods[highRequestGuaranteed]}, insufficientResources: getAdmissionRequirementList(0, 550, 0), expectErr: false, expectedOutput: nil, }, } for _, r := range runs { podProvider.setPods(r.inputPods) outErr := criticalPodAdmissionHandler.evictPodsToFreeRequests(allPods[clusterCritical], r.insufficientResources) outputPods := podKiller.getKilledPods()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jul 24 10:04:08 UTC 2022 - 19.2K bytes - Viewed (0) -
pkg/kubelet/preemption/preemption.go
// evict a pod with request=250Mb. func (c *CriticalPodAdmissionHandler) evictPodsToFreeRequests(admitPod *v1.Pod, insufficientResources admissionRequirementList) error { podsToPreempt, err := getPodsToPreempt(admitPod, c.getPodsFunc(), insufficientResources) if err != nil { return fmt.Errorf("preemption: error finding a set of pods to preempt: %v", err) } for _, pod := range podsToPreempt {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 02 16:53:19 UTC 2023 - 11.5K bytes - Viewed (0) -
pkg/scheduler/eventhandlers.go
var admissionResults []AdmissionResult insufficientResources := noderesources.Fits(pod, nodeInfo) if len(insufficientResources) != 0 { for i := range insufficientResources { admissionResults = append(admissionResults, AdmissionResult{InsufficientResource: &insufficientResources[i]}) } if !includeAllFailures { return admissionResults } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:21:04 UTC 2024 - 24K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/noderesources/fit_test.go
wantInsufficientResources []InsufficientResource wantStatus *framework.Status }{ { pod: &v1.Pod{}, nodeInfo: framework.NewNodeInfo( newResourcePod(framework.Resource{MilliCPU: 10, Memory: 20})), name: "no resources requested always fits", wantInsufficientResources: []InsufficientResource{}, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 57.4K bytes - Viewed (0) -
pkg/kubelet/lifecycle/predicate.go
var reasons []PredicateFailureReason for _, r := range admissionResults { if r.InsufficientResource != nil { reasons = append(reasons, &InsufficientResourceError{ ResourceName: r.InsufficientResource.ResourceName, Requested: r.InsufficientResource.Requested, Used: r.InsufficientResource.Used, Capacity: r.InsufficientResource.Capacity, }) } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 19 00:47:50 UTC 2023 - 10.9K bytes - Viewed (0) -
pkg/scheduler/eventhandlers_test.go
nodenameError := AdmissionResult{Name: nodename.Name, Reason: nodename.ErrReason} nodeportsError := AdmissionResult{Name: nodeports.Name, Reason: nodeports.ErrReason} podOverheadError := AdmissionResult{InsufficientResource: &noderesources.InsufficientResource{ResourceName: v1.ResourceCPU, Reason: "Insufficient cpu", Requested: 2000, Used: 7000, Capacity: 8000}} cpu := map[v1.ResourceName]string{v1.ResourceCPU: "8"} tests := []struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 10 14:38:54 UTC 2024 - 21.5K bytes - Viewed (0)