const queueMetricMetadata …
var nodeAdd …
var pvAdd …
var pvUpdate …
var pvcAdd …
var csiNodeUpdate …
var (
lowPriority …
midPriority …
highPriority …
)
var mediumPriority …
var highPriorityPodInfo …
var highPriNominatedPodInfo …
var medPriorityPodInfo …
var unschedulablePodInfo …
var nonExistentPodInfo …
var scheduledPodInfo …
var nominatorCmpOpts …
var queueHintReturnQueue …
var queueHintReturnSkip …
func setQueuedPodInfoGated(queuedPodInfo *framework.QueuedPodInfo) *framework.QueuedPodInfo { … }
func getUnschedulablePod(p *PriorityQueue, pod *v1.Pod) *v1.Pod { … }
func makeEmptyQueueingHintMapPerProfile() QueueingHintMapPerProfile { … }
func TestPriorityQueue_Add(t *testing.T) { … }
func newDefaultQueueSort() framework.LessFunc { … }
func TestPriorityQueue_AddWithReversePriorityLessFunc(t *testing.T) { … }
func Test_InFlightPods(t *testing.T) { … }
func popPod(t *testing.T, logger klog.Logger, q *PriorityQueue, pod *v1.Pod) *framework.QueuedPodInfo { … }
func TestPop(t *testing.T) { … }
func TestPriorityQueue_AddUnschedulableIfNotPresent(t *testing.T) { … }
func TestPriorityQueue_AddUnschedulableIfNotPresent_Backoff(t *testing.T) { … }
func TestPriorityQueue_Pop(t *testing.T) { … }
func TestPriorityQueue_Update(t *testing.T) { … }
func TestPriorityQueue_UpdateWhenInflight(t *testing.T) { … }
func TestPriorityQueue_Delete(t *testing.T) { … }
func TestPriorityQueue_Activate(t *testing.T) { … }
type preEnqueuePlugin …
func (pl *preEnqueuePlugin) Name() string { … }
func (pl *preEnqueuePlugin) PreEnqueue(ctx context.Context, p *v1.Pod) *framework.Status { … }
func TestPriorityQueue_addToActiveQ(t *testing.T) { … }
func BenchmarkMoveAllToActiveOrBackoffQueue(b *testing.B) { … }
func TestPriorityQueue_MoveAllToActiveOrBackoffQueueWithQueueingHint(t *testing.T) { … }
func TestPriorityQueue_MoveAllToActiveOrBackoffQueue(t *testing.T) { … }
func TestPriorityQueue_MoveAllToActiveOrBackoffQueueWithOutQueueingHint(t *testing.T) { … }
func clonePod(pod *v1.Pod, newName string) *v1.Pod { … }
func expectInFlightPods(t *testing.T, q *PriorityQueue, uids ...types.UID) { … }
func TestPriorityQueue_AssignedPodAdded_(t *testing.T) { … }
func TestPriorityQueue_AssignedPodUpdated(t *testing.T) { … }
func TestPriorityQueue_NominatedPodsForNode(t *testing.T) { … }
func TestPriorityQueue_NominatedPodDeleted(t *testing.T) { … }
func TestPriorityQueue_PendingPods(t *testing.T) { … }
func TestPriorityQueue_UpdateNominatedPodForNode(t *testing.T) { … }
func TestPriorityQueue_NewWithOptions(t *testing.T) { … }
func TestUnschedulablePodsMap(t *testing.T) { … }
func TestSchedulingQueue_Close(t *testing.T) { … }
func TestRecentlyTriedPodsGoBack(t *testing.T) { … }
func TestPodFailedSchedulingMultipleTimesDoesNotBlockNewerPod(t *testing.T) { … }
func TestHighPriorityBackoff(t *testing.T) { … }
func TestHighPriorityFlushUnschedulablePodsLeftover(t *testing.T) { … }
func TestPriorityQueue_initPodMaxInUnschedulablePodsDuration(t *testing.T) { … }
type operation …
var add …
var popAndRequeueAsUnschedulable …
var popAndRequeueAsBackoff …
var addPodActiveQ …
var addPodActiveQDirectly …
var addPodUnschedulablePods …
var deletePod …
var updatePodQueueable …
var addPodBackoffQ …
var moveAllToActiveOrBackoffQ …
var flushBackoffQ …
var moveClockForward …
var flushUnscheduledQ …
func TestPodTimestamp(t *testing.T) { … }
func TestPendingPodsMetric(t *testing.T) { … }
func TestPerPodSchedulingMetrics(t *testing.T) { … }
func TestIncomingPodsMetrics(t *testing.T) { … }
func TestBackOffFlow(t *testing.T) { … }
func TestMoveAllToActiveOrBackoffQueue_PreEnqueueChecks(t *testing.T) { … }
func makeQueuedPodInfos(num int, namePrefix, label string, timestamp time.Time) []*framework.QueuedPodInfo { … }
func TestPriorityQueue_calculateBackoffDuration(t *testing.T) { … }
func mustNewTestPodInfo(t *testing.T, pod *v1.Pod) *framework.PodInfo { … }
func mustNewPodInfo(pod *v1.Pod) *framework.PodInfo { … }
func Test_isPodWorthRequeuing(t *testing.T) { … }
func Test_queuedPodInfo_gatedSetUponCreationAndUnsetUponUpdate(t *testing.T) { … }
func TestPriorityQueue_GetPod(t *testing.T) { … }
func attemptQueuedPodInfo(podInfo *framework.QueuedPodInfo) *framework.QueuedPodInfo { … }