Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for NewFramework (0.16 sec)

  1. pkg/scheduler/framework/plugins/testing/testing.go

    	objs = append([]runtime.Object{&v1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: ""}}}, objs...)
    	informerFactory := informers.NewSharedInformerFactory(fake.NewSimpleClientset(objs...), 0)
    	fh, err := frameworkruntime.NewFramework(ctx, nil, nil,
    		frameworkruntime.WithSnapshotSharedLister(sharedLister),
    		frameworkruntime.WithInformerFactory(informerFactory))
    	if err != nil {
    		tb.Fatalf("Failed creating framework runtime: %v", err)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 20 09:49:54 UTC 2023
    - 2.5K bytes
    - Viewed (0)
  2. pkg/scheduler/testing/framework/framework_helpers.go

    	"k8s.io/kubernetes/pkg/scheduler/framework"
    	"k8s.io/kubernetes/pkg/scheduler/framework/runtime"
    )
    
    var configDecoder = scheme.Codecs.UniversalDecoder()
    
    // NewFramework creates a Framework from the register functions and options.
    func NewFramework(ctx context.Context, fns []RegisterPluginFunc, profileName string, opts ...runtime.Option) (framework.Framework, error) {
    	registry := runtime.Registry{}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 6.3K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/autoscaler_contract/framework_contract_test.go

    	var f framework.Framework
    	var c frameworkContract = f
    	assert.Nil(t, c)
    }
    
    func TestNewFramework(t *testing.T) {
    	_, ctx := ktesting.NewTestContext(t)
    	var f interface{}
    	if f, _ = runtime.NewFramework(ctx, nil, nil); f != nil {
    		_, ok := f.(framework.Framework)
    		assert.True(t, ok)
    	}
    }
    
    func TestNewCycleState(t *testing.T) {
    	var state interface{} = framework.NewCycleState()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 23 02:17:34 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/plugins/defaultbinder/default_binder_test.go

    					return true, nil, tt.injectErr
    				}
    				gotBinding = action.(clienttesting.CreateAction).GetObject().(*v1.Binding)
    				return true, gotBinding, nil
    			})
    
    			fh, err := frameworkruntime.NewFramework(ctx, nil, nil, frameworkruntime.WithClientSet(client))
    			if err != nil {
    				t.Fatal(err)
    			}
    			binder := &DefaultBinder{handle: fh}
    			status := binder.Bind(ctx, nil, testPod, testNode)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 23 02:17:34 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  5. pkg/scheduler/profile/profile.go

    	opts ...frameworkruntime.Option) (framework.Framework, error) {
    	recorder := recorderFact(cfg.SchedulerName)
    	opts = append(opts, frameworkruntime.WithEventRecorder(recorder))
    	return frameworkruntime.NewFramework(ctx, r, &cfg, opts...)
    }
    
    // Map holds frameworks indexed by scheduler name.
    type Map map[string]framework.Framework
    
    // NewMap builds the frameworks given by the configuration, indexed by name.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jan 06 01:11:19 UTC 2024
    - 4K bytes
    - Viewed (0)
Back to top