Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for NewBalancedAllocation (0.35 sec)

  1. pkg/scheduler/framework/plugins/noderesources/balanced_allocation.go

    }
    
    // ScoreExtensions of the Score plugin.
    func (ba *BalancedAllocation) ScoreExtensions() framework.ScoreExtensions {
    	return nil
    }
    
    // NewBalancedAllocation initializes a new plugin and returns it.
    func NewBalancedAllocation(_ context.Context, baArgs runtime.Object, h framework.Handle, fts feature.Features) (framework.Plugin, error) {
    	args, ok := baArgs.(*config.NodeResourcesBalancedAllocationArgs)
    	if !ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 6.5K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/registry.go

    		noderesources.Name:                   runtime.FactoryAdapter(fts, noderesources.NewFit),
    		noderesources.BalancedAllocationName: runtime.FactoryAdapter(fts, noderesources.NewBalancedAllocation),
    		volumebinding.Name:                   runtime.FactoryAdapter(fts, volumebinding.New),
    		volumerestrictions.Name:              runtime.FactoryAdapter(fts, volumerestrictions.New),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 5K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/noderesources/balanced_allocation_test.go

    			_, ctx := ktesting.NewTestContext(t)
    			ctx, cancel := context.WithCancel(ctx)
    			defer cancel()
    			fh, _ := runtime.NewFramework(ctx, nil, nil, runtime.WithSnapshotSharedLister(snapshot))
    			p, _ := NewBalancedAllocation(ctx, &test.args, fh, feature.Features{})
    			state := framework.NewCycleState()
    			for i := range test.nodes {
    				if test.runPreScore {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 15.9K bytes
    - Viewed (0)
  4. pkg/scheduler/schedule_one_test.go

    				tf.RegisterScorePlugin(noderesources.Name, frameworkruntime.FactoryAdapter(fts, noderesources.NewFit), 1),
    				tf.RegisterScorePlugin(noderesources.BalancedAllocationName, frameworkruntime.FactoryAdapter(fts, noderesources.NewBalancedAllocation), 1),
    				tf.RegisterBindPlugin(defaultbinder.Name, defaultbinder.New),
    			}
    			ctx, cancel := context.WithCancel(context.Background())
    			defer cancel()
    			fwk, err := tf.NewFramework(
    				ctx,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 128.1K bytes
    - Viewed (0)
Back to top