如何使用 ServiceAccount Token 连接到 Kubernetes 集群？

Question

对于任何示例，client-go 使用 kubeconfig 文件连接到 kubernetes 集群，但我不想这样做。我已经创建了一个服务账户，现在我有了一个ServiceAccount Token，如何在kubernetes集群外用这个token连接到kubernetes集群？

package main

import (
    "flag"
    "k8s.io/client-go/tools/clientcmd"
    "log"
    "k8s.io/client-go/kubernetes"
    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    "fmt"
)

var clientset *kubernetes.Clientset

func main()  {
    k8sconfig := flag.String("k8sconfig","./k8sconfig","kubernetes config file path")
    flag.Parse()
    config , err := clientcmd.BuildConfigFromFlags("",*k8sconfig)
    if err != nil {
        log.Println(err)
    }
    clientset , err = kubernetes.NewForConfig(config)
    if err != nil {
        log.Fatalln(err)
    } else {
        fmt.Println("connect k8s success")
    }


    pods,err := clientset.CoreV1().Pods("").List(metav1.ListOptions{})
    if err != nil {
        log.Println(err.Error())
    }
}

Answer 1

client-go 已经内置了 In Cluster Authentication（用于带有 ServiceAccount 的 Pod）和 Out of Cluster Authentication（用于从集群外部使用，例如用于本地开发）

client-go 有两个例子：

• out of cluster authentication example
• in cluster authentication example - 它正在使用 ServiceAccount 令牌

集群内示例很短：

    // creates the in-cluster config
    config, err := rest.InClusterConfig()
    if err != nil {
        panic(err.Error())
    }
    // creates the clientset
    clientset, err := kubernetes.NewForConfig(config)
    if err != nil {
        panic(err.Error())
    }

你需要导入"k8s.io/client-go/rest"