kubernetes/pkg/scheduler/eventhandlers.go

func (sched *Scheduler) addNodeToCache(obj interface{ … }

func (sched *Scheduler) updateNodeInCache(oldObj, newObj interface{ … }

func (sched *Scheduler) deleteNodeFromCache(obj interface{ … }

func (sched *Scheduler) addPodToSchedulingQueue(obj interface{ … }

func (sched *Scheduler) updatePodInSchedulingQueue(oldObj, newObj interface{ … }

func (sched *Scheduler) deletePodFromSchedulingQueue(obj interface{ … }

func (sched *Scheduler) addPodToCache(obj interface{ … }

func (sched *Scheduler) updatePodInCache(oldObj, newObj interface{ … }

func (sched *Scheduler) deletePodFromCache(obj interface{ … }

// assignedPod selects pods that are assigned (scheduled and running).
func assignedPod(pod *v1.Pod) bool { … }

// responsibleForPod returns true if the pod has asked to be scheduled by the given scheduler.
func responsibleForPod(pod *v1.Pod, profiles profile.Map) bool { … }

const syncedPollPeriod …

// WaitForHandlersSync waits for EventHandlers to sync.
// It returns true if it was successful, false if the controller should shut down
func (sched *Scheduler) WaitForHandlersSync(ctx context.Context) error { … }

// addAllEventHandlers is a helper function used in tests and in Scheduler
// to add event handlers for various informers.
func addAllEventHandlers(
	sched *Scheduler,
	informerFactory informers.SharedInformerFactory,
	dynInformerFactory dynamicinformer.DynamicSharedInformerFactory,
	resourceClaimCache *assumecache.AssumeCache,
	gvkMap map[framework.EventResource]framework.ActionType,
) error { … }

func preCheckForNode(nodeInfo *framework.NodeInfo) queue.PreEnqueueCheck { … }

// AdmissionCheck calls the filtering logic of noderesources/nodeport/nodeAffinity/nodename
// and returns the failure reasons. It's used in kubelet(pkg/kubelet/lifecycle/predicate.go) and scheduler.
// It returns the first failure if `includeAllFailures` is set to false; otherwise
// returns all failures.
func AdmissionCheck(pod *v1.Pod, nodeInfo *framework.NodeInfo, includeAllFailures bool) []AdmissionResult { … }

type AdmissionResult …