如何进行k8s-client-go源码剖析
这篇文章给大家介绍如何进行k8s-client-go源码剖析，内容非常详细，感兴趣的小伙伴们可以参考借鉴，希望对大家能有所帮助。
蓬溪ssl适用于网站、小程序/APP、API接口等需要进行数据传输应用场景，ssl证书未来市场广阔！成为成都创新互联的ssl证书销售渠道，可以享受市场价格4-6折优惠！如果有意向欢迎电话联系或者加微信：18982081108（备注：SSL证书合作）期待与您的合作！
主题
Client-go源码目录结构
Plain Text
1
[root@normal11 k8s-client-go]# tree . -L 1
2
.
3
├── CHANGELOG.md
4
├── code-of-conduct.md
5
├── CONTRIBUTING.md
6
├── discovery
7
├── dynamic
8
├── examples
9
├── Godeps
10
├── go.mod
11
├── go.sum
12
├── informers
13
├── INSTALL.md
14
├── kubernetes
15
├── kubernetes_test
16
├── LICENSE
17
├── listers
18
├── metadata
19
├── OWNERS
20
├── pkg
21
├── plugin
22
├── README.md
23
├── rest
24
├── restmapper
25
├── scale
26
├── SECURITY_CONTACTS
27
├── testing
28
├── third_party
29
├── tools
30
├── transport
31
└── util
32
33
client-go代码库已经集成到了Kubernetes源码中，所以书本中展示的内容是在Kubernetes源码中源码结构，而这里展示的是Client-go代码库中原始的内容，所以多了一些源码之外的内容，例如README、example、go.mod等。下面讲一下各个目录的作用，内容引自书本：
编辑
删除
几种Client-go客户端
下图是一个简单的总结,其中ClientSet、DynamicClient、DiscoveryClient都是基于RESTClient封装的。
RESTClient
最基础的客户端，对HTTP Request进行了封装，实现了RESTFul风格的API。
案例代码：
Plain Text
1
package main
2
3
import (
4
"fmt"
5
6
corev1 "k8s.io/api/core/v1"
7
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
8
"k8s.io/client-go/kubernetes/scheme"
9
"k8s.io/client-go/rest"
10
"k8s.io/client-go/tools/clientcmd"
11
)
12
13
func main() {14
config, err := clientcmd.BuildConfigFromFlags("", "/root/.kube/config")15
if err != nil {16
panic(err.Error())
17
}
18
19
config.APIPath = "api"
20
config.GroupVersion = &corev1.SchemeGroupVersion
21
config.NegotiatedSerializer = scheme.Codecs
22
23
restClient, err := rest.RESTClientFor(config)
24
if err != nil {25
panic(err.Error())
26
}
27
28
result := &corev1.NodeList{}29
err = restClient.Get().Namespace("").Resource("nodes").VersionedParams(&metav1.ListOptions{Limit: 100}, scheme.ParameterCodec).Do().Into(result)30
if err != nil {31
panic(err)
32
}
33
34
for _, d := range result.Items {35
fmt.Printf("Node Name %v \n", d.Name)36
}
37
}
38
39
预期运行结果将会打印K8S集群中的node
ClientSet
对RESTClient进行了对象分类方式的封装，可以实例化特定资源的客户端，
以Resource和Version的方式暴露。例如实例化一个只操作appsv1版本的Deploy客户端,
ClientSet可以认为是一系列资源的集合客户端。缺点是不能直接访问CRD。
通过client-gen代码生成器生成带有CRD资源的ClientSet后可以访问CRD资源。(未测试)
案例代码：
Plain Text
1
package main
2
3
import (
4
apiv1 "k8s.io/api/core/v1"
5
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
6
"k8s.io/client-go/kubernetes"
7
"k8s.io/client-go/tools/clientcmd"
8
)
9
10
func main() {11
config, err := clientcmd.BuildConfigFromFlags("", "/root/.kube/config")12
if err != nil {13
panic(err)
14
}
15
clientset, err := kubernetes.NewForConfig(config)
16
if err != nil {17
panic(err)
18
}
19
20
podClient := clientset.CoreV1().Pods(apiv1.NamespaceDefault)
21
22
list, err := podClient.List(metav1.ListOptions{Limit: 500})23
if err != nil {24
panic(err)
25
}
26
for _, d := range list.Items {27
if d.Name == "" {28
}
29
// fmt.Printf("NAME:%v \t NAME:%v \t STATUS: %+v\n ", d.Namespace, d.Name, d.Status)30
}
31
32
//请求namespace为default下的deploy
33
deploymentClient := clientset.AppsV1().Deployments(apiv1.NamespaceDefault)
34
deployList, err2 := deploymentClient.List(metav1.ListOptions{Limit: 500})35
if err2 != nil {36
panic(err2)
37
}
38
for _, d := range deployList.Items {39
if d.Name == "" {40
41
}
42
// fmt.Printf("NAME:%v \t NAME:%v \t STATUS: %+v\n ", d.Namespace, d.Name, d.Status)43
}
44
45
// 请求ds资源 todo 有兴趣可以尝试下
46
// clientset.AppsV1().DaemonSets()
47
48
}
49
50
代码中分别打印了获取到K8S集群中的500个Pod和500个deploy，目前打印语句是注释了，如果要看效果需要先删掉注释。
案例代码中还留了一个小内容，请求获取daemonset资源，感兴趣的可以试一试。
DynamicClient
这是一种动态客户端，对K8S任意资源进行操作，包括CRD。
请求返回的结果是map[string]interface{}
代码案例：
Plain Text
1
package main
2
3
import (
4
"fmt"
5
6
apiv1 "k8s.io/api/core/v1"
7
corev1 "k8s.io/api/core/v1"
8
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
9
"k8s.io/apimachinery/pkg/runtime"
10
"k8s.io/apimachinery/pkg/runtime/schema"
11
"k8s.io/client-go/dynamic"
12
"k8s.io/client-go/tools/clientcmd"
13
)
14
15
func main() {16
config, err := clientcmd.BuildConfigFromFlags("", "/root/.kube/config")17
if err != nil {18
panic(err)
19
}
20
21
dymaicClient, err := dynamic.NewForConfig(config)
22
checkErr(err)
23
//map[string]interface{}24
25
//TODO 获取CRD资源 这里是获取了TIDB的CRD资源
26
// gvr := schema.GroupVersionResource{Version: "v1alpha1", Resource: "tidbclusters", Group: "pingcap.com"}27
// unstructObj, err := dymaicClient.Resource(gvr).Namespace("tidb-cluster").List(metav1.ListOptions{Limit: 500})28
// checkErr(err)
29
// fmt.Println(unstructObj)
30
31
gvr := schema.GroupVersionResource{Version: "v1", Resource: "pods"}32
unstructObj, err := dymaicClient.Resource(gvr).Namespace(apiv1.NamespaceDefault).List(metav1.ListOptions{Limit: 500})33
checkErr(err)
34
// fmt.Println(unstructObj)
35
podList := &corev1.PodList{}36
err = runtime.DefaultUnstructuredConverter.FromUnstructured(unstructObj.UnstructuredContent(), podList)
37
checkErr(err)
38
for _, d := range podList.Items {39
fmt.Printf("NAME:%v \t NAME:%v \t STATUS: %+v\n ", d.Namespace, d.Name, d.Status)40
}
41
42
}
43
44
func checkErr(err error) {45
if err != nil {46
panic(err)
47
}
48
}
49
50
这个案例是打印了namespace为default下的500个pod，同样的，在案例中也有一个todo，获取CRD资源，感兴趣的可以尝试一下。如果K8S集群中没有TIDB的资源可以自行换成自己想要的CRD资源。
代码中已经有获取v1alpha1版本的tidbclusters资源。如果你不知道CRD相关的信息，可以按照下面的步骤来找出对应的信息：
通过kubectl api-resources 获取到资源的Group和Resource
通过kubectl api-versions 找到对应Group的版本
这样 资源的GVR(Group、Version、Resource)都有了
DiscoveryClient
这是一种发现客户端，在前面的客户端中需要知道资源的Resource和Version才能找到你想要的，
这些信息太多很难全部记住，这个客户端用于获取资源组、版本等信息。
前面用到的api-resources和api-versions都是通过discoveryClient客户端实现的,源码在Kubernetes源码库中 pkg/kubectl/cmd/apiresources/apiresources.gopkg/kubectl/cmd/apiresources/apiversions.go
Plain Text
1
// RunAPIResources does the work
2
func (o *APIResourceOptions) RunAPIResources(cmd *cobra.Command, f cmdutil.Factory) error {3
w := printers.GetNewTabWriter(o.Out)
4
defer w.Flush()
5
6
//拿到一个DiscoveryClient客户端
7
discoveryclient, err := f.ToDiscoveryClient()
8
if err != nil {9
return err
10
}
11
12
13
Plain Text
1
// RunAPIVersions does the work
2
func (o *APIVersionsOptions) RunAPIVersions() error {3
// Always request fresh data from the server
4
o.discoveryClient.Invalidate()
5
6
//通过discoveryClient获取group相关信息
7
groupList, err := o.discoveryClient.ServerGroups()
8
if err != nil {9
return fmt.Errorf("couldn't get available api versions from server: %v", err)10
}
案例代码：
获取集群中的GVR
Plain Text
1
package main
2
3
import (
4
"fmt"
5
"k8s.io/apimachinery/pkg/runtime/schema"
6
"k8s.io/client-go/discovery"
7
"k8s.io/client-go/tools/clientcmd"
8
)
9
10
func main() {11
config, err := clientcmd.BuildConfigFromFlags("","/root/.kube/config")12
if err != nil {13
panic(err.Error())
14
}
15
16
discoveryClient, err := discovery.NewDiscoveryClientForConfig(config)
17
if err != nil {18
panic(err.Error())
19
}
20
21
_, APIResourceList, err := discoveryClient.ServerGroupsAndResources()
22
if err != nil {23
panic(err.Error())
24
}
25
for _, list := range APIResourceList {26
gv, err := schema.ParseGroupVersion(list.GroupVersion)
27
if err != nil {28
panic(err.Error())
29
}
30
for _, resource := range list.APIResources {31
fmt.Printf("name: %v, group: %v, version %v\n", resource.Name, gv.Group, gv.Version)32
}
33
}
34
}
预期效果：打印集群中的GVR
Plain Text
1
[root@normal11 discoveryclient]# go run main.go
2
name: bindings, group: , version v1
3
name: componentstatuses, group: , version v1
4
name: configmaps, group: , version v1
5
name: endpoints, group: , version v1
6
...
DiscoveryClient在请求到数据之后会缓存到本地，默认存储位置是~/.kube/cache和~/.kube/http-cache,默认是每10分钟会和API Server同步一次。关于如何进行k8s-client-go源码剖析就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。
名称栏目：如何进行k8s-client-go源码剖析
分享网址：http://6mz.cn/article/pppspc.html