Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for nodesScores (0.17 sec)

  1. pkg/scheduler/schedule_one.go

    		}
    		// wait for all go routines to finish
    		wg.Wait()
    		for i := range nodesScores {
    			if score, ok := allNodeExtendersScores[nodes[i].Node().Name]; ok {
    				nodesScores[i].Scores = append(nodesScores[i].Scores, score.Scores...)
    				nodesScores[i].TotalScore += score.TotalScore
    			}
    		}
    	}
    
    	if loggerVTen.Enabled() {
    		for i := range nodesScores {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 13:28:08 UTC 2024
    - 43.4K bytes
    - Viewed (0)
  2. pkg/scheduler/schedule_one_test.go

    			}
    			nodesscores, err := prioritizeNodes(ctx, extenders, fwk, state, test.pod, tf.BuildNodeInfos(test.nodes))
    			if err != nil {
    				t.Errorf("unexpected error: %v", err)
    			}
    			for i := range nodesscores {
    				sort.Slice(nodesscores[i].Scores, func(j, k int) bool {
    					return nodesscores[i].Scores[j].Name < nodesscores[i].Scores[k].Name
    				})
    			}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 128.1K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/noderesources/least_allocated.go

    	return func(requested, allocable []int64) int64 {
    		var nodeScore, weightSum int64
    		for i := range requested {
    			if allocable[i] == 0 {
    				continue
    			}
    			weight := resources[i].Weight
    			resourceScore := leastRequestedScore(requested[i], allocable[i])
    			nodeScore += resourceScore * weight
    			weightSum += weight
    		}
    		if weightSum == 0 {
    			return 0
    		}
    		return nodeScore / weightSum
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Mar 12 01:50:09 UTC 2023
    - 2K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/plugins/noderesources/requested_to_capacity_ratio_test.go

    					t.Errorf("Score is expected to return success, but didn't. Got status: %v", status)
    				}
    				gotList = append(gotList, framework.NodeScore{Name: n.Name, Score: score})
    			}
    
    			if diff := cmp.Diff(test.expectedScores, gotList); diff != "" {
    				t.Errorf("Unexpected nodescore list (-want,+got):\n%s", diff)
    			}
    		})
    	}
    }
    
    func TestResourceBinPackingMultipleExtended(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 21.2K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/imagelocality/image_locality_test.go

    			pod:          &v1.Pod{Spec: test40250},
    			nodes:        []*v1.Node{makeImageNode("node1", node403002000), makeImageNode("node2", node25010)},
    			expectedList: []framework.NodeScore{{Name: "node1", Score: 0}, {Name: "node2", Score: 5}},
    			name:         "two images spread on two nodes, prefer the larger image one",
    		},
    		{
    			// Pod: gcr.io/40 gcr.io/300
    
    			// Node1
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 19 06:17:57 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/volumebinding/scorer.go

    	return func(classResources classResourceMap) int64 {
    		var nodeScore int64
    		// in alpha stage, all classes have the same weight
    		weightSum := len(classResources)
    		if weightSum == 0 {
    			return 0
    		}
    		for _, resource := range classResources {
    			classScore := f(resource.Requested, resource.Capacity)
    			nodeScore += classScore
    		}
    		return int64(math.Round(float64(nodeScore) / float64(weightSum)))
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 13 11:08:45 UTC 2021
    - 1.8K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/plugins/noderesources/balanced_allocation_test.go

    			// Node2 Score: (1-0) * MaxNodeScore = MaxNodeScore
    			pod:          st.MakePod().Obj(),
    			nodes:        []*v1.Node{makeNode("node1", 4000, 10000, nil), makeNode("node2", 4000, 10000, nil)},
    			expectedList: []framework.NodeScore{{Name: "node1", Score: framework.MaxNodeScore}, {Name: "node2", Score: framework.MaxNodeScore}},
    			name:         "nothing scheduled, nothing requested",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 15.9K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/plugins/noderesources/least_allocated_test.go

    				st.MakeNode().Name("node2").Capacity(map[v1.ResourceName]string{"cpu": "4000", "memory": "10000"}).Obj(),
    			},
    			existingPods:   nil,
    			expectedScores: []framework.NodeScore{{Name: "node1", Score: framework.MaxNodeScore}, {Name: "node2", Score: framework.MaxNodeScore}},
    			resources:      defaultResources,
    		},
    		{
    			// Node1 scores on 0-MaxNodeScore scale
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 18.8K bytes
    - Viewed (0)
  9. pkg/scheduler/framework/plugins/helper/normalize_score_test.go

    			scores := framework.NodeScoreList{}
    			for _, score := range test.scores {
    				scores = append(scores, framework.NodeScore{Score: score})
    			}
    
    			expectedScores := framework.NodeScoreList{}
    			for _, score := range test.expectedScores {
    				expectedScores = append(expectedScores, framework.NodeScore{Score: score})
    			}
    
    			DefaultNormalizeScore(framework.MaxNodeScore, test.reverse, scores)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jul 14 16:15:18 UTC 2022
    - 2.4K bytes
    - Viewed (0)
  10. pkg/scheduler/framework/plugins/interpodaffinity/scoring_test.go

    				{ObjectMeta: metav1.ObjectMeta{Name: "node2", Labels: labelRgIndia}},
    				{ObjectMeta: metav1.ObjectMeta{Name: "node3", Labels: labelAzAz1}},
    			},
    			expectedList: []framework.NodeScore{{Name: "node1", Score: framework.MaxNodeScore}, {Name: "node2", Score: 0}, {Name: "node3", Score: 0}},
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 44.8K bytes
    - Viewed (0)
Back to top