client-go gin的简单整合五-list-watch deployment应用

client-go gin的简单整合五-list-watch deployment应用

背景：

紧接client-go gin的简单整合四-list-watch初探，list-watch的模式都在测试文件中写的，现在修改一下前面做的deployment pod namespace 等等的api！

client-go gin的简单整合五-list-watch deployment应用

src目录下创建core文件夹，并创建deployment_init.go文件，将test1.go中相关deployment配置迁移过来！（默认test1.go中内容迁移过来）

/src/core/deployment_init.go

package core import ( "fmt" "k8s-demo1/src/lib" v1 "k8s.io/api/apps/v1" "k8s.io/apimachinery/pkg/util/wait" "k8s.io/client-go/informers" "log" "sync" ) type DeploymentMap struct { data sync.Map } //新增 func (depmap *DeploymentMap) Add(dep *v1.Deployment) { if list, ok := depmap.data.Load(dep.Namespace); ok { list = append(list.([]*v1.Deployment), dep) depmap.data.Store(dep.Namespace, list) } else { depmap.data.Store(dep.Namespace, []*v1.Deployment{dep}) } } //更新 func (depmap *DeploymentMap) Update(dep *v1.Deployment) error { if list, ok := depmap.data.Load(dep.Namespace); ok { for i, range_dep := range list.([]*v1.Deployment) { if range_dep.Name == dep.Name { list.([]*v1.Deployment)[i] = dep } } return nil } return fmt.Errorf("deployment-%s not found", dep.Name) } // 删除 func (depmap *DeploymentMap) Delete(dep *v1.Deployment) { if list, ok := depmap.data.Load(dep.Namespace); ok { for i, range_dep := range list.([]*v1.Deployment) { if range_dep.Name == dep.Name { newList := append(list.([]*v1.Deployment)[:i], list.([]*v1.Deployment)[i+1:]...) depmap.data.Store(dep.Namespace, newList) break } } } } func (depmap *DeploymentMap) ListByNS(ns string) ([]*v1.Deployment, error) { if list, ok := depmap.data.Load(ns); ok { return list.([]*v1.Deployment), nil } return nil, fmt.Errorf("record not found") } var DepMap *DeploymentMap func init() { DepMap = &DeploymentMap{} } type DepHandler struct { } func (d *DepHandler) OnAdd(obj interface{}) { //fmt.Println(obj.(*v1.Deployment).Name) DepMap.Add(obj.(*v1.Deployment)) } func (d *DepHandler) OnUpdate(oldObj, newObj interface{}) { err := DepMap.Update(newObj.(*v1.Deployment)) if err != nil { log.Println(err) } } func (d *DepHandler) OnDelete(obj interface{}) { if d, ok := obj.(*v1.Deployment); ok { DepMap.Delete(d) } } func InitDeployment() { factory := informers.NewSharedInformerFactory(lib.K8sClient, 0) depinformer := factory.Apps().V1().Deployments() depinformer.Informer().AddEventHandler(&DepHandler{}) factory.Start(wait.NeverStop) }

/src/service/deployment.go

package service import ( "context" "fmt" "github.com/gin-gonic/gin" "k8s-demo1/src/core" . "k8s-demo1/src/lib" v1 "k8s.io/api/apps/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" ) type Deployment struct { Namespace string Name string Replicas int32 AvailableReplicas int32 UnavailableReplicas int32 Images string CreateTime string Labels map[string]string Pods []*Pod } func ListDeployment(g *gin.Context) { ns := g.Query("ns") deplist, err := core.DepMap.ListByNS(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 deplist { ret = append(ret, &Deployment{ Namespace: item.Namespace, Name: item.Name, Replicas: item.Status.Replicas, AvailableReplicas: item.Status.AvailableReplicas, UnavailableReplicas: item.Status.UnavailableReplicas, Images: item.Spec.Template.Spec.Containers[0].Image, Labels: item.GetLabels(), Pods: GetPodsByDep(ns, item), }) } g.JSON(200, ret) return } func GetDeployment(g *gin.Context) { ns := g.Query("ns") name := g.Query("name") ctx := context.Background() getopt := metav1.GetOptions{} dps, err := K8sClient.AppsV1().Deployments(ns).Get(ctx, name, getopt) if err != nil { g.Error(err) } ret := make([]*Deployment, 0) ret = append(ret, &Deployment{ Namespace: dps.Namespace, Name: dps.Name, Replicas: dps.Status.Replicas, AvailableReplicas: dps.Status.AvailableReplicas, UnavailableReplicas: dps.Status.UnavailableReplicas, Images: dps.Spec.Template.Spec.Containers[0].Image, CreateTime: dps.CreationTimestamp.Format("2006-01-02 15:03:04"), Labels: dps.Labels, Pods: GetPodsByDep(ns, dps), }) g.JSON(200, ret) return } func GetLabels(m map[string]string) string { labels := "" // aa=xxx,xxx=xx for k, v := range m { if labels != "" { labels += "," } labels += fmt.Sprintf("%s=%s", k, v) } return labels } func GetPodsByDep(ns string, dep *v1.Deployment) []*Pod { ctx := context.Background() listopt := metav1.ListOptions{ LabelSelector: GetLabels(dep.Spec.Selector.MatchLabels), } list, err := K8sClient.CoreV1().Pods(ns).List(ctx, listopt) if err != nil { panic(err.Error()) } pods := make([]*Pod, len(list.Items)) for i, pod := range list.Items { pods[i] = &Pod{ Namespace: pod.Namespace, Name: pod.Name, //获取 pod名称 Status: string(pod.Status.Phase), Images: pod.Spec.Containers[0].Image, NodeName: pod.Spec.NodeName, //所属节点 Labels: pod.Labels, CreateTime: pod.CreationTimestamp.Format("2006-01-02 15:04:05"), //创建时间 } } return pods }

go run main.go 启动应用

继续完善deployment的程序

问题复现：

nginx.yaml

apiVersion: apps/v1 kind: Deployment metadata: creationTimestamp: null labels: app: nginx name: nginx spec: replicas: 1 selector: matchLabels: app: nginx strategy: {} template: metadata: creationTimestamp: null labels: app: nginx spec: containers: - image: nginx name: nginx resources: {} status: {}

[zhangpeng@zhangpeng k8s]$ kubectl apply -f nginx.yaml deployment.apps/nginx created

nginx1.yaml

apiVersion: apps/v1 kind: Deployment metadata: creationTimestamp: null labels: app: nginx name: nginx1 spec: replicas: 1 selector: matchLabels: app: nginx strategy: {} template: metadata: creationTimestamp: null labels: app: nginx spec: containers: - image: nginx name: nginx1 resources: {} status: {}

[zhangpeng@zhangpeng k8s]$ kubectl apply -f nginx1.yaml deployment.apps/nginx1 created

Deployment repliceset and Pods

这是因为我们前面将Pod与Deployment绑定使用了（其实我的个人环境完全可以这样，因为我的标签没有重复使用的都区分了不同的名称）

关于deployment与RepliceSet:

[root@k8s-master-01 test]# kubectl get deployments NAME READY UP-TO-DATE AVAILABLE AGE nginx 1/1 1 1 2m40s nginx1 1/1 1 1 2m16s [root@k8s-master-01 test]# kubectl get pods NAME READY STATUS RESTARTS AGE nginx-6799fc88d8-sbrcd 1/1 Running 0 2m46s nginx1-6dc5c6d499-bzhgn 1/1 Running 0 2m22s [root@k8s-master-01 test]# kubectl get rs NAME DESIRED CURRENT READY AGE nginx-6799fc88d8 1 1 1 3m42s nginx1-6dc5c6d499 1 1 1 3m18s

/src/common/common.go

package common import ( "context" "k8s-demo1/src/lib" v1 "k8s.io/api/apps/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" ) func GetRsLableByDeployment(dep *v1.Deployment) string { selector, _ := metav1.LabelSelectorAsSelector(dep.Spec.Selector) listOpt := metav1.ListOptions{ LabelSelector: selector.String(), } rs, _ := lib.K8sClient.AppsV1().ReplicaSets(dep.Namespace).List(context.Background(), listOpt) for _, item := range rs.Items { if IsCurrentRsByDep(dep, item) { s, err := metav1.LabelSelectorAsSelector(item.Spec.Selector) if err != nil { return "" } return s.String() } } return "" } func IsCurrentRsByDep(dep *v1.Deployment, rs v1.ReplicaSet) bool { if rs.ObjectMeta.Annotations["deployment.kubernetes.io/revision"] != dep.ObjectMeta.Annotations["deployment.kubernetes.io/revision"] { return false } for _, ref := range rs.OwnerReferences { if ref.Kind == "Deployment" && ref.Name == dep.Name { return true } } return false }

/src/service/deployment.go

package service import ( "context" "fmt" "github.com/gin-gonic/gin" "k8s-demo1/src/common" "k8s-demo1/src/core" . "k8s-demo1/src/lib" v1 "k8s.io/api/apps/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" ) type Deployment struct { Namespace string Name string Replicas int32 AvailableReplicas int32 UnavailableReplicas int32 Images string CreateTime string Labels map[string]string Pods []*Pod } func ListDeployment(g *gin.Context) { ns := g.Query("ns") deplist, err := core.DepMap.ListByNS(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 deplist { ret = append(ret, &Deployment{ Namespace: item.Namespace, Name: item.Name, Replicas: item.Status.Replicas, AvailableReplicas: item.Status.AvailableReplicas, UnavailableReplicas: item.Status.UnavailableReplicas, Images: item.Spec.Template.Spec.Containers[0].Image, CreateTime: item.CreationTimestamp.Format("2006-01-02 15:03:04"), Labels: item.GetLabels(), Pods: GetPodsByDep(ns, item), }) } g.JSON(200, ret) return } func GetDeployment(g *gin.Context) { ns := g.Query("ns") name := g.Query("name") ctx := context.Background() getopt := metav1.GetOptions{} dps, err := K8sClient.AppsV1().Deployments(ns).Get(ctx, name, getopt) if err != nil { fmt.Println(err) } ret := make([]*Deployment, 0) ret = append(ret, &Deployment{ Namespace: dps.Namespace, Name: dps.Name, Replicas: dps.Status.Replicas, AvailableReplicas: dps.Status.AvailableReplicas, UnavailableReplicas: dps.Status.UnavailableReplicas, Images: dps.Spec.Template.Spec.Containers[0].Image, CreateTime: dps.CreationTimestamp.Format("2006-01-02 15:03:04"), Labels: dps.Labels, Pods: GetPodsByDep(ns, dps), }) //fmt.Println(ret) g.JSON(200, ret) return } func GetLabels(m map[string]string) string { labels := "" // aa=xxx,xxx=xx for k, v := range m { if labels != "" { labels += "," } labels += fmt.Sprintf("%s=%s", k, v) } return labels } func GetPodsByDep(ns string, dep *v1.Deployment) []*Pod { ctx := context.Background() listopt := metav1.ListOptions{ LabelSelector: common.GetRsLableByDeployment(dep), } list, err := K8sClient.CoreV1().Pods(ns).List(ctx, listopt) if err != nil { panic(err.Error()) } pods := make([]*Pod, len(list.Items)) for i, pod := range list.Items { pods[i] = &Pod{ Namespace: pod.Namespace, Name: pod.Name, //获取 pod名称 Status: string(pod.Status.Phase), Images: pod.Spec.Containers[0].Image, NodeName: pod.Spec.NodeName, //所属节点 Labels: pod.Labels, CreateTime: pod.CreationTimestamp.Format("2006-01-02 15:04:05"), //创建时间 } } return pods }

/src/main.go

package main import ( "github.com/gin-gonic/gin" "k8s-demo1/src/core" "k8s-demo1/src/service" // "k8s.io/client-go/informers/core" ) 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.GET("/deployment", service.GetDeployment) r.GET("pods", service.ListallPod) // r.GET("deployment1", service.GetDeployment1) core.InitDeployment() r.Run() }

收获：

代码好多https://github.com/cleverhu/k8s-manger-v1中copy来的。 deployment repliceset pods之间的关系还要深究一下。kubernetes基础知识还是要更深入一下 代码写的还是很不顺畅......一步一步来吧

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。