Kubernetes资源调度Go语言实现实例-Golang-PHP中文网

Go语言无法直接控制Kubernetes Pod调度，必须通过Binding API强制绑定、开发自定义调度器插件或使用affinity/taint等声明式配置；其中Binding API是唯一运行时绕过调度器的合法方式。

kubernetes资源调度go语言实现实例

Go语言本身不参与Kubernetes的Pod调度决策——那是kube-scheduler的事。你无法在自己的Go程序里调用某个函数“让这个Pod调度到node-3”。真要干预调度，只有三条路：改配置、写插件、或自己造轮子。

为什么直接调用client-go的Create方法不能控制调度节点

很多人试过用client-go创建Pod后加spec.nodeName字段，以为能“指定节点”，结果发现要么报错field is immutable，要么Pod卡在Pending状态。这是因为：

spec.nodeName只能由scheduler或binding controller设置，用户提交时设了会被API Server拒绝（除非你有bind权限且走Binding API）
即使绕过校验强行写入，kubelet会忽略该字段，因为没经过调度器的admission和predicate流程
真正生效的节点绑定动作，必须通过POST /api/v1/namespaces/{ns}/pods/{name}/binding发起，且需提前构造Binding对象

用Go实现Binding API强制绑定Pod到指定节点

这是少数能在运行时“绕过调度器”的合法方式，适合调试、灾备或特殊硬件调度场景。关键点：

必须先创建一个未调度的Pod（不设nodeName，也不依赖默认调度器）
构造v1.Binding对象，其中Target.Name填目标节点名，Target.Kind固定为Node
用corev1.PodBinding客户端调用Bind()方法，注意context和namespace不能错
绑定失败常见原因是节点不存在、Pod已终止、或RBAC没授予bind权限

示例片段：

binding := &corev1.Binding{
    ObjectMeta: metav1.ObjectMeta{Namespace: "default"},
    Target: corev1.ObjectReference{
        Kind: "Node",
        Name: "node-2",
    },
}
err := client.CoreV1().Pods("default").Bind(context.TODO(), "my-pod", binding, metav1.CreateOptions{})

自定义调度器不是“写个Go函数就行”

所谓“用Go写调度器”，本质是实现一个独立服务，监听/apis/xxx/v1/pods事件，再调用Binding API完成调度。但要注意：

Kubernetes Network Policy Generator

使用加权评分卡在12项标准上评估和比较隐私解决方案供应商。适用于选择隐私管理软件、比较数据保护方案等场景。

下载

你得自己实现Filter（比如检查节点是否有GPU标签）、Score（比如按内存剩余量打分）、Reserve（防止并发冲突）逻辑
必须注册为kube-scheduler的扩展点（Scheduler Framework插件），或完全替代原生调度器（需修改kube-scheduler启动参数）
不能只靠client-go轮询Pod列表——延迟高、易丢事件；必须用Informer机制监听变化
生产环境务必加锁和幂等处理：同一个Pod可能被反复触发Reconcile，Binding重复调用会报AlreadyBound

更实际的选择：用affinity/taint配合原生调度器

90%的调度需求根本不需要动代码。比如让Pod只跑在GPU节点上，只需在Pod spec里加：

affinity:
  nodeAffinity:
    requiredDuringSchedulingIgnoredDuringExecution:
      nodeSelectorTerms:
      - matchExpressions:
        - key: hardware-type
          operator: In
          values: ["gpu"]

对应节点打上污点：kubectl taint nodes node-2 hardware-type=gpu:NoSchedule，再给Pod加容忍。这种方式：