Documentation
¶
Index ¶
- type PreEnqueueCheck
- type SchedulingQueue
- func (s *SchedulingQueue) Add(pod *v1.Pod) error
- func (s *SchedulingQueue) AddUnschedulable(pInfo *framework.QueuedPodInfo) error
- func (s *SchedulingQueue) AssignedPodAdded(pod *v1.Pod)
- func (s *SchedulingQueue) AssignedPodUpdated(pod *v1.Pod)
- func (s *SchedulingQueue) Delete(pod *v1.Pod) error
- func (s *SchedulingQueue) MoveAllToActiveOrBackoffQueue(event framework.ClusterEvent)
- func (s *SchedulingQueue) NextPod() *v1.Pod
- func (s *SchedulingQueue) Update(oldPod, newPod *v1.Pod) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PreEnqueueCheck ¶
PreEnqueueCheck is a function type. It's used to build functions that run against a Pod and the caller can choose to enqueue or skip the Pod by the checking result.
type SchedulingQueue ¶
type SchedulingQueue struct {
// contains filtered or unexported fields
}
func New ¶
func New(clusterEventMap map[framework.ClusterEvent]sets.String) *SchedulingQueue
func (*SchedulingQueue) AddUnschedulable ¶
func (s *SchedulingQueue) AddUnschedulable(pInfo *framework.QueuedPodInfo) error
func (*SchedulingQueue) AssignedPodAdded ¶
func (s *SchedulingQueue) AssignedPodAdded(pod *v1.Pod)
AssignedPodAdded is called when a bound pod is added. Creation of this pod may make pending pods with matching affinity terms schedulable.
func (*SchedulingQueue) AssignedPodUpdated ¶
func (s *SchedulingQueue) AssignedPodUpdated(pod *v1.Pod)
AssignedPodUpdated is called when a bound pod is updated. Change of labels may make pending pods with matching affinity terms schedulable.
func (*SchedulingQueue) MoveAllToActiveOrBackoffQueue ¶
func (s *SchedulingQueue) MoveAllToActiveOrBackoffQueue(event framework.ClusterEvent)
MoveAllToActiveOrBackoffQueue moves all pods from unschedulableQ to activeQ or backoffQ. This function adds all pods and then signals the condition variable to ensure that if Pop() is waiting for an item, it receives the signal after all the pods are in the queue and the head is the highest priority pod.
func (*SchedulingQueue) NextPod ¶
func (s *SchedulingQueue) NextPod() *v1.Pod
Source Files