Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewFakePermitPlugin (0.35 sec)

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

    func (pl *FakePermitPlugin) Permit(_ context.Context, _ *framework.CycleState, _ *v1.Pod, _ string) (*framework.Status, time.Duration) {
    	return pl.Status, pl.Timeout
    }
    
    // NewFakePermitPlugin initializes a fakePermitPlugin and returns it.
    func NewFakePermitPlugin(status *framework.Status, timeout time.Duration) frameworkruntime.PluginFactory {
    	return func(_ context.Context, _ runtime.Object, _ framework.Handle) (framework.Plugin, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 19:07:19 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  2. pkg/scheduler/scheduler_test.go

    			eventRecorder := eventBroadcaster.NewRecorder(scheme.Scheme, fakePermit)
    
    			outOfTreeRegistry := frameworkruntime.Registry{
    				fakePermit: newFakePermitPlugin(eventRecorder),
    			}
    
    			_, ctx := ktesting.NewTestContext(t)
    			ctx, cancel := context.WithCancel(ctx)
    			defer cancel()
    
    			scheduler, err := New(
    				ctx,
    				fakeClient,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 42K bytes
    - Viewed (0)
  3. pkg/scheduler/schedule_one_test.go

    			mockResult: mockScheduleResult{ScheduleResult{SuggestedHost: testNode.Name, EvaluatedNodes: 1, FeasibleNodes: 1}, nil},
    			registerPluginFuncs: []tf.RegisterPluginFunc{
    				tf.RegisterPermitPlugin("FakePermit", tf.NewFakePermitPlugin(framework.NewStatus(framework.Error, "permit error"), time.Minute)),
    			},
    			expectErrorPod:   podWithID("foo", testNode.Name),
    			expectForgetPod:  podWithID("foo", testNode.Name),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 128.1K bytes
    - Viewed (0)
Back to top