Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for nodesScores (0.18 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/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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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