- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for NewFramework (0.39 sec)
-
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) -
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) -
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) -
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) -
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)