Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for frameworkruntime (0.44 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
Back to top