kubernetes/pkg/scheduler/framework/runtime/waiting_pods_map.go

type waitingPodsMap …

// NewWaitingPodsMap returns a new waitingPodsMap.
func NewWaitingPodsMap() *waitingPodsMap { … }

// add a new WaitingPod to the map.
func (m *waitingPodsMap) add(wp *waitingPod) { … }

// remove a WaitingPod from the map.
func (m *waitingPodsMap) remove(uid types.UID) { … }

// get a WaitingPod from the map.
func (m *waitingPodsMap) get(uid types.UID) *waitingPod { … }

// iterate acquires a read lock and iterates over the WaitingPods map.
func (m *waitingPodsMap) iterate(callback func(framework.WaitingPod)) { … }

type waitingPod …

var _ …

// newWaitingPod returns a new waitingPod instance.
func newWaitingPod(pod *v1.Pod, pluginsMaxWaitTime map[string]time.Duration) *waitingPod { … }

// GetPod returns a reference to the waiting pod.
func (w *waitingPod) GetPod() *v1.Pod { … }

// GetPendingPlugins returns a list of pending permit plugin's name.
func (w *waitingPod) GetPendingPlugins() []string { … }

// Allow declares the waiting pod is allowed to be scheduled by plugin pluginName.
// If this is the last remaining plugin to allow, then a success signal is delivered
// to unblock the pod.
func (w *waitingPod) Allow(pluginName string) { … }

// Reject declares the waiting pod unschedulable.
func (w *waitingPod) Reject(pluginName, msg string) { … }