背景:

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 mainimport (    "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.6go 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的集群形式