紫色飞猪的研发之旅–04client-go客户端

此部分是对紫色飞猪的研发之旅–02golang：client-go浅学demo[https://www.cnblogs.com/zisefeizhu/p/15207204.html]的补充

对02的改动点如下：

cmd/root.go

// 初始化配置func initConifg() {config.Loader(cfgFile) // cfgFile string//dservice.Demo()//service.RESTClient()//service.ClientSet()//service.DynamicClient()service.DiscoveryClient()}

config/config.go

// DeployAndKuExternal 部署与k8s外部func DeployAndKuExternal() *rest.Config {// 3. 在k8s的环境中kubectl配置文件一般放在用户目录的.kube文件中if home := homeDir(); home != ""{kubeconfig = flag.String("kubeconfig",filepath.Join(home,".kube","config"),"(可选)kubeconfig 文件的绝对路径")fmt.Println("kubeConfig", *kubeconfig)}else {kubeconfig = flag.String("kubeconfig","","kubeconfig 文件的绝对路径")fmt.Println(kubeconfig)fmt.Println("##################")}flag.Parse()// 4.创建集群配置,首先使用 inCluster 模式(需要区配置对应的RBAC 权限,默认的sa是default-->是没有获取deployment的List权限)if config, err = rest.InClusterConfig(); err != nil {// 使用Kubeconfig文件配置集群Config对象if config,err = clientcmd.BuildConfigFromFlags("",*kubeconfig); err != nil {panic(err.Error())}}return config}// DeployAndKuInternal 部署与k8s内部func DeployAndKuInternal() *rest.Config {// 使用当前上下文环境kubeconfig := filepath.Join(os.Getenv("KUBECONFIG"),)config, err := clientcmd.BuildConfigFromFlags("", kubeconfig)if err != nil {logrus.Fatal(err)}return config}// KubeConfig k8s的config加载func KubeConfig() *rest.Config  {switch choose := viper.GetInt("DeploymentMethod"); choose {case 1 :config = DeployAndKuExternal()case 0 :config = DeployAndKuInternal()}return config}

service/demo.go

package service/*参考文档：Kubernetes的Group、Version、Resource学习小记： https://xinchen.blog.csdn.net/article/details/113715847Client-go 实战：https://xinchen.blog.csdn.net/article/details/113753087注：上面的链接博主写的已经十分详细，本着好记性不如烂笔头的目的 跟着敲了一边*/import ("context""flag""fmt"appsV1 "k8s.io/api/apps/v1"coreV1 "k8s.io/api/core/v1"metaV1 "k8s.io/apimachinery/pkg/apis/meta/v1""k8s.io/apimachinery/pkg/runtime""k8s.io/client-go/discovery""k8s.io/client-go/kubernetes/scheme"rschema "k8s.io/apimachinery/pkg/runtime/schema""k8s.io/client-go/dynamic""k8s.io/client-go/kubernetes""k8s.io/client-go/rest""operator/config""operator/pkg")func RESTClient()  {//RestClient demo : 查询kube-system这个namespace下的所有pod，然后在控制台打印每个pod的几个关键字段；config := config.KubeConfig()// 参考path : /api/v1/namespaces/{namespace}/podsconfig.APIPath = "api"// pod的group是空字符串config.GroupVersion = &coreV1.SchemeGroupVersion// 指定序列化工具config.NegotiatedSerializer = scheme.Codecs// 根据配置信息构建restClient实例restClient, err := rest.RESTClientFor(config)if err!=nil {panic(err.Error())}// 保存pod结果的数据结构实例result := &coreV1.PodList{}//  指定namespacenamespace := "kube-system"// 设置请求参数，然后发起请求// GET请求err = restClient.Get().//  指定namespace，参考path : /api/v1/namespaces/{namespace}/podsNamespace(namespace).// 查找多个pod，参考path : /api/v1/namespaces/{namespace}/podsResource("pods").// 指定大小限制和序列化工具VersionedParams(&metaV1.ListOptions{Limit:100}, scheme.ParameterCodec).// 请求Do(context.TODO()).// 结果存入resultInto(result)if err != nil {panic(err.Error())}// 表头fmt.Printf("namespace\\t status\\t\\t name\\n")// 每个pod都打印namespace、status.Phase、name三个字段for _, d := range result.Items {fmt.Printf("%v\\t %v\\t %v\\n",d.Namespace,d.Status.Phase,d.Name)}}const (NAMESPACE = "test-clientset"DEPLOYMENT_NAME = "client-test-deployment"SERVICE_NAME = "client-test-service")func ClientSet()  {/*本次编码实战的需求如下：写一段代码，检查用户输入的operate参数，该参数默认是create，也可以接受clean；如果operate参数等于create，就执行以下操作：新建名为test-clientset的namespace新建一个deployment，namespace为test-clientset，镜像用tomcat，副本数为2新建一个service，namespace为test-clientset，类型是NodePort如果operate参数等于clean，就删除create操作中创建的service、deployment、namespace等资源：以上需求使用Clientset客户端实现，完成后咱们用浏览器访问来验证tomcat是否正常；*/// 获取用户输入的操作类型，默认是create，还可以输入clean，用于清理所有资源operate := flag.String("operate", "clean", "operate type : create or clean")// 把用户传递的命令行参数解析为对应变量的值flag.Parse()fmt.Printf("operation is %v\\n", *operate)// 实例化clientset对象clientset, err := kubernetes.NewForConfig(config.KubeConfig()); if err != nil {panic(err.Error())}// 如果要执行清理操作if "clean" == *operate {clean(clientset)} else {// 创建namespacecreateNamespace(clientset)// 创建deploymentcreateDeployment(clientset)// 创建servicecreateService(clientset)}}// 清理本次实战创建的所有资源func clean(clientset *kubernetes.Clientset)  {emptyDeleteOptions := metaV1.DeleteOptions{}// 删除serviceif err := clientset.CoreV1().Services(NAMESPACE).Delete(context.TODO(), SERVICE_NAME,emptyDeleteOptions); err != nil {panic(err.Error())}// 删除deploymentif err := clientset.AppsV1().Deployments(NAMESPACE).Delete(context.TODO(), DEPLOYMENT_NAME, emptyDeleteOptions); err != nil {panic(err.Error())}// 删除namespaceif err := clientset.CoreV1().Namespaces().Delete(context.TODO(),NAMESPACE, emptyDeleteOptions); err != nil {panic(err.Error())}}// 新建namespacefunc createNamespace(clientset *kubernetes.Clientset)  {namespaceClient := clientset.CoreV1().Namespaces()namespace := &coreV1.Namespace{ObjectMeta: metaV1.ObjectMeta{Name: NAMESPACE,},}result, err := namespaceClient.Create(context.TODO(), namespace, metaV1.CreateOptions{}); if err != nil{panic(err.Error())}fmt.Printf("Create namespace %s \\n", result.GetName())}// 新建servicefunc createService(clientset *kubernetes.Clientset)  {// 得到service的客户端serviceClient := clientset.CoreV1().Services(NAMESPACE)// 实例化一个数据结构service := &coreV1.Service{ObjectMeta: metaV1.ObjectMeta{Name: SERVICE_NAME,},Spec: coreV1.ServiceSpec{Ports: []coreV1.ServicePort{{Name: "http",Port: 8080,NodePort: 30080,},},Selector: map[string]string{"app" : "tomcat",},Type: coreV1.ServiceTypeNodePort,},}result, err := serviceClient.Create(context.TODO(), service, metaV1.CreateOptions{}); if err != nil {panic(err.Error())}fmt.Printf("Create service %s \\\\n", result.GetName())}// 新建deploymentfunc createDeployment(clientset *kubernetes.Clientset)  {// 得到deployment的客户端deploymentClient := clientset.AppsV1().Deployments(NAMESPACE)// 实例化一个数据结构deployment := &appsV1.Deployment{ObjectMeta: metaV1.ObjectMeta{Name: DEPLOYMENT_NAME,},Spec: appsV1.DeploymentSpec{Replicas: pkg.Int32Ptr(2),Selector: &metaV1.LabelSelector{MatchLabels: map[string]string{"app": "tomcat",},},Template: coreV1.PodTemplateSpec{ObjectMeta: metaV1.ObjectMeta{Labels: map[string]string{"app": "tomcat",},},Spec: coreV1.PodSpec{Containers: []coreV1.Container{{Name:            "tomcat",Image:           "tomcat:latest",ImagePullPolicy: "IfNotPresent",Ports: []coreV1.ContainerPort{{Name:          "http",Protocol:      coreV1.ProtocolTCP,ContainerPort: 8080,},},},},},},},}result, err := deploymentClient.Create(context.TODO(), deployment, metaV1.CreateOptions{}); if err != nil {panic(err.Error())}fmt.Printf("Create deployment %s \\n", result.GetName())}func DynamicClient()  {// 查询指定namespace下的所有pod，然后在控制台打印出来，要求用dynamicClient实现dynamicClient, err := dynamic.NewForConfig(config.KubeConfig()); if err != nil {panic(err.Error())}// 从dynamicClient 的唯一关联方法所需的入参gvr := rschema.GroupVersionResource{Version: "v1", Resource: "pods"}// 使用dynamicClient的查询列表方法，查询指定namespace下的所有pod，// 注意此方法返回的数据结构类型是UnstructuredListunstructObj, err := dynamicClient.Resource(gvr).Namespace("kube-system").List(context.TODO(), metaV1.ListOptions{Limit: 100}); if err != nil {panic(err.Error())}// 实例化一个PodList数据结构，用于接收从unstructObj转换后的结果podList := &coreV1.PodList{}// 转换err = runtime.DefaultUnstructuredConverter.FromUnstructured(unstructObj.UnstructuredContent(), podList); if err != nil {panic(err.Error())}// 表头fmt.Printf("namespace\\t status\\t\\t name\\n")// 每个pod都打印namespace、status.Phase、name三个字段for _, d := range podList.Items {fmt.Printf("%v\\t %v\\t %v\\n",d.Namespace,d.Status.Phase,d.Name)}}func DiscoveryClient()  {// 从kubernetes查询所有的Group、Version、Resource信息，在控制台打印出来discoveryClient, err := discovery.NewDiscoveryClientForConfig(config.KubeConfig()); if err != nil{panic(err.Error())}// 获取所有分组和资源数据APIGroup, APIResourceListSlice, err := discoveryClient.ServerGroupsAndResources(); if err != nil {panic(err.Error())}// 先看Group信息fmt.Printf("APIGroup :\\n\\n %v\\n\\n\\n\\n",APIGroup)// APIResourceListSlice是个切片，里面的每个元素代表一个GroupVersion及其资源for _, singleAPIResourceList := range APIResourceListSlice {// GroupVersion是个字符串，例如"apps/v1"groupVerionStr := singleAPIResourceList.GroupVersion// ParseGroupVersion方法将字符串转成数据结构gv, err := rschema.ParseGroupVersion(groupVerionStr)if err != nil {panic(err.Error())}fmt.Println("*****************************************************************")fmt.Printf("GV string [%v]\\nGV struct [%#v]\\nresources :\\n\\n", groupVerionStr, gv)// APIResources字段是个切片，里面是当前GroupVersion下的所有资源for _, singleAPIResource := range singleAPIResourceList.APIResources {fmt.Printf("%v\\n", singleAPIResource.Name)}}}