Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NewSchedulingQueue (0.32 sec)

  1. pkg/scheduler/scheduler.go

    		preEnqueuePluginMap[profileName] = profile.PreEnqueuePlugins()
    		queueingHintsPerProfile[profileName] = buildQueueingHintMap(profile.EnqueueExtensions())
    	}
    
    	podQueue := internalqueue.NewSchedulingQueue(
    		profiles[options.profiles[0].SchedulerName].QueueSortFunc(),
    		informerFactory,
    		internalqueue.WithPodInitialBackoffDuration(time.Duration(options.podInitialBackoffSeconds)*time.Second),
    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

    	// waiting to pop items can exit gracefully.
    	Close()
    	// Run starts the goroutines managing the queue.
    	Run(logger klog.Logger)
    }
    
    // NewSchedulingQueue initializes a priority queue as a new scheduling queue.
    func NewSchedulingQueue(
    	lessFn framework.LessFunc,
    	informerFactory informers.SharedInformerFactory,
    	opts ...Option) SchedulingQueue {
    	return NewPriorityQueue(lessFn, informerFactory, opts...)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 61.4K bytes
    - Viewed (0)
Back to top