type getNodeAnyWayFuncType … type pluginResourceUpdateFuncType … type AdmissionFailureHandler … type predicateAdmitHandler … var _ … // NewPredicateAdmitHandler returns a PodAdmitHandler which is used to evaluates // if a pod can be admitted from the perspective of predicates. func NewPredicateAdmitHandler(getNodeAnyWayFunc getNodeAnyWayFuncType, admissionFailureHandler AdmissionFailureHandler, pluginResourceUpdateFunc pluginResourceUpdateFuncType) PodAdmitHandler { … } func (w *predicateAdmitHandler) Admit(attrs *PodAdmitAttributes) PodAdmitResult { … } // rejectPodAdmissionBasedOnOSSelector rejects pod if it's nodeSelector doesn't match // We expect the kubelet status reconcile which happens every 10sec to update the node labels if there is a mismatch. func rejectPodAdmissionBasedOnOSSelector(pod *v1.Pod, node *v1.Node) bool { … } // rejectPodAdmissionBasedOnOSField rejects pods if their OS field doesn't match runtime.GOOS. // TODO: Relax this restriction when we start supporting LCOW in kubernetes where podOS may not match // node's OS. func rejectPodAdmissionBasedOnOSField(pod *v1.Pod) bool { … } func removeMissingExtendedResources(pod *v1.Pod, nodeInfo *schedulerframework.NodeInfo) *v1.Pod { … } type InsufficientResourceError … func (e *InsufficientResourceError) Error() string { … } type PredicateFailureReason … // GetReason returns the reason of the InsufficientResourceError. func (e *InsufficientResourceError) GetReason() string { … } // GetInsufficientAmount returns the amount of the insufficient resource of the error. func (e *InsufficientResourceError) GetInsufficientAmount() int64 { … } type PredicateFailureError … func (e *PredicateFailureError) Error() string { … } // GetReason returns the reason of the PredicateFailureError. func (e *PredicateFailureError) GetReason() string { … } // generalFilter checks a group of filterings that the kubelet cares about. func generalFilter(pod *v1.Pod, nodeInfo *schedulerframework.NodeInfo) []PredicateFailureReason { … }
Codebase Browser
kubernetes