关于kubernetes:clientgo连接kubernetes集群

背景：

kubernetes 的根本利用的算是能入门了。然而基于各种客户端操作 kubernetes 集群还是没有深刻玩过，最近一段时间入门了一下 goland，就拿 client-go 深刻体验一下 kubernetes 集群的基本操作，当然了最初能更深刻一下跟 gin 框架联合了就好了 …… 算是练手入门
对于 client-go
参照 githubhttps://github.com/kubernetes/client-go。请留神版本与 kubernetes 的版本兼容性对应关系：https://github.com/kubernetes/client-go#versioning。我这里装置的最新的 1.23.6 版本（连贯的集群其实是 1.22 的阿里云的 ack 集群。只进行简略的操作，没有什么太大问题）

试验环境

阿里云 ack1.22.3

开发环境 Goland2022.1

上手 client-go 连贯 kubernetes 集群

创立我的项目 k8s-demo1 go get 装置依赖

创立好目录构造如下：

接下来应该是装置 client-go 的依赖了，参照 client-go 官网文档：https://github.com/kubernetes/client-go/blob/master/INSTALL.md。当然了我这里就依照最新版本了

go get  k8s.io/client-go@v0.23.6

留神：因为之前装置过，下载很是快了 …..

api 官网文档

https://kubernetes.io/docs/reference/generated/kubernetes-api/v1.23/

对于 client-go 连贯 kubernetes 集群的几种客户端

参照：csdn 博客 https://xinchen.blog.csdn.net/article/details/113753087

1. client-go 实战之二:RESTClient
2. client-go 实战之三：Clientset
3. client-go 实战之四：dynamicClient
4. client-go 实战之五：DiscoveryClient

我这里就应用 Clientset 了！

clientset 创立 kubernetes 客户端并验证 version

下载集群配置文件

登录阿里云 ack 集群治理页面下载 config 配置文件保留到开发机器 C:\Users\zhangpeng.kube 下：


注：当然了很多自建的集群填写的都是内网的形式，能够通过代理或者其余形式连贯集群

第一个例子打印一下 kubernetes 集群 version

package main

import (
    "flag"
    "fmt"
    "k8s.io/client-go/kubernetes"
    "k8s.io/client-go/tools/clientcmd"
    "k8s.io/client-go/util/homedir"
    "path/filepath"
)

func main() {
    var kubeconfig *string
    if home := homedir.HomeDir(); home != "" {kubeconfig = flag.String("kubeconfig", filepath.Join(home, ".kube", "config"), "(optional) absolute path to the kubeconfig file")
    } else {kubeconfig = flag.String("kubeconfig", "","absolute path to the kubeconfig file")
    }
    flag.Parse()
    config, err := clientcmd.BuildConfigFromFlags("", *kubeconfig)
    if err != nil {panic(err.Error())
    }

    // create the clientset
    clientset, err := kubernetes.NewForConfig(config)
    if err != nil {panic(err.Error())
    }
    fmt.Println(clientset.ServerVersion())
}

go run main.go 的时候报错了貌似少了依赖包。依照提醒依照了一下

 go get k8s.io/client-go/kubernetes@v0.23.6
go get k8s.io/client-go/tools/clientcmd@v0.23.6

ok. 打印了集群的版本 v1.22.3. 实现。扩大一下 我打印一下 namespace 列表？

第二个例子打印 namespace 列表

参照文档 https://kubernetes.io/docs/reference/generated/kubernetes-api/v1.23/#namespace-v1-core
namespace 也是属于 corev1 的，看一下怎么打印一下命名空间列表呢？
main.go 减少了如下配置：

    list, _ := clientset.CoreV1().Namespaces().List(context.Background(), metav1.ListOptions{})
    for _, item := range list.Items {fmt.Println(item.Name)

    }

阐明：
列表就是定义 list 了，err 疏忽。corev1 输出那么补全了 namespaces。下一步呈现了 List 将鼠标放在 List 上的提醒持续补全：

func (NamespaceInterface) List(ctx context.Context, opts v1.ListOptions) (*v1.NamespaceList, error

罕用的两个 context:

• context.Background(): 能够简略了解咱们晓得这个上下文要去干什么
• context.TODO(): 能够简略了解咱们不分明要应用哪个上下文、或者还没有可用的上下文

就依照这里的去了解了 https://www.jianshu.com/p/755426897746。最笨的办法能够一个一个试试 …..，在前面其实补全的是 v1.ListOptions{}。然而 v1 前面会和其余的类抵触。依照常规设置为 metav1. 当然了也记得在 import 中设置

metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"

同理，上面打印一下 develop 命名空间一下的 pod…

第三个例子打印 develop namespace 下的 pod

    fmt.Println("pod list in develop")
    list1, _ := clientset.CoreV1().Pods("develop").List(context.Background(), metav1.ListOptions{})
    for _, item := range list1.Items {fmt.Println(item.Name)

    }

其余 service deployment 都差不多的了。这里就先演示一下简略的利用。

强调的：

1. CoreV1 AppV1
2. context 的用法
3. metav1
4. 其余连贯 kubernetes 的集群形式