Skip to content

Latest commit

 

History

History
79 lines (73 loc) · 2.97 KB

README-zh.md

File metadata and controls

79 lines (73 loc) · 2.97 KB
Raw

kubernetes 的多集群 client-go

项目思路与功能

项目背景：本项目对原生的 client-go 包进行扩展封装，实现"多集群"的 client-go SDK(clientSet dynamicClient discoveryClient)。调用方仅需要维护 config.yaml 配置文件。

附注：

  1. 目录下创建一个 resource 文件，把集群的 .kube/config 文件复制一份放入(记得 cluster server 需要改成"公网ip")。
  2. 本项目支持 insecurity 模式，所以 config 文件需要把 certificate-authority-data 字段删除，否则连接会报错(本身支持 tls 证书也可以不删除)。(重要！！)
  3. 可配置多个 .kube/config 配置文件。
  4. 可读取远程 kubeconfig ，获取客户端实例

配置文件

  • 重要 配置文件可参考config.yaml中配置，调用方只需要关注配置文件中的内容即可。
clusters:                     # 集群列表
  - metadata:
      clusterName: cluster1   # 自定义集群名
      insecure: true          # 是否开启跳过tls证书认证
      configPath: /Users/zhenyu.jiang/go/src/golanglearning/new_project/multi_cluster_client/resource/config2 # kube config配置文件地址
  - metadata:
      clusterName: cluster2
      insecure: true
      configPath: /Users/zhenyu.jiang/go/src/golanglearning/new_project/multi_cluster_client/resource/config1
  - metadata:
      clusterName: cluster3
      insecure: true
      configPath: /Users/zhenyu.jiang/go/src/golanglearning/new_project/multi_cluster_client/resource/config
  - metadata:
      clusterName: cluster4
      insecure: true
      configPath: ./config
      remoteMode: true        # 远程读取kubeconfig模式
      remoteNode:             # 远端节点登入信息
        host: xxx
        password: xxx
        user: root
        port: 22

使用范例

  • 使用配置文件的方式
func main() {
    // 1. 创建文件
    c, _ := config.BuildConfig("./config.yaml")
    multiClient, _ := client.NewForConfig(c)
    // 2. 使用时与原生client-go几乎相同，只是需要多指定集群名，
    p1, _ := multiClient.Cluster("cluster1").CoreV1().Pods("default").List(context.Background(), v1.ListOptions{})
    for _, v := range p1.Items {
    	fmt.Println(v.Name)
    }
    
    p2, _ := multiClient.Cluster("cluster2").CoreV1().Pods("default").List(context.Background(), v1.ListOptions{})
    for _, v := range p2.Items {
        fmt.Println(v.Name)
    }
    
    p3, _ := multiClient.Cluster("cluster3").CoreV1().Pods("default").List(context.Background(), v1.ListOptions{})
    for _, v := range p3.Items {
        fmt.Println(v.Name)
    }
}
  • 读取远端client实例
func main() {
    rn := &client.RemoteNode{
        Host: "xxx",
        Password: "xxx",
        User: "root",
        Port: "22",
    }
    c ,_ := client.GetClientByRemoteKubeConfig(rn, "./config", true)
    p , _ := c.CoreV1().Pods("default").List(context.Background(), v1.ListOptions{})
    for _, v := range p.Items {
        fmt.Println(v.Name)
    }
}