queue

Documentation

Index

• type PreEnqueueCheck
• type SchedulingQueue
  • func New(clusterEventMap map[framework.ClusterEvent]sets.String) *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

Types

type PreEnqueueCheck

type PreEnqueueCheck func(pod *v1.Pod) bool

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) Add

func (s *SchedulingQueue) Add(pod *v1.Pod) error

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) Delete

func (s *SchedulingQueue) Delete(pod *v1.Pod) error

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

func (*SchedulingQueue) Update

func (s *SchedulingQueue) Update(oldPod, newPod *v1.Pod) error