Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for SetupPluginWithInformers (0.4 sec)

  1. pkg/scheduler/framework/plugins/volumerestrictions/volume_restrictions_test.go

    	}
    	snapshot := cache.NewSnapshot(pods, nodes)
    
    	objects := make([]runtime.Object, 0, len(pvcs))
    	for _, pvc := range pvcs {
    		objects = append(objects, pvc)
    	}
    
    	return plugintesting.SetupPluginWithInformers(ctx, t, pluginFactory, &config.InterPodAffinityArgs{}, snapshot, objects)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 20 17:40:39 UTC 2023
    - 17.3K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/volumezone/volume_zone_test.go

    	objects := make([]runtime.Object, 0, len(pvcs))
    	for _, pvc := range pvcs {
    		objects = append(objects, pvc)
    	}
    	for _, pv := range pvs {
    		objects = append(objects, pv)
    	}
    	return plugintesting.SetupPluginWithInformers(ctx, tb, New, &config.InterPodAffinityArgs{}, snapshot, objects)
    }
    
    func makePVsWithZoneLabel(num int) []*v1.PersistentVolume {
    	pvList := make([]*v1.PersistentVolume, num, num)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 14 05:17:04 UTC 2023
    - 20K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/interpodaffinity/scoring_test.go

    		t.Run(test.name, func(t *testing.T) {
    			_, ctx := ktesting.NewTestContext(t)
    			ctx, cancel := context.WithCancel(ctx)
    			defer cancel()
    			state := framework.NewCycleState()
    			p := plugintesting.SetupPluginWithInformers(ctx, t, New, &config.InterPodAffinityArgs{HardPodAffinityWeight: 1, IgnorePreferredTermsOfExistingPods: test.ignorePreferredTermsOfExistingPods}, cache.NewSnapshot(test.pods, test.nodes), namespaces)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 44.8K bytes
    - Viewed (0)
Back to top