带你畅游k8s调度器！

   // node快照  if err := sched.Cache.UpdateSnapshot(sched.nodeInfoSnapshot); err != nil {    return result, err  }      // 过滤  feasibleNodes, diagnosis, err := sched.findNodesThatFitPod(ctx, fwk, state, pod)  if err != nil {    return result, err  }        // 打分  priorityList, err := prioritizeNodes(ctx, sched.Extenders, fwk, state, pod, feasibleNodes)  if err != nil {    return result, err  }        // 随机筛选  host, err := selectHost(priorityList)

// QueueSort is a list of plugins that should be invoked when sorting pods in the scheduling queue.QueueSort PluginSet `json:"queueSort,omitempty"`
// PreFilter is a list of plugins that should be invoked at "PreFilter" extension point of the scheduling framework.PreFilter PluginSet `json:"preFilter,omitempty"`
// Filter is a list of plugins that should be invoked when filtering out nodes that cannot run the Pod.Filter PluginSet `json:"filter,omitempty"`
// PostFilter is a list of plugins that are invoked after filtering phase, but only when no feasible nodes were found for the pod.PostFilter PluginSet `json:"postFilter,omitempty"`
// PreScore is a list of plugins that are invoked before scoring.PreScore PluginSet `json:"preScore,omitempty"`
// Score is a list of plugins that should be invoked when ranking nodes that have passed the filtering phase.Score PluginSet `json:"score,omitempty"`
// Reserve is a list of plugins invoked when reserving/unreserving resources// after a node is assigned to run the pod.Reserve PluginSet `json:"reserve,omitempty"`
// Permit is a list of plugins that control binding of a Pod. These plugins can prevent or delay binding of a Pod.Permit PluginSet `json:"permit,omitempty"`
// PreBind is a list of plugins that should be invoked before a pod is bound.PreBind PluginSet `json:"preBind,omitempty"`
// Bind is a list of plugins that should be invoked at "Bind" extension point of the scheduling framework.// The scheduler call these plugins in order. Scheduler skips the rest of these plugins as soon as one returns success.Bind PluginSet `json:"bind,omitempty"`
// PostBind is a list of plugins that should be invoked after a pod is successfully bound.PostBind PluginSet `json:"postBind,omitempty"`
// MultiPoint is a simplified config section to enable plugins for all valid extension points.MultiPoint PluginSet `json:"multiPoint,omitempty"`

"PrioritySort" : "DefaultBinder""DefaultPreemption""ImageLocality""InterPodAffinity""NodeAffinity""NodeName""NodePorts""NodeResourcesBalancedAllocation""NodeResourcesFit""NodeUnschedulable""NodeVolumeLimits""AzureDiskLimits""CinderLimits""EBSLimits""GCEPDLimits""PodTopologySpread""SelectorSpread""ServiceAffinity""TaintToleration""VolumeBinding""VolumeRestrictions""VolumeZone"

type ScorePlugin interface {  Plugin  // Score is called on each filtered node. It must return success and an integer  // indicating the rank of the node. All scoring plugins must return success or  // the pod will be rejected.  Score(ctx context.Context, state *CycleState, p *v1.Pod, nodeName string) (int64, *Status)
  // ScoreExtensions returns a ScoreExtensions interface if it implements one, or nil if does not.  ScoreExtensions() ScoreExtensions}

// 亲和性，反亲和性判定判定if hasPreferredAffinityConstraints || hasPreferredAntiAffinityConstraints {    for _, existingPod := range podsToProcess {      pl.processExistingPod(state, existingPod, nodeInfo, pod, topoScore)    }      topoScores[atomic.AddInt32(&index, 1)] = topoScore}

    // 尽可能不调度  TaintEffectPreferNoSchedule TaintEffect = "PreferNoSchedule"        // 一定不调度  TaintEffectNoSchedule TaintEffect = "NoSchedule"    // 一定不调度且驱逐  TaintEffectNoExecute TaintEffect = "NoExecute"

   {      "name": "BalancedResourceAllocation",      "weight": 1    },    {      "name": "EvenPodsSpreadPriority",      "weight": 1    },    {      "name": "InterPodAffinityPriority",      "weight": 1    },    {      "name": "LeastRequestedPriority",      "weight": 1    },    {      "name": "NodeAffinityPriority",      "weight": 1    },    {      "name": "NodePreferAvoidPodsPriority",      "weight": 10000    },    {      "name": "SelectorSpreadPriority",      "weight": 1    },    {      "name": "TaintTolerationPriority",      "weight": 1    }

"extenders": [{    "urlPrefix": "http://xxx/prefix",    "filterVerb": "filter",    "weight": 1,    "bindVerb": "bind",    "enableHttps": false}]

import (    scheduler "k8s.io/kubernetes/cmd/kube-scheduler/app")
func main() {    command := scheduler.NewSchedulerCommand(            scheduler.WithPlugin("my-plugin", MyPlugin))    if err := command.Execute(); err != nil {        fmt.Fprintf(os.Stderr, "%v\n", err)    }}