Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NewPriorityQueue (0.34 sec)

  1. pkg/scheduler/internal/queue/scheduling_queue.go

    	return &framework.QueuedPodInfo{
    		PodInfo:              &framework.PodInfo{Pod: pod},
    		UnschedulablePlugins: sets.New(plugins...),
    	}
    }
    
    // NewPriorityQueue creates a PriorityQueue object.
    func NewPriorityQueue(
    	lessFn framework.LessFunc,
    	informerFactory informers.SharedInformerFactory,
    	opts ...Option,
    ) *PriorityQueue {
    	options := defaultPriorityQueueOptions
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 61.4K bytes
    - Viewed (0)
  2. pkg/scheduler/internal/queue/scheduling_queue_test.go

    			cs := fake.NewSimpleClientset(tt.podInfo.Pod)
    			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())
    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