Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for WithWaitingPods (0.15 sec)

  1. pkg/scheduler/scheduler.go

    		frameworkruntime.WithParallelism(int(options.parallelism)),
    		frameworkruntime.WithExtenders(extenders),
    		frameworkruntime.WithMetricsRecorder(metricsRecorder),
    		frameworkruntime.WithWaitingPods(waitingPods),
    	)
    	if err != nil {
    		return nil, fmt.Errorf("initializing profiles: %v", err)
    	}
    
    	if len(profiles) == 0 {
    		return nil, errors.New("at least one profile is required")
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 20.8K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/runtime/framework_test.go

    			profile := config.KubeSchedulerProfile{Plugins: configPlugins}
    			ctx, cancel := context.WithCancel(context.Background())
    			defer cancel()
    			f, err := newFrameworkWithQueueSortAndBind(ctx, registry, profile,
    				WithWaitingPods(NewWaitingPodsMap()),
    			)
    			if err != nil {
    				t.Fatalf("fail to create framework: %s", err)
    			}
    
    			status := f.RunPermitPlugins(ctx, nil, pod, "")
    			if !reflect.DeepEqual(status, tt.want) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 103K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/runtime/framework.go

    func WithMetricsRecorder(r *metrics.MetricAsyncRecorder) Option {
    	return func(o *frameworkOptions) {
    		o.metricsRecorder = r
    	}
    }
    
    // WithWaitingPods sets waitingPods for the scheduling frameworkImpl.
    func WithWaitingPods(wp *waitingPodsMap) Option {
    	return func(o *frameworkOptions) {
    		o.waitingPods = wp
    	}
    }
    
    // WithLogger overrides the default logger from k8s.io/klog.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 60.9K bytes
    - Viewed (0)
  4. pkg/scheduler/scheduler_test.go

    		frameworkruntime.WithClientSet(client),
    		frameworkruntime.WithInformerFactory(informerFactory),
    		frameworkruntime.WithEventRecorder(eventBroadcaster.NewRecorder(scheme.Scheme, testSchedulerName)),
    		frameworkruntime.WithWaitingPods(waitingPods),
    	)
    	if err != nil {
    		return nil, nil, err
    	}
    
    	s := &Scheduler{
    		Cache:           cache,
    		client:          client,
    		StopEverything:  ctx.Done(),
    		SchedulingQueue: queue,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 42K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go

    				frameworkruntime.WithExtenders(extenders),
    				frameworkruntime.WithSnapshotSharedLister(internalcache.NewSnapshot(tt.pods, tt.nodes)),
    				frameworkruntime.WithLogger(logger),
    				frameworkruntime.WithWaitingPods(frameworkruntime.NewWaitingPodsMap()),
    			)
    			if err != nil {
    				t.Fatal(err)
    			}
    			p := DefaultPreemption{
    				fh:        f,
    				podLister: informerFactory.Core().V1().Pods().Lister(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 82.8K bytes
    - Viewed (0)
  6. pkg/scheduler/schedule_one_test.go

    				registerPluginFuncs,
    				testSchedulerName,
    				frameworkruntime.WithClientSet(client),
    				frameworkruntime.WithEventRecorder(eventBroadcaster.NewRecorder(scheme.Scheme, testSchedulerName)),
    				frameworkruntime.WithWaitingPods(frameworkruntime.NewWaitingPodsMap()),
    			)
    			if err != nil {
    				t.Fatal(err)
    			}
    
    			sched := &Scheduler{
    				Cache:  cache,
    				client: client,
    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