Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 13 of 13 for NewFramework (0.16 sec)

  1. pkg/scheduler/framework/runtime/framework.go

    		parallelizer:    parallelize.NewParallelizer(parallelize.DefaultParallelism),
    	}
    }
    
    var _ framework.Framework = &frameworkImpl{}
    
    // NewFramework initializes plugins given the configuration and the registry.
    func NewFramework(ctx context.Context, r Registry, profile *config.KubeSchedulerProfile, opts ...Option) (framework.Framework, error) {
    	options := defaultFrameworkOptions(ctx.Done())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 60.9K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/noderesources/fit_test.go

    			ctx, cancel := context.WithCancel(ctx)
    			defer cancel()
    
    			state := framework.NewCycleState()
    			snapshot := cache.NewSnapshot(test.existingPods, test.nodes)
    			fh, _ := runtime.NewFramework(ctx, nil, nil, runtime.WithSnapshotSharedLister(snapshot))
    			args := test.nodeResourcesFitArgs
    			p, err := NewFit(ctx, &args, fh, plfeature.Features{})
    			if err != nil {
    				t.Fatalf("unexpected error: %v", err)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 57.4K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go

    	opts := []runtime.Option{
    		runtime.WithClientSet(tc.client),
    		runtime.WithInformerFactory(tc.informerFactory),
    	}
    	fh, err := runtime.NewFramework(tCtx, nil, nil, opts...)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	pl, err := New(tCtx, nil, fh, feature.Features{EnableDynamicResourceAllocation: true})
    	if err != nil {
    		t.Fatal(err)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 07:57:10 UTC 2024
    - 61.9K bytes
    - Viewed (0)
Back to top