Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for nodeToStatusMap (0.29 sec)

  1. pkg/scheduler/framework/types_test.go

    	}{
    		{
    			name:        "nodes failed Prefilter plugin",
    			numAllNodes: 3,
    			diagnosis: Diagnosis{
    				PreFilterMsg: "Node(s) failed PreFilter plugin FalsePreFilter",
    				NodeToStatusMap: NodeToStatusMap{
    					// They're inserted by the framework.
    					// We don't include them in the reason message because they'd be just duplicates.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 45.9K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/preemption/preemption_test.go

    	nodeNames := []string{"node1", "node2", "node3", "node4"}
    	tests := []struct {
    		name          string
    		nodesStatuses framework.NodeToStatusMap
    		expected      sets.Set[string] // set of expected node names.
    	}{
    		{
    			name: "No node should be attempted",
    			nodesStatuses: framework.NodeToStatusMap{
    				"node1": framework.NewStatus(framework.UnschedulableAndUnresolvable, nodeaffinity.ErrReasonPod),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  3. pkg/scheduler/schedule_one_test.go

    	scheduler.ScheduleOne(ctx)
    	select {
    	case err := <-errChan:
    		expectErr := &framework.FitError{
    			Pod:         secondPod,
    			NumAllNodes: 1,
    			Diagnosis: framework.Diagnosis{
    				NodeToStatusMap: framework.NodeToStatusMap{
    					node.Name: framework.NewStatus(framework.Unschedulable, nodeports.ErrReason).WithPlugin(nodeports.Name),
    				},
    				UnschedulablePlugins: sets.New(nodeports.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)
  4. pkg/scheduler/schedule_one.go

    		}
    
    		if sts.IsRejected() {
    			fitErr := &framework.FitError{
    				NumAllNodes: 1,
    				Pod:         pod,
    				Diagnosis: framework.Diagnosis{
    					NodeToStatusMap: framework.NodeToStatusMap{scheduleResult.SuggestedHost: sts},
    				},
    			}
    			fitErr.Diagnosis.AddPluginStatus(sts)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 13:28:08 UTC 2024
    - 43.4K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/preemption/preemption.go

    // that may be satisfied by removing pods from the node.
    func nodesWherePreemptionMightHelp(nodes []*framework.NodeInfo, m framework.NodeToStatusMap) ([]*framework.NodeInfo, framework.NodeToStatusMap) {
    	var potentialNodes []*framework.NodeInfo
    	nodeStatuses := make(framework.NodeToStatusMap)
    	unresolvableStatus := framework.NewStatus(framework.UnschedulableAndUnresolvable, "Preemption is not helpful for scheduling")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 25.1K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/interface.go

    	// NodeToStatusMap has statuses that each Node got in the Filter phase.
    	// If this scheduling cycle failed at PreFilter, all Nodes have the status from the rejector PreFilter plugin in NodeToStatusMap.
    	// Note that the scheduling framework runs PostFilter plugins even when PreFilter returned UnschedulableAndUnresolvable.
    	// In that case, NodeToStatusMap contains all Nodes with UnschedulableAndUnresolvable.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 35.4K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go

    			// so that these nodes are eligible for preemption, we set their status
    			// to Unschedulable.
    			nodeToStatusMap := make(framework.NodeToStatusMap, len(nodes))
    			for _, n := range nodes {
    				nodeToStatusMap[n.Name] = framework.NewStatus(framework.Unschedulable)
    			}
    
    			res, status := pe.Preempt(ctx, test.pod, nodeToStatusMap)
    			if !status.IsSuccess() && !status.IsRejected() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 82.8K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/types.go

    		// the scheduling framework inserts the same unschedulable status to all nodes in NodeToStatusMap.
    		// So, we shouldn't add the message from NodeToStatusMap when the PreFilter failed.
    		// Otherwise, we will have duplicated reasons in the error message.
    		reasons := make(map[string]int)
    		for _, status := range f.Diagnosis.NodeToStatusMap {
    			for _, reason := range status.Reasons() {
    				reasons[reason]++
    			}
    		}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 19:28:17 UTC 2024
    - 36.7K bytes
    - Viewed (0)
  9. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption.go

    	}
    	return &pl, nil
    }
    
    // PostFilter invoked at the postFilter extension point.
    func (pl *DefaultPreemption) PostFilter(ctx context.Context, state *framework.CycleState, pod *v1.Pod, m framework.NodeToStatusMap) (*framework.PostFilterResult, *framework.Status) {
    	defer func() {
    		metrics.PreemptionAttempts.Inc()
    	}()
    
    	pe := preemption.Evaluator{
    		PluginName: names.DefaultPreemption,
    		Handler:    pl.fh,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Nov 25 19:36:04 UTC 2023
    - 12.7K bytes
    - Viewed (0)
  10. pkg/scheduler/framework/runtime/framework.go

    func (f *frameworkImpl) RunPostFilterPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, filteredNodeStatusMap framework.NodeToStatusMap) (_ *framework.PostFilterResult, status *framework.Status) {
    	startTime := time.Now()
    	defer func() {
    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