Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 20 for nodesScores (0.28 sec)

  1. pkg/scheduler/framework/plugins/noderesources/most_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.MinNodeScore}, {Name: "node2", Score: framework.MinNodeScore}},
    			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
    - 16K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/noderesources/requested_to_capacity_ratio.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 := resourceScoringFunction(requested[i], allocable[i])
    			if resourceScore > 0 {
    				nodeScore += resourceScore * weight
    				weightSum += weight
    			}
    		}
    		if weightSum == 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Dec 21 15:23:47 UTC 2022
    - 2.6K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/noderesources/most_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 := mostRequestedScore(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: Wed Dec 21 15:23:47 UTC 2022
    - 2.2K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/plugins/podtopologyspread/scoring_test.go

    				Obj(),
    			nodes: []*v1.Node{
    				st.MakeNode().Name("node-a").Label(v1.LabelHostname, "node-a").Obj(),
    				st.MakeNode().Name("node-b").Label(v1.LabelHostname, "node-b").Obj(),
    			},
    			want: []framework.NodeScore{
    				{Name: "node-a", Score: 100},
    				{Name: "node-b", Score: 100},
    			},
    		},
    		{
    			// if there is only one candidate node, it should be scored to 100
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 60K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/tainttoleration/taint_toleration_test.go

    				}}),
    				nodeWithTaints("nodeB", []v1.Taint{{
    					Key:    "foo",
    					Value:  "blah",
    					Effect: v1.TaintEffectPreferNoSchedule,
    				}}),
    			},
    			expectedList: []framework.NodeScore{
    				{Name: "nodeA", Score: framework.MaxNodeScore},
    				{Name: "nodeB", Score: 0},
    			},
    		},
    		// the count of taints that are tolerated by pod, does not matter.
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 17.5K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/nodeaffinity/node_affinity_test.go

    				{ObjectMeta: metav1.ObjectMeta{Name: "node2", Labels: label2}},
    				{ObjectMeta: metav1.ObjectMeta{Name: "node3", Labels: label3}},
    			},
    			expectedList: []framework.NodeScore{{Name: "node1", Score: 0}, {Name: "node2", Score: 0}, {Name: "node3", Score: 0}},
    		},
    		{
    			// PreScore returns Skip.
    			name: "Skip is returned in PreScore when NodeAffinity is nil",
    			pod: &v1.Pod{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Dec 18 12:00:10 UTC 2023
    - 38.7K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/plugins/noderesources/fit_test.go

    				st.MakePod().Node("node2").Req(map[v1.ResourceName]string{"cpu": "1000", "memory": "2000"}).Obj(),
    			},
    			expectedPriorities: []framework.NodeScore{{Name: "node1", Score: 10}, {Name: "node2", Score: 32}},
    			nodeResourcesFitArgs: config.NodeResourcesFitArgs{
    				ScoringStrategy: &config.ScoringStrategy{
    					Type:      config.RequestedToCapacityRatio,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 57.4K bytes
    - Viewed (0)
  8. pkg/scheduler/testing/framework/fake_extender.go

    	result := framework.NodeScoreList{}
    	for _, node := range nodes {
    		score := 1
    		if node.Node().Name == "node1" {
    			score = 10
    		}
    		result = append(result, framework.NodeScore{Name: node.Node().Name, Score: int64(score)})
    	}
    	return &result, nil
    }
    
    // Node2PrioritizerExtender implements PriorityFunc function to give score 10
    // if the given node's name is "node2"; otherwise score 1.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 19:07:19 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  9. pkg/scheduler/framework/interface.go

    	"k8s.io/kubernetes/pkg/scheduler/framework/parallelize"
    )
    
    // NodeScoreList declares a list of nodes and their scores.
    type NodeScoreList []NodeScore
    
    // NodeScore is a struct with node name and score.
    type NodeScore struct {
    	Name  string
    	Score int64
    }
    
    // NodeToStatusMap contains the statuses of the Nodes where the incoming Pod was not schedulable.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 35.4K bytes
    - Viewed (0)
  10. pkg/scheduler/framework/runtime/framework.go

    					err := fmt.Errorf("plugin %q failed with: %w", pl.Name(), status.AsError())
    					errCh.SendErrorWithCancel(err, cancel)
    					return
    				}
    				pluginToNodeScores[pl.Name()][index] = framework.NodeScore{
    					Name:  nodeName,
    					Score: s,
    				}
    			}
    		}, metrics.Score)
    		if err := errCh.ReceiveError(); err != nil {
    			return nil, framework.AsStatus(fmt.Errorf("running Score plugins: %w", err))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 60.9K bytes
    - Viewed (0)
Back to top