Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for NewFit (0.14 sec)

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

    				test.args.ScoringStrategy = defaultScoringStrategy
    			}
    
    			_, ctx := ktesting.NewTestContext(t)
    			ctx, cancel := context.WithCancel(ctx)
    			defer cancel()
    			p, err := NewFit(ctx, &test.args, nil, plfeature.Features{})
    			if err != nil {
    				t.Fatal(err)
    			}
    			cycleState := framework.NewCycleState()
    			_, preFilterStatus := p.(framework.PreFilterPlugin).PreFilter(ctx, cycleState, test.pod)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 57.4K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/noderesources/requested_to_capacity_ratio_test.go

    			state := framework.NewCycleState()
    			snapshot := cache.NewSnapshot(test.existingPods, test.nodes)
    			fh, _ := runtime.NewFramework(ctx, nil, nil, runtime.WithSnapshotSharedLister(snapshot))
    
    			p, err := NewFit(ctx, &config.NodeResourcesFitArgs{
    				ScoringStrategy: &config.ScoringStrategy{
    					Type:      config.RequestedToCapacityRatio,
    					Resources: test.resources,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 21.2K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/registry.go

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

    	}
    	return s, nil
    }
    
    // Name returns name of the plugin. It is used in logs, etc.
    func (f *Fit) Name() string {
    	return Name
    }
    
    // NewFit initializes a new plugin and returns it.
    func NewFit(_ context.Context, plArgs runtime.Object, h framework.Handle, fts feature.Features) (framework.Plugin, error) {
    	args, ok := plArgs.(*config.NodeResourcesFitArgs)
    	if !ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 20.2K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/noderesources/most_allocated_test.go

    			state := framework.NewCycleState()
    			snapshot := cache.NewSnapshot(test.existingPods, test.nodes)
    			fh, _ := runtime.NewFramework(ctx, nil, nil, runtime.WithSnapshotSharedLister(snapshot))
    
    			p, err := NewFit(ctx,
    				&config.NodeResourcesFitArgs{
    					ScoringStrategy: &config.ScoringStrategy{
    						Type:      config.MostAllocated,
    						Resources: test.resources,
    					},
    				}, fh, plfeature.Features{})
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 16K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/noderesources/least_allocated_test.go

    			state := framework.NewCycleState()
    			snapshot := cache.NewSnapshot(test.existingPods, test.nodes)
    			fh, _ := runtime.NewFramework(ctx, nil, nil, runtime.WithSnapshotSharedLister(snapshot))
    
    			p, err := NewFit(
    				ctx,
    				&config.NodeResourcesFitArgs{
    					ScoringStrategy: &config.ScoringStrategy{
    						Type:      config.LeastAllocated,
    						Resources: test.resources,
    					},
    				}, fh, plfeature.Features{})
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 18.8K bytes
    - Viewed (0)
  7. pkg/scheduler/schedule_one_test.go

    		tf.RegisterBindPlugin(defaultbinder.Name, defaultbinder.New),
    		tf.RegisterPluginAsExtensions(noderesources.Name, frameworkruntime.FactoryAdapter(feature.Features{}, noderesources.NewFit), "Filter", "PreFilter"),
    	}
    
    	informerFactory := informers.NewSharedInformerFactory(clientsetfake.NewSimpleClientset(objects...), 0)
    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/plugins/defaultpreemption/default_preemption_test.go

    	configv1.Convert_v1_DefaultPreemptionArgs_To_config_DefaultPreemptionArgs(v1dpa, dpa, nil)
    	return dpa
    }
    
    var nodeResourcesFitFunc = frameworkruntime.FactoryAdapter(feature.Features{}, noderesources.NewFit)
    var podTopologySpreadFunc = frameworkruntime.FactoryAdapter(feature.Features{}, podtopologyspread.New)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 82.8K bytes
    - Viewed (0)
  9. src/runtime/map_fast64.go

    	if h.growing() {
    		evacuate_fast64(t, h, h.nevacuate)
    	}
    }
    
    func evacuate_fast64(t *maptype, h *hmap, oldbucket uintptr) {
    	b := (*bmap)(add(h.oldbuckets, oldbucket*uintptr(t.BucketSize)))
    	newbit := h.noldbuckets()
    	if !evacuated(b) {
    		// TODO: reuse overflow buckets instead of using new ones, if there
    		// is no iterator using the old buckets.  (If !oldIterator.)
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:17:26 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  10. src/runtime/map_faststr.go

    	if h.growing() {
    		evacuate_faststr(t, h, h.nevacuate)
    	}
    }
    
    func evacuate_faststr(t *maptype, h *hmap, oldbucket uintptr) {
    	b := (*bmap)(add(h.oldbuckets, oldbucket*uintptr(t.BucketSize)))
    	newbit := h.noldbuckets()
    	if !evacuated(b) {
    		// TODO: reuse overflow buckets instead of using new ones, if there
    		// is no iterator using the old buckets.  (If !oldIterator.)
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:17:26 UTC 2024
    - 15.3K bytes
    - Viewed (0)
Back to top