Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 73 of 73 for Testfunc (0.1 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top