client-go实战之七：准备一个工程管理后续实战的代码

欢迎访问我的GitHub

这里分类和汇总了欣宸的全部原创(含配套源码)：https://github.com/zq2599/blog_demos

本篇概览

• 本文是《client-go实战》系列的第八篇，主要内容是新建一个golang工程，用于管理代码，后面整个系列的代码都会保存在这个工程中
  

工程结构简述

• 此工程打算写一个简单的接口，接下来所有实战的功能代码都实现这个接口，在命中输入参数来决定执行哪个实现类
  
• 整个工程结构如下图所示，后续的实战中，每个功能类都如绿色箭头所示，是个独立的go文件
  
  

编码

• 新建一个名为client-go-tutorials的golang工程
  
• 为了便于扩展，新建名为action的文件夹，里面增加action.go文件，内容如下
  

1. package action
3. import "k8s.io/client-go/kubernetes"
5. type Action interface {
6.         DoAction(clientset *kubernetes.Clientset) error
7. }

复制代码

• 后面的实战都实现这个接口，先把前文的helloworld迁移到本工程中，即list_pod.go
  

1. package action
3. import (
4.         "context"
5.         "fmt"
7.         "k8s.io/apimachinery/pkg/api/errors"
8.         metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
9.         "k8s.io/client-go/kubernetes"
10. )
12. type ListPod struct{}
14. func (listPod ListPod) DoAction(clientset *kubernetes.Clientset) error {
15.         namespace := "kube-system"
17.         // 查询pod列表
18.         pods, err := clientset.CoreV1().Pods(namespace).List(context.TODO(), metav1.ListOptions{})
19.         if err != nil {
20.                 panic(err.Error())
21.         }
23.         nums := len(pods.Items)
25.         fmt.Printf("There are %d pods in the cluster\n", nums)
27.         // 如果没有pod就返回了
28.         if nums < 1 {
29.                 return nil
30.         }
32.         // 遍历列表中的每个pod
33.         for index, pod := range pods.Items {
34.                 fmt.Printf("%v. pod name : %v\n", index, pod.Name)
36.                 // 用pod name精确搜索单个pod
37.                 podObj, err := clientset.CoreV1().Pods(namespace).Get(context.TODO(), pod.Name, metav1.GetOptions{})
38.                 if errors.IsNotFound(err) {
39.                         fmt.Printf("Pod %s in namespace %s not found\n", pod.Name, namespace)
40.                 } else if statusError, isStatus := err.(*errors.StatusError); isStatus {
41.                         fmt.Printf("Error getting pod %s in namespace %s: %v\n",
42.                                 pod.Name, namespace, statusError.ErrStatus.Message)
43.                 } else if err != nil {
44.                         panic(err.Error())
45.                 } else {
46.                         fmt.Printf("Found pod %s in namespace %s\n", podObj.Name, namespace)
47.                 }
48.         }
50.         return nil
51. }

复制代码

程序入口

• 接下来是main.go，这是程序的入口，代码有以下功能：
  

• 加载kubernetes的配置文件，以便后续的处理
  
• 检查命令的入参action，根据不同的值执行不同的实现类，在本篇就是list-pod，即获取pod列表并在控制台输出
  

• main.go源码如下
  

1. package main
3. import (
4.         "client-go-tutorials/action"
5.         "flag"
6.         "fmt"
7.         "path/filepath"
9.         "k8s.io/client-go/kubernetes"
10.         "k8s.io/client-go/tools/clientcmd"
11.         "k8s.io/client-go/util/homedir"
12. )
14. func main() {
15.         var kubeconfig *string
16.         var actionFlag *string
18.         // 试图取到当前账号的家目录
19.         if home := homedir.HomeDir(); home != "" {
20.                 // 如果能取到，就把家目录下的.kube/config作为默认配置文件
21.                 kubeconfig = flag.String("kubeconfig", filepath.Join(home, ".kube", "config"), "(optional) absolute path to the kubeconfig file")
22.         } else {
23.                 // 如果取不到，就没有默认配置文件，必须通过kubeconfig参数来指定
24.                 kubeconfig = flag.String("kubeconfig", "", "absolute path to the kubeconfig file")
25.         }
27.         actionFlag = flag.String("action", "list-pod", "指定实际操作功能")
29.         flag.Parse()
31.         fmt.Println("解析命令完毕，开始加载配置文件")
33.         // 加载配置文件
34.         config, err := clientcmd.BuildConfigFromFlags("", *kubeconfig)
35.         if err != nil {
36.                 panic(err.Error())
37.         }
39.         // 用clientset类来执行后续的查询操作
40.         clientset, err := kubernetes.NewForConfig(config)
41.         if err != nil {
42.                 panic(err.Error())
43.         }
45.         fmt.Printf("加载配置文件完毕，即将执行业务 [%v]\n", *actionFlag)
47.         var actionInterface action.Action
49.         // 注意，如果有新的功能类实现，就在这里添加对应的处理
50.         switch *actionFlag {
51.         case "list-pod":
52.                 listPod := action.ListPod{}
53.                 actionInterface = &listPod
54.         case "conflict":
55.                 conflict := action.Confilct{}
56.                 actionInterface = &conflict
57.         }
59.         err = actionInterface.DoAction(clientset)
60.         if err != nil {
61.                 fmt.Printf("err: %v\n", err)
62.         } else {
63.                 fmt.Println("执行完成")
64.         }
65. }

复制代码

启动配置

• 最后，如果您用的是vscode，可以像下面这样配置launch.json文件，以便快速运行main.go，以及输入参数
  

1. {
2.     // Use IntelliSense to learn about possible attributes.
3.     // Hover to view descriptions of existing attributes.
4.     // For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
5.     "version": "0.2.0",
6.     "configurations": [
7.         {
8.             "name": "Launch Package",
9.             "type": "go",
10.             "request": "launch",
11.             "mode": "auto",
12.             "program": "${workspaceFolder}",
13.             "args": ["-action=list-pod"]
14.         }
15.     ]
16. }

复制代码

• 最后，确认.kube/config文件可以正常使用
  
• 按照下图操作，可以正常运行程序，输出pod列表信息
  
  
• 至此，本篇完成，接下来的实战都会使用本篇创建的工程，在这里面添加action接口的实现类
  

源码下载

• 上述完整源码可在GitHub下载到，地址和链接信息如下表所示(https://github.com/zq2599/blog_demos)：
  

名称链接备注项目主页https://github.com/zq2599/blog_demos该项目在GitHub上的主页git仓库地址(https)https://github.com/zq2599/blog_demos.git该项目源码的仓库地址，https协议git仓库地址(ssh)git@github.com:zq2599/blog_demos.git该项目源码的仓库地址，ssh协议

• 这个git项目中有多个文件夹，本篇的源码在tutorials/client-go-tutorials文件夹下，如下图红框所示：
  
  

欢迎关注博客园：程序员欣宸

学习路上，你不孤单，欣宸原创一路相伴...

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！