关于云原生:clientgo-gin的简单整合一list列表相关操作

背景：

实现了client-go连贯kubernetes集群-delete相干操作，略微看过一些B站go圈里最会写js的奇淼的go 与gin的视频，还有沈叔的一些课程：https://www.jtthink.com/。个别都是习惯先入手的，本人入手操作，有问题就看沈叔的视频与解决思路！

1. client-go gin的简略整合一

注：以下操作环境可能有些许区别（在家写货色用的windows，公司的办公环境集体装置了一台rocky linux）。一下所有门路为相对路径在k8s-demo1我的项目目录下！

1. go get 装置gin依赖

PS C:\Users\zhangpeng\GolandProjects\k8s-demo1> go get github.com/gin-gonic/gin
go get: added github.com/gin-contrib/sse v0.1.0
go get: added github.com/gin-gonic/gin v1.7.7
go get: added github.com/go-playground/locales v0.13.0
go get: added github.com/go-playground/universal-translator v0.17.0
go get: added github.com/go-playground/validator/v10 v10.4.1
go get: added github.com/leodido/go-urn v1.2.0
go get: added github.com/mattn/go-isatty v0.0.12
go get: added github.com/ugorji/go/codec v1.1.7

注：linux环境操作省略……如报错短少其余依赖go get自行依照提醒获取装置！

2. 将连贯客户端独自封装成一个办法文件

将后面测试环境写的独自的文件拆分。把客户端独自封装成一个独自文件：
lib/K8sClient.go

package lib

import (
    "flag"
    "k8s.io/client-go/kubernetes"
    "k8s.io/client-go/tools/clientcmd"
    "k8s.io/client-go/util/homedir"
    "path/filepath"
)

var K8sClient *kubernetes.Clientset

func init() {
    var kubeconfig *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")
    }
    flag.Parse()
    config, err := clientcmd.BuildConfigFromFlags("", *kubeconfig)
    if err != nil {
        panic(err.Error())
    }

    // create the clientset
    c, err := kubernetes.NewForConfig(config)
    if err != nil {
        panic(err.Error())
    }
    K8sClient = c
}

3. 创立service目录创立namespace deployment service对应service文件

以namespace deployment service为例：

src/service/Namespace.go

package service

import (
    "context"
    "github.com/gin-gonic/gin"
    . "k8s-demo1/src/lib"
    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)

func ListNamespace(g *gin.Context) {
    ns, err := K8sClient.CoreV1().Namespaces().List(context.Background(), metav1.ListOptions{})
    if err != nil {
        g.Error(err)
        return
    }
    g.JSON(200, ns)
}

src/service/Deployment.go

package service

import (
    "context"
    "github.com/gin-gonic/gin"
    . "k8s-demo1/src/lib"
    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)

func ListDeployment(g *gin.Context) {
    ns := g.Query("ns")

    dps, err := K8sClient.AppsV1().Deployments(ns).List(context.Background(), metav1.ListOptions{})
    if err != nil {
        g.Error(err)
    }
    g.JSON(200, dps)
    return
}

src/service/Service.go

package service

import (
    "context"
    "github.com/gin-gonic/gin"
    . "k8s-demo1/src/lib"
    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)

func ListService(g *gin.Context) {
    ns := g.Query("ns")
    svc, err := K8sClient.CoreV1().Services(ns).List(context.Background(), metav1.ListOptions{})
    if err != nil {
        g.Error(err)
        return
    }
    g.JSON(200, svc)
}

注：失常的应该是lib.K8sClient援用，import设置为了 . “k8s-demo1/src/lib”！

4.编辑main.go 设置路由

main.go

package main

import (
    "github.com/gin-gonic/gin"
    "k8s-demo1/src/service"
)

func main() {
    r := gin.Default()
    r.GET("/", func(context *gin.Context) {
        context.JSON(200, "hello")
    })
    r.GET("/namespaces", service.ListNamespace)
    r.GET("/deployments", service.ListDeployment)
    r.GET("/service", service.ListService)
    r.Run()
}

5. 运行main.go,浏览器拜访是否失常返回

能够命令行控制台go run main.go 也能够goland间接run main.go

注：此集群非后面的ack集群，为本地内网一个测试集群！故namespace等相干信息输入并不与后面局部对应

1. namespace:

http://127.0.0.1:8080/namespaces

2. deployment

http://127.0.0.1:8080/deployments

http://127.0.0.1:8080/deployments?ns=default 指定命名空间

3. service

http://127.0.0.1:8080/service

http://127.0.0.1:8080/service?ns=default 指定命名空间

根本实现了集体的目标。然而输入的内容太多了，很多货色不须要，想要进一步优化输入本人先要的信息！

2. 更进一步的-定制化输入须要的内容

1.对于namespace

namespace我只想输入空间name! 创立一个struct,并make创立一个切片：
src/service/Namespace.go

package service

import (
    "context"
    "github.com/gin-gonic/gin"
    . "k8s-demo1/src/lib"
    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)

type Namespace struct {
    Name string
}

func ListNamespace(g *gin.Context) {
    ns, err := K8sClient.CoreV1().Namespaces().List(context.Background(), metav1.ListOptions{})
    if err != nil {
        g.Error(err)
        return
    }
    ret := make([]*Namespace, 0)
    for _, item := range ns.Items {
        ret = append(ret, &Namespace{
            Name: item.Name,
        })

    }
    g.JSON(200, ret)
    return
}

浏览器拜访http://127.0.0.1:8080/namespaces，如下：

2. 对于deployment

参照namespace设置src/service/Deployment.go

package service

import (
    "context"
    "github.com/gin-gonic/gin"
    . "k8s-demo1/src/lib"
    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)

type Deployment struct {
    Name string
}

func ListDeployment(g *gin.Context) {
    ns := g.Query("ns")

    dps, err := K8sClient.AppsV1().Deployments(ns).List(context.Background(), metav1.ListOptions{})
    if err != nil {
        g.Error(err)
    }
    ret := make([]*Deployment, 0)
    for _, item := range dps.Items {
        ret = append(ret, &Deployment{
            Name: item.Name,
        })

    }
    g.JSON(200, ret)
    return
}

运行main.go 拜访http://127.0.0.1:8080/deployments http://127.0.0.1:8080/deployments?ns=default

3. 对于service

src/service/Service.go如下

package service

import (
    "context"
    "github.com/gin-gonic/gin"
    . "k8s-demo1/src/lib"
    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)

type Service struct {
    Name string
}

func ListService(g *gin.Context) {
    ns := g.Query("ns")
    svc, err := K8sClient.CoreV1().Services(ns).List(context.Background(), metav1.ListOptions{})
    if err != nil {
        g.Error(err)
        return
    }
    ret := make([]*Service, 0)
    for _, item := range svc.Items {
        ret = append(ret, &Service{
            Name: item.Name,
        })

    }
    g.JSON(200, ret)
    return
}

运行main.go 拜访http://127.0.0.1:8080/service http://127.0.0.1:8080/service?ns=default

反思：

1.切片的应用，指针的应用……
2.定制化输入更多的相干配置？比方deployments中镜像，正本数。namespace中label？创立工夫？
3.gin.Context该让我怎么去了解……

关于云原生:clientgo-gin的简单整合一list列表相关操作

背景：

1. client-go gin的简略整合一

1. go get 装置gin依赖

2. 将连贯客户端独自封装成一个办法文件

3. 创立service目录创立namespace deployment service对应service文件

4.编辑main.go 设置路由

5. 运行main.go,浏览器拜访是否失常返回

1. namespace:

2. deployment

3. service

2. 更进一步的-定制化输入须要的内容

1.对于namespace

2. 对于deployment

3. 对于service

反思：

评论

发表回复取消回复

更多文章

苹果iOS打包的ipa应用无法安装？一篇文章带你了解可能的原因及排查方法

图解Golang：从零开始实现简易版过期LRU缓存

深入解析：基于Delta的线性数据结构模型，打造高效富文本编辑器

轻松管理社交媒体：使用Automa插件实现一键拉黑功能

关于云原生:clientgo-gin的简单整合一list列表相关操作

背景：

1. client-go gin的简略整合一

1. go get 装置gin依赖

2. 将连贯客户端独自封装成一个办法文件

3. 创立service目录创立namespace deployment service对应service文件

4.编辑main.go 设置路由

5. 运行main.go,浏览器拜访是否失常返回

1. namespace:

2. deployment

3. service

2. 更进一步的-定制化输入须要的内容

1.对于namespace

2. 对于deployment

3. 对于service

反思：

评论

发表回复 取消回复

更多文章

苹果iOS打包的ipa应用无法安装？一篇文章带你了解可能的原因及排查方法

图解Golang：从零开始实现简易版过期LRU缓存

深入解析：基于Delta的线性数据结构模型，打造高效富文本编辑器

轻松管理社交媒体：使用Automa插件实现一键拉黑功能

发表回复取消回复