Versions in this module Expand all Collapse all v1 v1.16.3 Nov 9, 2022 Changes in this version + const BalancedResourceAllocation + const EqualPriority + const EvenPodsSpreadPriority + const ImageLocalityPriority + const InterPodAffinityPriority + const LeastRequestedPriority + const MostRequestedPriority + const NodeAffinityPriority + const NodePreferAvoidPodsPriority + const RequestedToCapacityRatioPriority + const ResourceLimitsPriority + const SelectorSpreadPriority + const ServiceSpreadingPriority + const TaintTolerationPriority + var BalancedResourceAllocationMap = balancedResourcePriority.PriorityMap + var CalculateNodeAffinityPriorityReduce = NormalizeReduce(schedulerapi.MaxPriority, false) + var ComputeTaintTolerationPriorityReduce = NormalizeReduce(schedulerapi.MaxPriority, true) + var DefaultRequestedRatioResources = ResourceToWeightMap + var LeastRequestedPriorityMap = leastResourcePriority.PriorityMap + var MostRequestedPriorityMap = mostResourcePriority.PriorityMap + func CalculateEvenPodsSpreadPriority(pod *v1.Pod, nodeNameToInfo map[string]*schedulernodeinfo.NodeInfo, ...) (schedulerapi.HostPriorityList, error) + func CalculateNodeAffinityPriorityMap(pod *v1.Pod, meta interface{}, nodeInfo *schedulernodeinfo.NodeInfo) (schedulerapi.HostPriority, error) + func CalculateNodePreferAvoidPodsPriorityMap(pod *v1.Pod, meta interface{}, nodeInfo *schedulernodeinfo.NodeInfo) (schedulerapi.HostPriority, error) + func ComputeTaintTolerationPriorityMap(pod *v1.Pod, meta interface{}, nodeInfo *schedulernodeinfo.NodeInfo) (schedulerapi.HostPriority, error) + func EmptyPriorityMetadataProducer(pod *v1.Pod, nodeNameToInfo map[string]*schedulernodeinfo.NodeInfo) interface + func ImageLocalityPriorityMap(pod *v1.Pod, meta interface{}, nodeInfo *schedulernodeinfo.NodeInfo) (schedulerapi.HostPriority, error) + func NewNodeLabelPriority(label string, presence bool) (PriorityMapFunction, PriorityReduceFunction) + func NewSelectorSpreadPriority(serviceLister algorithm.ServiceLister, ...) (PriorityMapFunction, PriorityReduceFunction) + func NewServiceAntiAffinityPriority(podLister algorithm.PodLister, serviceLister algorithm.ServiceLister, ...) (PriorityMapFunction, PriorityReduceFunction) + func ResourceLimitsPriorityMap(pod *v1.Pod, meta interface{}, nodeInfo *schedulernodeinfo.NodeInfo) (schedulerapi.HostPriority, error) + type FunctionShape []FunctionShapePoint + func NewFunctionShape(points []FunctionShapePoint) (FunctionShape, error) + type FunctionShapePoint struct + Score int64 + Utilization int64 + type InterPodAffinity struct + func (ipa *InterPodAffinity) CalculateInterPodAffinityPriority(pod *v1.Pod, nodeNameToInfo map[string]*schedulernodeinfo.NodeInfo, ...) (schedulerapi.HostPriorityList, error) + type NodeLabelPrioritizer struct + func (n *NodeLabelPrioritizer) CalculateNodeLabelPriorityMap(pod *v1.Pod, meta interface{}, nodeInfo *schedulernodeinfo.NodeInfo) (schedulerapi.HostPriority, error) + type PriorityConfig struct + Function PriorityFunction + Map PriorityMapFunction + Name string + Reduce PriorityReduceFunction + Weight int + type PriorityFunction func(pod *v1.Pod, nodeNameToInfo map[string]*schedulernodeinfo.NodeInfo, ...) (schedulerapi.HostPriorityList, error) + func NewInterPodAffinityPriority(info predicates.NodeInfo, hardPodAffinityWeight int32) PriorityFunction + type PriorityMapFunction func(pod *v1.Pod, meta interface{}, nodeInfo *schedulernodeinfo.NodeInfo) (schedulerapi.HostPriority, error) + type PriorityMetadataFactory struct + func (pmf *PriorityMetadataFactory) PriorityMetadata(pod *v1.Pod, nodeNameToInfo map[string]*schedulernodeinfo.NodeInfo) interface{} + type PriorityMetadataProducer func(pod *v1.Pod, nodeNameToInfo map[string]*schedulernodeinfo.NodeInfo) interface + func NewPriorityMetadataFactory(serviceLister algorithm.ServiceLister, ...) PriorityMetadataProducer + type PriorityReduceFunction func(pod *v1.Pod, meta interface{}, ...) error + func NormalizeReduce(maxPriority int, reverse bool) PriorityReduceFunction + type ResourceAllocationPriority struct + Name string + func RequestedToCapacityRatioResourceAllocationPriority(scoringFunctionShape FunctionShape, resourceToWeightMap ResourceToWeightMap) *ResourceAllocationPriority + func RequestedToCapacityRatioResourceAllocationPriorityDefault() *ResourceAllocationPriority + func (r *ResourceAllocationPriority) PriorityMap(pod *v1.Pod, meta interface{}, nodeInfo *schedulernodeinfo.NodeInfo) (schedulerapi.HostPriority, error) + type ResourceToValueMap map[v1.ResourceName]int64 + type ResourceToWeightMap map[v1.ResourceName]int64 + type SelectorSpread struct + func (s *SelectorSpread) CalculateSpreadPriorityMap(pod *v1.Pod, meta interface{}, nodeInfo *schedulernodeinfo.NodeInfo) (schedulerapi.HostPriority, error) + func (s *SelectorSpread) CalculateSpreadPriorityReduce(pod *v1.Pod, meta interface{}, ...) error + type ServiceAntiAffinity struct + func (s *ServiceAntiAffinity) CalculateAntiAffinityPriorityMap(pod *v1.Pod, meta interface{}, nodeInfo *schedulernodeinfo.NodeInfo) (schedulerapi.HostPriority, error) + func (s *ServiceAntiAffinity) CalculateAntiAffinityPriorityReduce(pod *v1.Pod, meta interface{}, ...) error