多个kube-shceduler

package main

import (
    "context"
    "fmt"
    "k8s.io/client-go/kubernetes"
    "k8s.io/client-go/rest"
    "k8s.io/kubernetes/pkg/scheduler/framework"
)

type CustomScheduler struct{}

func (s *CustomScheduler) Schedule(ctx context.Context, pod *v1.Pod, nodeList []*v1.Node) (*v1.PodScheduledStatus, error) {
    // 自定义调度逻辑
    for _, node := range nodeList {
        if isNodeSuitable(node, pod) {
            return &v1.PodScheduledStatus{PodName: pod.Name, NodeName: node.Name}, nil
        }
    }
    return nil, fmt.Errorf("no suitable node found for pod %s", pod.Name)
}

func isNodeSuitable(node *v1.Node, pod *v1.Pod) bool {
    // 自定义节点适合性检查逻辑
    return true
}

func main() {
    config, err := rest.InClusterConfig()
    if err != nil {
        panic(err.Error())
    }
    clientset, err := kubernetes.NewForConfig(config)
    if err != nil {
        panic(err.Error())
    }

    scheduler := &CustomScheduler{}
    framework.RunSimpleScheduler(clientset, scheduler)
}