client-go连接kubernetes集群

2022-05-01 12:16:47 浏览数 (1)

背景：

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

image.pngimage.png

开发环境Goland2022.1

image.pngimage.png

上手client-go连接kubernetes集群

创建项目k8s-demo1 go get安装依赖

image.pngimage.png

创建好目录结构如下：

image.pngimage.png

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

代码语言：txt复制
go get  k8s.io/client-go@v0.23.6

注意：由于之前安装过，下载很是快了.....

image.pngimage.png

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:Userszhangpeng.kube下：

image.pngimage.png
image.pngimage.png

注：当然了很多自建的集群填写的都是内网的方式，可以通过代理或者其他方式连接集群

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

代码语言：txt复制
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的时候报错了貌似少了依赖包。按照提示按照了一下

代码语言：txt复制
 go get k8s.io/client-go/kubernetes@v0.23.6
go get k8s.io/client-go/tools/clientcmd@v0.23.6
image.pngimage.png

ok.打印了集群的版本v1.22.3.完成。扩展一下 我打印一下namespace列表？

第二个例子打印namespace列表

参照文档https://kubernetes.io/docs/reference/generated/kubernetes-api/v1.23/#namespace-v1-core

namespace也是属于corev1的，看一下怎么打印一下命名空间列表呢？

main.go增加了如下配置：

代码语言：txt复制
	list, _ := clientset.CoreV1().Namespaces().List(context.Background(), metav1.ListOptions{})
	for _, item := range list.Items {
		fmt.Println(item.Name)

	}

说明：

列表就是定义list了，err忽略。corev1输入那么补全了namespaces。下一步出现了List将鼠标放在List上的提示继续补全：

代码语言：txt复制
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中设置

代码语言：txt复制
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
image.pngimage.png

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

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

代码语言：txt复制
	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)

	}
image.pngimage.png

其他service deployment都差不多的了。这里就先演示一下简单的应用。

强调的：

  1. CoreV1 AppV1
  2. context的用法
  3. metav1
  4. 其他连接kubernetes的集群方式
kuberneteskubernetes client-go

0 人点赞