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中所有客户端的功能原理及使用方式。