Kubernetes 调度器

for predicateKey, predicate := range predicateFuncs {
	fit, reasons, err = predicate(pod, meta, info)
	if err != nil {
		return false, []algorithm.PredicateFailureReason{}, err
	}
	if !fit {
		failedPredicates = append(failedPredicates, reasons...)
	}
}

fScore := maxPriority
if maxCountByNodeName > 0 {
	fScore = maxPriority * ((maxCountByNodeName - countsByNodeName[node.Name]) / maxCountByNodeName)
}
	
// If there is zone information present, incorporate it
if haveZones {
	zoneId := utilnode.GetZoneKey(node)
	if zoneId != "" {
		zoneScore := maxPriority * ((maxCountByZone - countsByZone[zoneId]) / maxCountByZone)
		fScore = (fScore * (1.0 - zoneWeighting)) + (zoneWeighting * zoneScore)
	}
}

fScore = cpu((capacity - sum(requested)) * 10 / capacity) + memory((capacity - sum(requested)) * 10 / capacity) / 2

fScore = 10 - abs(cpu(requested/capacity)-memory(requested/capacity))*10

fScore = (1.0 - float64(result[i].Score)/maxCountFloat) * 10

// URLPrefix at which the extender is available
URLPrefix string
// Verb for the filter call, empty if not supported. This verb is appended to the URLPrefix when issuing the filter call to extender.
FilterVerb string
// Verb for the prioritize call, empty if not supported. This verb is appended to the URLPrefix when issuing the prioritize call to extender.
PrioritizeVerb string
// The numeric multiplier for the node scores that the prioritize call generates.
// The weight should be a positive integer
Weight int
// Verb for the bind call, empty if not supported. This verb is appended to the URLPrefix when issuing the bind call to extender.
// If this method is implemented by the extender, it is the extender's responsibility to bind the pod to apiserver. Only one extender
// can implement this function.
BindVerb string
// EnableHttps specifies whether https should be used to communicate with the extender
EnableHttps bool
// TLSConfig specifies the transport layer security config
TLSConfig *restclient.TLSClientConfig
// HTTPTimeout specifies the timeout duration for a call to the extender. Filter timeout fails the scheduling of the pod. Prioritize
// timeout is ignored, k8s/other extenders priorities are used to select the node.
HTTPTimeout time.Duration
// NodeCacheCapable specifies that the extender is capable of caching node information,
// so the scheduler should only send minimal information about the eligible nodes
// assuming that the extender already cached full details of all nodes in the cluster
NodeCacheCapable bool

// ExtenderArgs represents the arguments needed by the extender to filter/prioritize
// nodes for a pod.
type ExtenderArgs struct {
	// Pod being scheduled
	Pod v1.Pod
	// List of candidate nodes where the pod can be scheduled; to be populated
	// only if ExtenderConfig.NodeCacheCapable == false
	Nodes *v1.NodeList
	// List of candidate node names where the pod can be scheduled; to be
	// populated only if ExtenderConfig.NodeCacheCapable == true
	NodeNames *[]string
}

// ExtenderFilterResult represents the results of a filter call to an extender
type ExtenderFilterResult struct {
	// Filtered set of nodes where the pod can be scheduled; to be populated
	// only if ExtenderConfig.NodeCacheCapable == false
	Nodes *v1.NodeList
	// Filtered set of nodes where the pod can be scheduled; to be populated
	// only if ExtenderConfig.NodeCacheCapable == true
	NodeNames *[]string
	// Filtered out nodes where the pod can't be scheduled and the failure messages
	FailedNodes FailedNodesMap
	// Error message indicating failure
	Error string
}

// ExtenderArgs represents the arguments needed by the extender to filter/prioritize
// nodes for a pod.
type ExtenderArgs struct {
	// Pod being scheduled
	Pod v1.Pod
	// List of candidate nodes where the pod can be scheduled; to be populated
	// only if ExtenderConfig.NodeCacheCapable == false
	Nodes *v1.NodeList
	// List of candidate node names where the pod can be scheduled; to be
	// populated only if ExtenderConfig.NodeCacheCapable == true
	NodeNames *[]string
}

type HostPriorityList []HostPriority

// ExtenderBindingArgs represents the arguments to an extender for binding a pod to a node.
type ExtenderBindingArgs struct {
	// PodName is the name of the pod being bound
	PodName string
	// PodNamespace is the namespace of the pod being bound
	PodNamespace string
	// PodUID is the UID of the pod being bound
	PodUID types.UID
	// Node selected by the scheduler
	Node string
}

// ExtenderBindingResult represents the result of binding of a pod to a node from an extender.
type ExtenderBindingResult struct {
	// Error message indicating failure
	Error string
}

type Cache interface {
	// AssumePod 假设一个 Pod 已经被调度， 并且把 pod 的信息聚合到对应的 Node 上。
	// 它的实现也决定了 Pod 在（通过接收 Add event)被确认前的过期策略。
	// 在过期后，它的信息会被删掉。
	AssumePod(pod *v1.Pod) error

	// FinishBinding 示意被假定的 Pod 的缓存可以被过期了。
	FinishBinding(pod *v1.Pod) error

	// ForgetPod 将一个被假定的 Pod 从缓存中移除。
	ForgetPod(pod *v1.Pod) error

	// AddPod 即确认了一个 Pod 是否假定了，如果它过期了还可以将它加回。
	// 如果被加回，Pod 的信息也会被加回。
	AddPod(pod *v1.Pod) error

	// UpdatePod 删除旧 Pod 的信息，加入新 Pod 的信息。
	UpdatePod(oldPod, newPod *v1.Pod) error

	// RemovePod 删除一个 Pod。Pod 的信息会从被分配的 Node 上删除。
	RemovePod(pod *v1.Pod) error

	// AddNode 添加一个 Node 的总体信息。
	AddNode(node *v1.Node) error

	// UpdateNode 更新 Node 的总体信息。
	UpdateNode(oldNode, newNode *v1.Node) error

	// RemoveNode 删除 Node 的总体信息。
	RemoveNode(node *v1.Node) error

	// UpdateNodeNameToInfoMap 将传入的 infoMap 更新到现有的缓存中。
	// Node 信息包括这个节点上已被调度或者假定的 Pod 聚合信息。
	UpdateNodeNameToInfoMap(infoMap map[string]*NodeInfo) error
	
	// 列出所有被缓存的 Pod （包括假定的）。
	List(labels.Selector) ([]*v1.Pod, error)
}