Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for FakeFilter (0.17 sec)

  1. staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go

    	handler.ServeHTTP(w, req)
    
    	if !reflect.DeepEqual(reqDigestExpected, fakeFilter.requestDigestGot) {
    		t.Errorf("Expected RequestDigest to match, diff: %s", cmp.Diff(reqDigestExpected, fakeFilter.requestDigestGot))
    	}
    	if !reflect.DeepEqual(workExpected, fakeFilter.workEstimateGot) {
    		t.Errorf("Expected WorkEstimate to match, diff: %s", cmp.Diff(workExpected, fakeFilter.workEstimateGot))
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:40 UTC 2023
    - 52.6K bytes
    - Viewed (0)
  2. pkg/scheduler/schedule_one_test.go

    					},
    					UnschedulablePlugins: sets.New("FakeFilter"),
    				},
    			},
    		},
    		{
    			name: "test with extender which filters out some Nodes",
    			registerPlugins: []tf.RegisterPluginFunc{
    				tf.RegisterQueueSortPlugin(queuesort.Name, queuesort.New),
    				tf.RegisterFilterPlugin(
    					"FakeFilter",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 128.1K bytes
    - Viewed (0)
  3. pkg/scheduler/testing/framework/fake_plugins.go

    type FakeFilterPlugin struct {
    	NumFilterCalled         int32
    	FailedNodeReturnCodeMap map[string]framework.Code
    }
    
    // Name returns name of the plugin.
    func (pl *FakeFilterPlugin) Name() string {
    	return "FakeFilter"
    }
    
    // Filter invoked at the filter extension point.
    func (pl *FakeFilterPlugin) Filter(_ context.Context, _ *framework.CycleState, pod *v1.Pod, nodeInfo *framework.NodeInfo) *framework.Status {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 19:07:19 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go

    			fakePlugin := tf.FakeFilterPlugin{
    				FailedNodeReturnCodeMap: fakeFilterRCMap,
    			}
    			registeredPlugins := append([]tf.RegisterPluginFunc{
    				tf.RegisterFilterPlugin(
    					"FakeFilter",
    					func(_ context.Context, _ runtime.Object, fh framework.Handle) (framework.Plugin, error) {
    						return &fakePlugin, nil
    					},
    				)},
    				tf.RegisterQueueSortPlugin(queuesort.Name, queuesort.New),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 82.8K bytes
    - Viewed (0)
Back to top