带你读《云原生应用开发 Operator原理与实践》第二章 Operator 原理2.2Client-go 原理(二)

2. 使用说明

 

操作 Kubernetes集群的方式有多种,但本质上都要通过调用KubernetesRESTAPI实现对集群的访问和操作。例如,常用的Kubectl命令,当执行 KubectlGetPods命令时,Kubectl向 KubernetesAPIServer完成认证,并发送 GET请求(见代码清单2-7)。

GET/api/v1/namespaces/test/pods

---

200OK

Content-Type:application/json

{

"kind":"PodList",

"apiVersion":"v1","metadata":{...},

"items":[...]

}

 

Client-go库抽象封装了与 KubernetesRESTAPI的交互,方便开发者对Kubernetes的二次开发。利用 Client-go操作 Kubernetes资源的流程基本如下。

(1)  通过 KubeConfig信息,构造 Config 实例。该实例记录了集群证书、KubernetesAPIServer地址等信息。

(2)  根据 Config实例携带的信息,构建特定客户端(例如,ClientSet、DynamicSet等)。

(3)  利用客户端向 KubernetesAPIServer发起请求,操纵 Kubernetes资源。

下面以Examples目录中的示例讲解Client-go库的使用流程(见代码清单2-8)。

示例:out-of-cluster-client-configuration,列出 defaultNamespace下所有的 Pod资源。

funcmain(){

varkubeconfig*string

ifhome:=homeDir();home!=""{

kubeconfig=flag.String("kubeconfig",

filepath.Join(home,".kube","config"),"(optional)absolutepathtothekubeconfigfile",

)

}else{

kubeconfig=flag.String("kubeconfig","","absolutepathtothekubeconfigfile")

}

flag.Parse()

 

//usethecurrentcontextinkubeconfig

config,err:=clientcmd.BuildConfigFromFlags("",*kubeconfig)

iferr!=nil{

panic(err.Error())

}

 

//createtheclientset

clientset,err:=kubernetes.NewForConfig(config)

iferr!=nil{

panic(err.Error())

}

for{

pods,err:=clientset.CoreV1().Pods("").List(context.TODO(),metav1.

ListOptions{})

iferr!=nil{

panic(err.Error())

}

 

//...

}

}

 

funchomeDir()string{

if h:=os.Getenv("HOME");h!=""{returnh

}

returnos.Getenv("USERPROFILE")//windows


}

 

(1)加载配置信息

在访问 Kubernetes集群时,需要进行身份认证。Kubeconfig用于管理访问集群的配置信息,默认的Kubeconfig文件路径为 $HOME/.kube/config。范例中通过命令行参数配置,若存在HOME环境变量,则使用默认 Kubeconfig配置,并利用 BuildConfig-FromFlags函数构建 Config结构体。

(2)构建客户端

在操作资源前需要先构建对应客户端(具体客户端种类在后面章节介绍),示例中利用NewForConfig函数构建 ClientSet,ClientSet能访问 Kubernetes自身内置的资源,这里ClientSet负责列出 Pod 资源。

(3)操作资源

根据 Kubernetes 资源类型和版本的不同,ClientSet 中包含了一组操作资源的客户端,如代码清单 2-9所示,操作Pod资源使用 CoreV1客户端。示例中:CoreV1方法返回对应客户端;Pods方法指定要操作的对象是 Pod资源,参数用于设定 Namespace为空,表示 defaultNamespace;List方法表示对资源的操作动作,有 List、Get、Create、Delete等。最终返回的Pods 变量就包含了所有Pod 资源的信息。

typeClientsetstruct{

*discovery.DiscoveryClient

//...

coreV1                     *corev1.CoreV1Client

 

//...

}

//...

 

//CoreV1retrievestheCoreV1Client

func(c*Clientset)CoreV1()corev1.CoreV1Interface{returnc.coreV1

}

 

以上只是简单介绍了 ClientSet的使用流程,下面将详细讲解Client-go中所有客户端的功能原理及使用方式。

上一篇:带你读《云原生应用开发 Operator原理与实践》第二章 Operator 原理2.2Client-go 原理(三)


下一篇:带你读《云原生应用开发 Operator原理与实践》第二章 Operator 原理2.1(四)