如何在k8s client-go中使用GKE IAM

import (
    "context"
    "fmt"
    "os"

    "k8s.io/client-go/kubernetes"
    "k8s.io/client-go/tools/clientcmd"
    "k8s.io/client-go/util/homedir"
)

func createClientConfig() (*rest.Config, error) {
    kubeconfig := filepath.Join(homedir.HomeDir(), ".kube", "config")
    config, err := clientcmd.BuildConfigFromFlags("", kubeconfig)
    if err != nil {
        return nil, fmt.Errorf("failed to build kubeconfig: %w", err)
    }
    return config, nil
}

func createClientSet(config *rest.Config) (*kubernetes.Clientset, error) {
    clientset, err := kubernetes.NewForConfig(config)
    if err != nil {
        return nil, fmt.Errorf("failed to create clientset: %w", err)
    }
    return clientset, nil
}

func main() {
    config, err := createClientConfig()
    if err != nil {
        fmt.Println(err)
        os.Exit(1)
    }

    clientset, err := createClientSet(config)
    if err != nil {
        fmt.Println(err)
        os.Exit(1)
    }

    // 使用 clientset 进行后续操作
}

import (
    "context"
    "fmt"

    "k8s.io/apimachinery/pkg/api/errors"
    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    corev1 "k8s.io/api/core/v1"
)

func main() {
    // ...

    // 示例：获取所有 Pod
    pods, err := clientset.CoreV1().Pods("default").List(context.TODO(), metav1.ListOptions{})
    if err != nil {
        fmt.Printf("Failed to get pods: %v", err)
        os.Exit(1)
    }
    for _, pod := range pods.Items {
        fmt.Printf("Pod Name: %s\n", pod.ObjectMeta.Name)
    }

    // 示例：创建一个 Pod
    pod := &corev1.Pod{
        ObjectMeta: metav1.ObjectMeta{
            Name: "my-pod",
        },
        Spec: corev1.PodSpec{
            Containers: []corev1.Container{
                {
                    Name:  "my-container",
                    Image: "nginx",
                },
            },
        },
    }
    createdPod, err := clientset.CoreV1().Pods("default").Create(context.TODO(), pod, metav1.CreateOptions{})
    if err != nil {
        fmt.Printf("Failed to create pod: %v", err)
        os.Exit(1)
    }
    fmt.Printf("Created Pod: %s\n", createdPod.ObjectMeta.Name)

    // ...
}