阿里云国内75折 回扣 微信号:monov8 |
阿里云国际,腾讯云国际,低至75折。AWS 93折 免费开户实名账号 代冲值 优惠多多 微信号:monov8 飞机:@monov6 |
欢迎访问我的GitHub
这里分类和汇总了欣宸的全部原创(含配套源码)https://github.com/zq2599/blog_demos
系列文章链接
- client-go实战之一准备工作
- client-go实战之二:RESTClient
- client-go实战之三Clientset
- client-go实战之四dynamicClient
- client-go实战之五DiscoveryClient
- client-go实战之六:时隔两年刷新版本继续实战
本篇概览
- 本文是《client-go实战》系列的第八篇主要内容是新建一个golang工程用于管理代码后面整个系列的代码都会保存在这个工程中
工程结构简述
- 此工程打算写一个简单的接口接下来所有实战的功能代码都实现这个接口在命中输入参数来决定执行哪个实现类
- 整个工程结构如下图所示后续的实战中每个功能类都如绿色箭头所示是个独立的go文件
编码
- 新建一个名为client-go-tutorials的golang工程
- 为了便于扩展新建名为action的文件夹里面增加action.go文件内容如下
package action
import "k8s.io/client-go/kubernetes"
type Action interface {
DoAction(clientset *kubernetes.Clientset) error
}
- 后面的实战都实现这个接口先把前文的helloworld迁移到本工程中即list_pod.go
package action
import (
"context"
"fmt"
"k8s.io/apimachinery/pkg/api/errors"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/client-go/kubernetes"
)
type ListPod struct{}
func (listPod ListPod) DoAction(clientset *kubernetes.Clientset) error {
namespace := "kube-system"
pods, err := clientset.CoreV1().Pods(namespace).List(context.TODO(), metav1.ListOptions{})
if err != nil {
panic(err.Error())
}
nums := len(pods.Items)
fmt.Printf("There are %d pods in the cluster\n", nums)
if nums < 1 {
return nil
}
for index, pod := range pods.Items {
fmt.Printf("%v. pod name : %v\n", index, pod.Name)
podObj, err := clientset.CoreV1().Pods(namespace).Get(context.TODO(), pod.Name, metav1.GetOptions{})
if errors.IsNotFound(err) {
fmt.Printf("Pod %s in namespace %s not found\n", pod.Name, namespace)
} else if statusError, isStatus := err.(*errors.StatusError); isStatus {
fmt.Printf("Error getting pod %s in namespace %s: %v\n",
pod.Name, namespace, statusError.ErrStatus.Message)
} else if err != nil {
panic(err.Error())
} else {
fmt.Printf("Found pod %s in namespace %s\n", podObj.Name, namespace)
}
}
return nil
}
程序入口
- 接下来是main.go这是程序的入口代码有以下功能
- 加载kubernetes的配置文件以便后续的处理
- 检查命令的入参action根据不同的值执行不同的实现类在本篇就是list-pod即获取pod列表并在控制台输出
package main
import (
"client-go-tutorials/action"
"flag"
"fmt"
"path/filepath"
"k8s.io/client-go/kubernetes"
"k8s.io/client-go/tools/clientcmd"
"k8s.io/client-go/util/homedir"
)
func main() {
var kubeconfig *string
var actionFlag *string
if home := homedir.HomeDir(); home != "" {
kubeconfig = flag.String("kubeconfig", filepath.Join(home, ".kube", "config"), "(optional) absolute path to the kubeconfig file")
} else {
kubeconfig = flag.String("kubeconfig", "", "absolute path to the kubeconfig file")
}
actionFlag = flag.String("action", "list-pod", "指定实际操作功能")
flag.Parse()
fmt.Println("解析命令完毕开始加载配置文件")
config, err := clientcmd.BuildConfigFromFlags("", *kubeconfig)
if err != nil {
panic(err.Error())
}
clientset, err := kubernetes.NewForConfig(config)
if err != nil {
panic(err.Error())
}
fmt.Printf("加载配置文件完毕即将执行业务 [%v]\n", *actionFlag)
var actionInterface action.Action
switch *actionFlag {
case "list-pod":
listPod := action.ListPod{}
actionInterface = &listPod
case "conflict":
conflict := action.Confilct{}
actionInterface = &conflict
}
err = actionInterface.DoAction(clientset)
if err != nil {
fmt.Printf("err: %v\n", err)
} else {
fmt.Println("执行完成")
}
}
启动配置
- 最后如果您用的是vscode可以像下面这样配置launch.json文件以便快速运行main.go以及输入参数
{
// Use IntelliSense to learn about possible attributes.
// Hover to view descriptions of existing attributes.
// For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
"version": "0.2.0",
"configurations": [
{
"name": "Launch Package",
"type": "go",
"request": "launch",
"mode": "auto",
"program": "${workspaceFolder}",
"args": ["-action=list-pod"]
}
]
}
- 最后确认.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文件夹下如下图红框所示
你不孤单欣宸原创一路相伴
- Java系列
- Spring系列
- Docker系列
- kubernetes系列
- 数据库+中间件系列
- DevOps系列