Versions in this module Expand all Collapse all v1 v1.16.3 Nov 9, 2022 Changes in this version + func MakeNextPodFunc(queue SchedulingQueue) func() *v1.Pod + func NominatedNodeName(pod *v1.Pod) string + type PodBackoffMap struct + func NewPodBackoffMap(initialDuration, maxDuration time.Duration) *PodBackoffMap + func (pbm *PodBackoffMap) BackoffPod(nsPod ktypes.NamespacedName) + func (pbm *PodBackoffMap) CleanupPodsCompletesBackingoff() + func (pbm *PodBackoffMap) ClearPodBackoff(nsPod ktypes.NamespacedName) + func (pbm *PodBackoffMap) GetBackoffTime(nsPod ktypes.NamespacedName) (time.Time, bool) + type PriorityQueue struct + func NewPriorityQueue(stop <-chan struct{}, fwk framework.Framework) *PriorityQueue + func NewPriorityQueueWithClock(stop <-chan struct{}, clock util.Clock, fwk framework.Framework) *PriorityQueue + func (p *PriorityQueue) Add(pod *v1.Pod) error + func (p *PriorityQueue) AddIfNotPresent(pod *v1.Pod) error + func (p *PriorityQueue) AddUnschedulableIfNotPresent(pod *v1.Pod, podSchedulingCycle int64) error + func (p *PriorityQueue) AssignedPodAdded(pod *v1.Pod) + func (p *PriorityQueue) AssignedPodUpdated(pod *v1.Pod) + func (p *PriorityQueue) Close() + func (p *PriorityQueue) Delete(pod *v1.Pod) error + func (p *PriorityQueue) DeleteNominatedPodIfExists(pod *v1.Pod) + func (p *PriorityQueue) MoveAllToActiveQueue() + func (p *PriorityQueue) NominatedPodsForNode(nodeName string) []*v1.Pod + func (p *PriorityQueue) NumUnschedulablePods() int + func (p *PriorityQueue) PendingPods() []*v1.Pod + func (p *PriorityQueue) Pop() (*v1.Pod, error) + func (p *PriorityQueue) SchedulingCycle() int64 + func (p *PriorityQueue) Update(oldPod, newPod *v1.Pod) error + func (p *PriorityQueue) UpdateNominatedPodForNode(pod *v1.Pod, nodeName string) + type SchedulingQueue interface + Add func(pod *v1.Pod) error + AddIfNotPresent func(pod *v1.Pod) error + AddUnschedulableIfNotPresent func(pod *v1.Pod, podSchedulingCycle int64) error + AssignedPodAdded func(pod *v1.Pod) + AssignedPodUpdated func(pod *v1.Pod) + Close func() + Delete func(pod *v1.Pod) error + DeleteNominatedPodIfExists func(pod *v1.Pod) + MoveAllToActiveQueue func() + NominatedPodsForNode func(nodeName string) []*v1.Pod + NumUnschedulablePods func() int + PendingPods func() []*v1.Pod + Pop func() (*v1.Pod, error) + SchedulingCycle func() int64 + Update func(oldPod, newPod *v1.Pod) error + UpdateNominatedPodForNode func(pod *v1.Pod, nodeName string) + func NewSchedulingQueue(stop <-chan struct{}, fwk framework.Framework) SchedulingQueue + type UnschedulablePodsMap struct
Go to main page