- Sort Score
- Result 10 results
- Languages All
Results 71 - 73 of 73 for Testfunc (0.1 sec)
-
pkg/scheduler/internal/queue/scheduling_queue.go
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...) } // NominatedNodeName returns nominated node name of a Pod.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework.go
return f.enqueueExtensions } // QueueSortFunc returns the function to sort pods in scheduling queue func (f *frameworkImpl) QueueSortFunc() framework.LessFunc { if f == nil { // If frameworkImpl is nil, simply keep their order unchanged. // NOTE: this is primarily for tests. return func(_, _ *framework.QueuedPodInfo) bool { return false } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 60.9K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue_test.go
t.Errorf("Expected medPriorityPodInfo and unschedulablePodInfo to be still present in nomindatePods: %v", q.nominator.nominatedPods["node1"]) } } func newDefaultQueueSort() framework.LessFunc { sort := &queuesort.PrioritySort{} return sort.Less } func TestPriorityQueue_AddWithReversePriorityLessFunc(t *testing.T) { objs := []runtime.Object{medPriorityPodInfo.Pod, highPriorityPodInfo.Pod}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0)