Kubernetes，通过go客户端动态扩展/缩小pod的代码片段

package main

import (
    "context"
    "flag"
    "fmt"
    "log"
    "path/filepath"
    "time"

    corev1 "k8s.io/api/core/v1"
    "k8s.io/apimachinery/pkg/api/errors"
    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    "k8s.io/client-go/kubernetes"
    "k8s.io/client-go/tools/clientcmd"
)

func main() {
    kubeconfig := flag.String("kubeconfig", filepath.Join(homeDir(), ".kube", "config"), "kubeconfig file")
    config, err := clientcmd.BuildConfigFromFlags("", *kubeconfig)
    if err != nil {
        log.Fatal(err)
    }

    clientset, err := kubernetes.NewForConfig(config)
    if err != nil {
        log.Fatal(err)
    }

    podName := "example-pod"
    namespace := "default"

    // 获取Pod信息
    pod, err := clientset.CoreV1().Pods(namespace).Get(context.TODO(), podName, metav1.GetOptions{})
    if err != nil {
        if errors.IsNotFound(err) {
            log.Fatalf("Pod %s not found in namespace %s", podName, namespace)
        }
        log.Fatal(err)
    }

    // 扩展Pod副本数量
    replicas := int32(3)
    pod.Spec.Replicas = &replicas

    // 更新Pod
    _, err = clientset.CoreV1().Pods(namespace).Update(context.TODO(), pod, metav1.UpdateOptions{})
    if err != nil {
        log.Fatal(err)
    }

    fmt.Printf("Pod %s in namespace %s scaled to %d replicas\n", podName, namespace, replicas)
}

func homeDir() string {
    if h := os.Getenv("HOME"); h != "" {
        return h
    }
    return os.Getenv("USERPROFILE")
}