Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for SetupPlugin (0.14 sec)

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

    	if err != nil {
    		tb.Fatal(err)
    	}
    	informerFactory.Start(ctx.Done())
    	informerFactory.WaitForCacheSync(ctx.Done())
    	return p
    }
    
    // SetupPlugin creates a plugin using a framework handle that includes
    // the provided sharedLister.
    func SetupPlugin(
    	ctx context.Context,
    	tb testing.TB,
    	pf frameworkruntime.PluginFactory,
    	config runtime.Object,
    	sharedLister framework.SharedLister,
    ) framework.Plugin {
    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/podtopologyspread/plugin_test.go

    		},
    	}
    
    	for _, tc := range testcases {
    		t.Run(tc.name, func(t *testing.T) {
    			logger, ctx := ktesting.NewTestContext(t)
    			snapshot := cache.NewSnapshot(nil, nil)
    			pl := plugintesting.SetupPlugin(ctx, t, topologySpreadFunc, &config.PodTopologySpreadArgs{DefaultingType: config.ListDefaulting}, snapshot)
    			p := pl.(*PodTopologySpread)
    			actualHint, err := p.isSchedulableAfterNodeChange(logger, tc.pod, tc.oldNode, tc.newNode)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Dec 17 06:30:53 UTC 2023
    - 13K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/podtopologyspread/filtering_test.go

    		},
    	}
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			_, ctx := ktesting.NewTestContext(t)
    			snapshot := cache.NewSnapshot(tt.existingPods, tt.nodes)
    			pl := plugintesting.SetupPlugin(ctx, t, topologySpreadFunc, &config.PodTopologySpreadArgs{DefaultingType: config.ListDefaulting}, snapshot)
    			p := pl.(*PodTopologySpread)
    			p.enableNodeInclusionPolicyInPodTopologySpread = tt.enableNodeInclusionPolicy
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 10:42:29 UTC 2024
    - 143.1K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/plugins/noderesources/fit_test.go

    			}
    			state := framework.NewCycleState()
    			var nodeResourcesFunc = runtime.FactoryAdapter(plfeature.Features{}, NewFit)
    			pl := plugintesting.SetupPlugin(ctx, b, nodeResourcesFunc, &test.nodeResourcesFitArgs, cache.NewSnapshot(existingPods, nodes))
    			p := pl.(*Fit)
    
    			b.ResetTimer()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 57.4K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/podtopologyspread/scoring_test.go

    			existingPods, allNodes, filteredNodes := st.MakeNodesAndPodsForEvenPodsSpread(tt.pod.Labels, tt.existingPodsNum, tt.allNodesNum, tt.filteredNodesNum)
    			state := framework.NewCycleState()
    			pl := plugintesting.SetupPlugin(ctx, b, podTopologySpreadFunc, &config.PodTopologySpreadArgs{DefaultingType: config.ListDefaulting}, cache.NewSnapshot(existingPods, allNodes))
    			p := pl.(*PodTopologySpread)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 60K bytes
    - Viewed (0)
Back to top