- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for frameworkruntime (0.44 sec)
-
pkg/scheduler/framework/plugins/testing/testing.go
ctx context.Context, tb testing.TB, pf frameworkruntime.PluginFactory, config runtime.Object, sharedLister framework.SharedLister, ) framework.Plugin { fh, err := frameworkruntime.NewFramework(ctx, nil, nil, frameworkruntime.WithSnapshotSharedLister(sharedLister)) if err != nil { tb.Fatalf("Failed creating framework runtime: %v", err) } p, err := pf(ctx, config, fh) if err != nil { tb.Fatal(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/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 = 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. func NewMap(ctx context.Context, cfgs []config.KubeSchedulerProfile, r frameworkruntime.Registry, recorderFact RecorderFactory,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 06 01:11:19 UTC 2024 - 4K bytes - Viewed (0) -
pkg/scheduler/testing/framework/fake_plugins.go
*/ package framework import ( "context" "fmt" "sync/atomic" "time" v1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/runtime" "k8s.io/kubernetes/pkg/scheduler/framework" frameworkruntime "k8s.io/kubernetes/pkg/scheduler/framework/runtime" ) // ErrReasonFake is a fake error message denotes the filter function errored. const ErrReasonFake = "Nodes failed the fake plugin"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 19:07:19 UTC 2024 - 9.5K bytes - Viewed (0) -
pkg/scheduler/profile/profile_test.go
"k8s.io/client-go/tools/events" "k8s.io/klog/v2/ktesting" "k8s.io/kubernetes/pkg/scheduler/apis/config" "k8s.io/kubernetes/pkg/scheduler/framework" frameworkruntime "k8s.io/kubernetes/pkg/scheduler/framework/runtime" ) var fakeRegistry = frameworkruntime.Registry{ "QueueSort": newFakePlugin("QueueSort"), "Bind1": newFakePlugin("Bind1"), "Bind2": newFakePlugin("Bind2"), "Another": newFakePlugin("Another"), }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 20 09:49:54 UTC 2023 - 6.6K bytes - Viewed (0)