Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for WithInformerFactory (0.43 sec)

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

    	informerFactory := informers.NewSharedInformerFactory(fake.NewSimpleClientset(objs...), 0)
    	fh, err := frameworkruntime.NewFramework(ctx, nil, nil,
    		frameworkruntime.WithSnapshotSharedLister(sharedLister),
    		frameworkruntime.WithInformerFactory(informerFactory))
    	if err != nil {
    		tb.Fatalf("Failed creating framework runtime: %v", err)
    	}
    	p, err := pf(ctx, config, fh)
    	if err != nil {
    		tb.Fatal(err)
    	}
    	informerFactory.Start(ctx.Done())
    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/scheduler_test.go

    	waitingPods := frameworkruntime.NewWaitingPodsMap()
    	fwk, err := tf.NewFramework(ctx,
    		registerPluginFuncs,
    		testSchedulerName,
    		frameworkruntime.WithClientSet(client),
    		frameworkruntime.WithInformerFactory(informerFactory),
    		frameworkruntime.WithEventRecorder(eventBroadcaster.NewRecorder(scheme.Scheme, testSchedulerName)),
    		frameworkruntime.WithWaitingPods(waitingPods),
    	)
    	if err != nil {
    		return nil, nil, err
    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/extender_test.go

    			for _, name := range test.nodes {
    				cache.AddNode(logger, createNode(name))
    			}
    			fwk, err := tf.NewFramework(
    				ctx,
    				test.registerPlugins, "",
    				runtime.WithClientSet(client),
    				runtime.WithInformerFactory(informerFactory),
    				runtime.WithPodNominator(internalqueue.NewPodNominator(informerFactory.Core().V1().Pods().Lister())),
    				runtime.WithLogger(logger),
    			)
    			if err != nil {
    				t.Fatal(err)
    			}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 19:07:19 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/preemption/preemption_test.go

    			fwk, err := tf.NewFramework(
    				ctx,
    				registeredPlugins, "",
    				frameworkruntime.WithPodNominator(internalqueue.NewPodNominator(informerFactory.Core().V1().Pods().Lister())),
    				frameworkruntime.WithInformerFactory(informerFactory),
    				frameworkruntime.WithParallelism(parallelism),
    				frameworkruntime.WithSnapshotSharedLister(internalcache.NewSnapshot(tt.testPods, tt.nodes)),
    				frameworkruntime.WithLogger(logger),
    			)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  5. pkg/scheduler/scheduler.go

    		frameworkruntime.WithComponentConfigVersion(options.componentConfigVersion),
    		frameworkruntime.WithClientSet(client),
    		frameworkruntime.WithKubeConfig(options.kubeConfig),
    		frameworkruntime.WithInformerFactory(informerFactory),
    		frameworkruntime.WithSnapshotSharedLister(snapshot),
    		frameworkruntime.WithCaptureProfile(frameworkruntime.CaptureProfile(options.frameworkCapturer)),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 20.8K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/volumebinding/volume_binding_test.go

    			defer cancel()
    			client := fake.NewSimpleClientset()
    			informerFactory := informers.NewSharedInformerFactory(client, 0)
    			opts := []runtime.Option{
    				runtime.WithClientSet(client),
    				runtime.WithInformerFactory(informerFactory),
    			}
    			fh, err := runtime.NewFramework(ctx, nil, nil, opts...)
    			if err != nil {
    				t.Fatal(err)
    			}
    
    			args := item.args
    			if args == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 32K bytes
    - Viewed (0)
  7. pkg/scheduler/schedule_one_test.go

    			snapshot := internalcache.NewSnapshot(test.pods, nodes)
    			fwk, err := tf.NewFramework(
    				ctx,
    				test.registerPlugins, "",
    				frameworkruntime.WithSnapshotSharedLister(snapshot),
    				frameworkruntime.WithInformerFactory(informerFactory),
    				frameworkruntime.WithPodNominator(internalqueue.NewPodNominator(informerFactory.Core().V1().Pods().Lister())),
    			)
    			if err != nil {
    				t.Fatal(err)
    			}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 128.1K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go

    			defer cancel()
    			f, err := tf.NewFramework(ctx, registeredPlugins, "",
    				frameworkruntime.WithClientSet(cs),
    				frameworkruntime.WithEventRecorder(&events.FakeRecorder{}),
    				frameworkruntime.WithInformerFactory(informerFactory),
    				frameworkruntime.WithPodNominator(internalqueue.NewPodNominator(informerFactory.Core().V1().Pods().Lister())),
    				frameworkruntime.WithExtenders(extenders),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 82.8K bytes
    - Viewed (0)
  9. pkg/scheduler/framework/plugins/podtopologyspread/scoring_test.go

    			f, err := frameworkruntime.NewFramework(ctx, nil, nil,
    				frameworkruntime.WithSnapshotSharedLister(cache.NewSnapshot(nil, tt.nodes)),
    				frameworkruntime.WithInformerFactory(informerFactory))
    			if err != nil {
    				t.Fatalf("Failed creating framework runtime: %v", err)
    			}
    			pl, err := New(ctx, &tt.config, f, feature.Features{})
    			if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 60K bytes
    - Viewed (0)
  10. pkg/scheduler/framework/runtime/framework.go

    func WithEventRecorder(recorder events.EventRecorder) Option {
    	return func(o *frameworkOptions) {
    		o.eventRecorder = recorder
    	}
    }
    
    // WithInformerFactory sets informer factory for the scheduling frameworkImpl.
    func WithInformerFactory(informerFactory informers.SharedInformerFactory) Option {
    	return func(o *frameworkOptions) {
    		o.informerFactory = informerFactory
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 60.9K bytes
    - Viewed (0)
Back to top