如何使用k8s client获取GKE工作节点的最新列表-go

import (
    "context"
    "fmt"
    "k8s.io/client-go/kubernetes"
    "k8s.io/client-go/tools/clientcmd"
)

func GetGKENodes() ([]string, error) {
    // 加载kubeconfig文件
    kubeconfig := "<path-to-kubeconfig-file>"
    config, err := clientcmd.BuildConfigFromFlags("", kubeconfig)
    if err != nil {
        return nil, err
    }

    // 创建Kubernetes客户端
    clientset, err := kubernetes.NewForConfig(config)
    if err != nil {
        return nil, err
    }

    // 获取工作节点列表
    nodeList, err := clientset.CoreV1().Nodes().List(context.Background(), metav1.ListOptions{})
    if err != nil {
        return nil, err
    }

    // 提取节点IP地址并返回
    var nodes []string
    for _, node := range nodeList.Items {
        for _, addr := range node.Status.Addresses {
            if addr.Type == v1.NodeInternalIP {
                nodes = append(nodes, addr.Address)
            }
        }
    }

    return nodes, nil
}

nodes, err := GetGKENodes()
if err != nil {
    fmt.Println("获取GKE工作节点列表失败：", err)
    return
}

fmt.Println("GKE工作节点列表：")
for _, node := range nodes {
    fmt.Println(node)
}