Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for WithPodLister (0.13 sec)

  1. pkg/scheduler/scheduler.go

    		internalqueue.WithPodInitialBackoffDuration(time.Duration(options.podInitialBackoffSeconds)*time.Second),
    		internalqueue.WithPodMaxBackoffDuration(time.Duration(options.podMaxBackoffSeconds)*time.Second),
    		internalqueue.WithPodLister(podLister),
    		internalqueue.WithPodMaxInUnschedulablePodsDuration(options.podMaxInUnschedulablePodsDuration),
    		internalqueue.WithPreEnqueuePluginMap(preEnqueuePluginMap),
    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/internal/queue/scheduling_queue.go

    func WithPodMaxBackoffDuration(duration time.Duration) Option {
    	return func(o *priorityQueueOptions) {
    		o.podMaxBackoffDuration = duration
    	}
    }
    
    // WithPodLister sets pod lister for PriorityQueue.
    func WithPodLister(pl listersv1.PodLister) Option {
    	return func(o *priorityQueueOptions) {
    		o.podLister = pl
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 61.4K bytes
    - Viewed (0)
  3. pkg/scheduler/internal/queue/scheduling_queue_test.go

    			informerFactory := informers.NewSharedInformerFactory(cs, 0)
    			podLister := informerFactory.Core().V1().Pods().Lister()
    
    			// Build a PriorityQueue.
    			q := NewPriorityQueue(newDefaultQueueSort(), informerFactory, WithPodLister(podLister))
    			ctx, cancel := context.WithCancel(context.Background())
    			defer cancel()
    			informerFactory.Start(ctx.Done())
    			informerFactory.WaitForCacheSync(ctx.Done())
    
    			if tt.deletePod {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 146.9K bytes
    - Viewed (0)
Back to top