2.2.2         Client-go主体结构

Client-go 共支持 4 种与 Kubernetes APIServer交互的客户端逻辑，如图 2-4所示。

（1）  RESTClient：最基础的客户端，它主要对 HTTP请求进行了封装，并且支持JSON和Protobuf格式数据。

（2）  DiscoveryClient：发现客户端，发现API- Server   支持的资源组、资源版本和资源信息。如 Kubectl Api-Versions 。

（3） ClientSet：Kubernetes自身内置资源的客户端集合，仅能操作已知类型的内置资源，如Pods、Service 等。

                     图2—4   Cient交互图

 

（4）  DynamicClient：动态客户端，可以对任意的 Kubernetes 资源执行通用操作，包括 CRD。

1. RESTClient

 

RESTClient是所有客户端的父类，RESTClient提供的 RESTful方法（如 Get()、Put()、Post()、Delete() 等 ）与KubernetesAPIServer进 行 交 互，ClientSet、DynamicClient和DiscoveryClient等也都是基于 RESTClient 二次开发实现的。因此，RESTClient可以操作Kubernetes自身内置的原生资源以及 CRD。

前面Example，目录中的out-of-cluster-client-configuration  示例，用RESTClient实现的代码见代码清单 2-10。

packagemain

 

import(

"context""fmt"

 

corev1"k8s.io/api/core/v1"

metav1"k8s.io/apimachinery/pkg/apis/meta/v1""k8s.io/client-go/kubernetes/scheme""k8s.io/client-go/rest"

"k8s.io/client-go/tools/clientcmd"

)

 

funcmain(){

//加载配置⽂件，⽣成 config对象

config,err:=clientcmd.BuildConfigFromFlags("","/root/.kube/config")

iferr!=nil{

panic(err.Error())

}

//配置 API路径和请求的资源组 /资源版本信息

config.APIPath="api"

config.GroupVersion=&corev1.SchemeGroupVersion

 

//配置数据的编解码器

config.NegotiatedSerializer=scheme.Codecs

//实例化RESTClient对象

restClient,err:=rest.RESTClientFor(config)

iferr!=nil{

panic(err.Error())

}

 

//预设返回值存放对象

result:=&corev1.PodList{}

 

//Get⽅法设置HTTP请求⽅法 ；Namespace⽅法设置操作的命名空间

//Resource⽅法设置操作的资源类型 ；VersionedParams⽅法设置请求的查询参数

//Do⽅法发起请求并⽤Into⽅法将APIServer返回的结果写⼊Result变量中

err=restClient.Get().

Namespace("default").Resource("pods").

VersionedParams(&metav1.ListOptions{Limit:100},scheme.ParameterCodec).Do(context.TODO()).

Into(result)

 

iferr!=nil{panic(err)

}

 

//打印Pod信息

for _,d:=rangeresult.Items{fmt.Printf(

"NAMESPACE:%v\tNAME:%v\tSTATUS:%v\n",

d.Namespace,d.Name,d.Status.Phase,

)

}

}

 

运行以上代码，会获得命名空间 Default下的所有 Pod 资源的相关信息，部分信息打印输出见代码清单 2-11。

# 运⾏输出

NAMESPACE:default          NAME:nginx-deployment-6b474476c4-lpld7

STATUS:Running

NAMESPACE:default          NAME:nginx-deployment-6b474476c4-t6xl4

STATUS:Running

RESTClient 实际上是对 KubernetesAPIServer的 RESTfulAPI 的访问进行了封装抽象，底层调用的是 Go语言 Net/Http库。

分析 RESTClient发起请求的过程如下。

（1）      Get方法返回Request类型对象（见代码清单2-12）。

//GetbeginsaGETrequest.Shortforc.Verb("GET").func(c*RESTClient)Get()*Request{

returnc.Verb("GET")

}

（2）      Request结构体对象用于构建访问 APIServer的请求， 示例中依次调用的Namespace、Resource、VersionedParams、Do等方法都是 Request结构体的方法，最终Do方法中r.request 发起请求，r.transformResponse将 APIServer 的返回值解析成corev1.PodList类型对象，即示例中的Result变量（见代码清单2-13）。

func(r*Request)Do(ctxcontext.Context)Result{varresultResult

err:=r.request(ctx,func(req*http.Request,resp*http.Response){result=r.transformResponse(resp,req)

})

//...

}