[k8s源码]1.client-go集群外部署

在Kubernetes中，client-go库是常用的Go语言客户端，用于与Kubernetes集群交互。以下是一个使用client-go库来与Kubernetes集群进行通信的基本示例。

首先，你需要设置KUBECONFIG环境变量，指向你的集群配置文件。

export KUBECONFIG=/path/to/your/kubeconfig

然后，你可以使用client-go库来与集群进行交互。以下是一个简单的Go程序，它会列出默认命名空间下的所有Pods。

package main
 
import (
    "context"
    "fmt"
    "time"
 
    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    "k8s.io/client-go/kubernetes"
    "k8s.io/client-go/rest"
)
 
func main() {
    // 使用集群的kubeconfig创建一个新的客户端
    config, err := rest.InClusterConfig()
    if err != nil {
        panic(err.Error())
    }
    clientset, err := kubernetes.NewForConfig(config)
    if err != nil {
        panic(err.Error())
    }
 
    // 列出默认命名空间下的所有Pods
    for {
        pods, err := clientset.CoreV1().Pods(metav1.NamespaceDefault).List(context.TODO(), metav1.ListOptions{})
        if err != nil {
            panic(err.Error())
        }
        fmt.Printf("Number of Pods: %v\n", len(pods.Items))
        for _, pod := range pods.Items {
            fmt.Printf(" * %s (%s)\n", pod.Name, pod.Status.Phase)
        }
        time.Sleep(10 * time.Second)
    }
}

这个程序会创建一个Kubernetes客户端，然后无限循环地列出默认命名空间下的所有Pods，并打印它们的状态。

请注意，这个示例假设你的程序有足够的权限与Kubernetes集群进行交互。如果你的程序运行在集群之外，你需要一个有效的kubeconfig文件来配置API服务器的地址和认证信息。rest.InClusterConfig() 函数用于在集群内部的Pod中获取配置，通常通过服务账户自动挂载的。

这只是client-go库与Kubernetes集群交互的一个基本示例。client-go库提供了丰富的API，可以用于执行更复杂的操作，比如创建、更新、删除Pods、Services等Kubernetes资源对象。