Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for fExtenders (0.23 sec)

  1. pkg/scheduler/scheduler.go

    	fExtenders = append(fExtenders, ignorableExtenders...)
    
    	// If there are any extended resources found from the Extenders, append them to the pluginConfig for each profile.
    	// This should only have an effect on ComponentConfig, where it is possible to configure Extenders and
    	// plugin args (and in which case the extender ignored resources take precedence).
    	if len(ignoredExtendedResources) == 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 20.8K bytes
    - Viewed (0)
  2. pkg/scheduler/apis/config/validation/validation_test.go

    	extenderDuplicateManagedResource.Extenders[0].ManagedResources = []config.ExtenderManagedResource{
    		{Name: "example.com/foo", IgnoredByScheduler: false},
    		{Name: "example.com/foo", IgnoredByScheduler: false},
    	}
    
    	extenderDuplicateBind := validConfig.DeepCopy()
    	extenderDuplicateBind.Extenders[0].BindVerb = "foo"
    	extenderDuplicateBind.Extenders = append(extenderDuplicateBind.Extenders, config.Extender{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 06:27:01 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  3. pkg/scheduler/scheduler_test.go

    			}
    
    			// Extenders
    			if len(tc.wantExtenders) != 0 {
    				// Scheduler.Extenders
    				extenders := make([]string, 0, len(s.Extenders))
    				for _, e := range s.Extenders {
    					extenders = append(extenders, e.Name())
    				}
    				if diff := cmp.Diff(tc.wantExtenders, extenders); diff != "" {
    					t.Errorf("unexpected extenders (-want, +got):\n%s", diff)
    				}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 42K bytes
    - Viewed (0)
  4. pkg/scheduler/apis/config/validation/validation.go

    			}
    		}
    	}
    	return errs
    }
    
    // validateExtenders validates the configured extenders for the Scheduler
    func validateExtenders(fldPath *field.Path, extenders []config.Extender) []error {
    	var errs []error
    	binders := 0
    	extenderManagedResources := sets.New[string]()
    	for i, extender := range extenders {
    		path := fldPath.Index(i)
    		if len(extender.PrioritizeVerb) > 0 && extender.Weight <= 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 06:27:01 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  5. pkg/scheduler/schedule_one.go

    			}
    		}
    	}
    
    	if len(extenders) != 0 && nodes != nil {
    		// allNodeExtendersScores has all extenders scores for all nodes.
    		// It is keyed with node name.
    		allNodeExtendersScores := make(map[string]*framework.NodePluginScores, len(nodes))
    		var mu sync.Mutex
    		var wg sync.WaitGroup
    		for i := range extenders {
    			if !extenders[i].IsInterested(pod) {
    				continue
    			}
    			wg.Add(1)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 13:28:08 UTC 2024
    - 43.4K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/runtime/framework.go

    		{&plugins.Permit, &f.permitPlugins},
    		{&plugins.PreEnqueue, &f.preEnqueuePlugins},
    		{&plugins.QueueSort, &f.queueSortPlugins},
    	}
    }
    
    // Extenders returns the registered extenders.
    func (f *frameworkImpl) Extenders() []framework.Extender {
    	return f.extenders
    }
    
    type frameworkOptions struct {
    	componentConfigVersion string
    	clientSet              clientset.Interface
    	kubeConfig             *restclient.Config
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 60.9K bytes
    - Viewed (0)
  7. pkg/scheduler/schedule_one_test.go

    				t.Fatal(err)
    			}
    
    			var extenders []framework.Extender
    			for ii := range test.extenders {
    				extenders = append(extenders, &test.extenders[ii])
    			}
    			sched := &Scheduler{
    				Cache:                    cache,
    				nodeInfoSnapshot:         snapshot,
    				percentageOfNodesToScore: schedulerapi.DefaultPercentageOfNodesToScore,
    				Extenders:                extenders,
    			}
    			sched.applyDefaultHandlers()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 128.1K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/preemption/preemption.go

    		nodeStatuses[node] = nodeStatus
    	}
    	return candidates, nodeStatuses, err
    }
    
    // callExtenders calls given <extenders> to select the list of feasible candidates.
    // We will only check <candidates> with extenders that support preemption.
    // Extenders which do not support preemption may later prevent preemptor from being scheduled on the nominated
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 25.1K bytes
    - Viewed (0)
  9. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go

    				nodes[i] = node
    
    				// Set nodeInfo to extenders to mock extenders' cache for preemption.
    				cachedNodeInfo := framework.NewNodeInfo()
    				cachedNodeInfo.SetNode(node)
    				cachedNodeInfoMap[node.Name] = cachedNodeInfo
    			}
    			var extenders []framework.Extender
    			for _, extender := range test.extenders {
    				// Set nodeInfoMap as extenders cached node information.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 82.8K bytes
    - Viewed (0)
  10. pkg/scheduler/framework/interface.go

    	RunFilterPluginsWithNominatedPods(ctx context.Context, state *CycleState, pod *v1.Pod, info *NodeInfo) *Status
    
    	// Extenders returns registered scheduler extenders.
    	Extenders() []Extender
    
    	// Parallelizer returns a parallelizer holding parallelism for scheduler.
    	Parallelizer() parallelize.Parallelizer
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 35.4K bytes
    - Viewed (0)
Back to top