【client-go gin的简单整合七-继续完善】著论准过秦，作赋拟子虚。这篇文章主要讲述client-go gin的简单整合七-继续完善相关的知识，希望能为你提供帮助。
背景：紧接上文：client-go gin的简单整合六-list-watch二（关于Rs与Pod以及Deployment的完善）,继续去完善相关的event 以及显示pod ip等相关配置还要继续搞一下指定deployment name显示相关pod信息！
client-go gin的简单整合七-继续完善 为什么要加一下event呢？ 举一个例子
cat nginx3.yaml

apiVersion: apps/v1 kind: Deployment metadata: creationTimestamp: null labels: app: nginx name: nginx3 spec: replicas: 1 selector: matchLabels: app: nginx strategy: template: metadata: creationTimestamp: null labels: app: nginx spec: containers: - image: nginx name: nginx command: ["/abc"] resources: status:

[zhangpeng@zhangpeng k8s]$ kubectl apply -f nginx3.yaml deployment.apps/nginx3 created [zhangpeng@zhangpeng k8s]$ kubectl get pods -o wide NAMEREADYSTATUSRESTARTSAGEIPNODENOMINATED NODEREADINESS GATES nginx-85b98978db-xk7kc1/1Running021d10.244.1.22k8s-2< none> < none> nginx1-85b98978db-wmvck1/1Running028h10.244.1.29k8s-2< none> < none> nginx2-6b5fb95cd4-77lk51/1Running029h10.244.1.27k8s-2< none> < none> nginx3-9df8ff7bf-mjb2g0/1CrashLoopBackOff1 (17s ago)50s10.244.1.32k8s-2< none> < none>

文章图片

but!访问：http://127.0.0.1:8080/deployments?ns=default（上一节运行的main.go依然在运行前提）

文章图片

为什么pod明明CrashLoopBackOff 了但是他还显示running......
参照：https://kubernetes.io/zh/docs/concepts/workloads/pods/pod-lifecycle/

文章图片


文章图片

解决方式：
想到的是判断pod contonditions中status是否为True，如果不是true则打印message字段，写一个方法：
/src/service/PodUtil.go

package serviceimport v1 "k8s.io/api/core/v1"func GetPodMessage(pod v1.Pod) string message := "" for _, contition := range pod.Status.Conditions if contition.Status != "True" message += contition.Messagereturn message

Pod的struct ,添加对应字段Message：
/src/service/Pod.go

package serviceimport ( "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 Pod struct Namespacestring Namestring Statusstring Imagesstring NodeNamestring CreateTime string Messagestring Labelsmap[string]stringfunc ListallPod(g *gin.Context) ns := g.Query("ns")//pods, err := K8sClient.CoreV1().Pods(ns).List(context.Background(), metav1.ListOptions) pods, err := core.PodMap.ListByNS(ns) if err != nil g.Error(err)ret := make([]*Pod, 0) for _, item := range pods ret = append(ret, & Pod Namespace:item.Namespace, Name:item.Name, Status:string(item.Status.Phase), Labels:item.Labels, NodeName:item.Spec.NodeName, Images:item.Spec.Containers[0].Image, Message:GetPodMessage(*item), CreateTime: item.CreationTimestamp.Format("2006-01-02 15:04:05"), )g.JSON(200, ret) return

/src/service/Deployment.go

package serviceimport ( "fmt" "github.com/gin-gonic/gin" "k8s-demo1/src/core" v1 "k8s.io/api/apps/v1" "log" )type Deployment struct Namespacestring Namestring Replicasint32 AvailableReplicasint32 UnavailableReplicas int32 Imagesstring CreateTimestring Labelsmap[string]string Pods[]*Podfunc ListDeployment(g *gin.Context) ns := g.Query("ns") deplist, _ := 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(*item), CreateTime:item.CreationTimestamp.Format("2006-01-02 15:03:04"), )g.JSON(200, ret) returnfunc 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 labelsfunc GetPodsByDep(dep v1.Deployment) []*Pod rsLabelsMap, err := core.RSMap.GetRsLabelsByDeployment(& dep) if err != nil log.Fatal(err)pods, err := core.PodMap.ListByRsLabels(dep.Namespace, rsLabelsMap) if err != nil log.Fatal(err)ret := make([]*Pod, 0)for _, pod := range pods if core.RSMap.GetRsLabelsByDeploymentname(& dep) == pod.OwnerReferences[0].Name ret = append(ret, & Pod Name:pod.Name, Namespace:pod.Namespace, Images:pod.Spec.Containers[0].Image, NodeName:pod.Spec.NodeName, Labels:pod.Labels, Status:string(pod.Status.Phase), Message:GetPodMessage(*pod), CreateTime: pod.CreationTimestamp.Format("2006-01-02 15:04:05"), )return ret

运行mai.go
http://127.0.0.1:8080/deployments?ns=default

文章图片

http://127.0.0.1:8080/pods?ns=default

文章图片

list-watch实现一下event注：抄来的，还要消化一下
/src/core/event_int.go

package coreimport ( "fmt" v1 "k8s.io/api/core/v1" "sync" )var EventMap *EventMapStructtype EventMapStruct struct data sync.Mapfunc (eventmap EventMapStruct) GetMessage(ns string, kind string, name string) string key := fmt.Sprintf("%s-%s-%s", ns, kind, name) if v, ok := eventmap.data.Load(key); ok return v.(*v1.Event).Messagereturn ""type EventHandler structfunc (eventmap *EventHandler) storeData(obj interface, isDelete bool) if event, ok := obj.(*v1.Event); ok key := fmt.Sprintf("%s-%s-%s", event.Namespace, event.InvolvedObject.Kind, event.InvolvedObject.Name) if !isDelete EventMap.data.Store(key, event) else EventMap.data.Delete(key)func (eventmap *EventHandler) OnAdd(obj interface) eventmap.storeData(obj, false)func (eventmap *EventHandler) OnUpdate(oldObj, newObj interface) eventmap.storeData(newObj, false)func (eventmap *EventHandler) OnDelete(obj interface) eventmap.storeData(obj, true)func init() EventMap = & EventMapStruct

在/src/core/deployment_int.go int初始化中添加eventInformer：

func InitDeployment() factory := informers.NewSharedInformerFactory(lib.K8sClient, 0) depinformer := factory.Apps().V1().Deployments() depinformer.Informer().AddEventHandler(& DepHandler) Podinformer := factory.Core().V1().Pods() Podinformer.Informer().AddEventHandler(& PodHandler) Rsinformer := factory.Apps().V1().ReplicaSets() Rsinformer.Informer().AddEventHandler(& RSHandler) eventInformer := factory.Core().V1().Events() eventInformer.Informer().AddEventHandler(& EventHandler) factory.Start(wait.NeverStop)

/src/service/Pod.go

package serviceimport ( "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 Pod struct Namespacestring Namestring Statusstring Imagesstring NodeNamestring CreateTime string //IsReadybool Messagestring HostIpstring PodIpstring RestartCount int32 Labelsmap[string]stringfunc ListallPod(g *gin.Context) ns := g.Query("ns")//pods, err := K8sClient.CoreV1().Pods(ns).List(context.Background(), metav1.ListOptions) pods, err := core.PodMap.ListByNS(ns) if err != nil g.Error(err)ret := make([]*Pod, 0) for _, item := range pods ret = append(ret, & Pod Namespace: item.Namespace, Name:item.Name, Status:string(item.Status.Phase), Labels:item.Labels, NodeName:item.Spec.NodeName, Images:item.Spec.Containers[0].Image, //IsReady:GetPodIsReady(*item), //Message: GetPodMessage(*item), Message:core.EventMap.GetMessage(item.Namespace, "Pod", item.Name), HostIp:item.Status.HostIP, PodIp:item.Status.PodIP, RestartCount: item.Status.ContainerStatuses[0].RestartCount, CreateTime:item.CreationTimestamp.Format("2006-01-02 15:04:05"), )g.JSON(200, ret) returnfunc ListPodsByLabel(ns string, labels []map[string]string) (ret []*Pod) list, err := core.PodMap.ListByRsLabels(ns, labels) if err != nil return nilfor _, item := range list ret = append(ret, & Pod Name:item.Name, Namespace: item.Namespace, Images:item.Spec.Containers[0].Image, NodeName:item.Spec.NodeName, Status:string(item.Status.Phase), //Message: GetPodMessage(*item), Message:core.EventMap.GetMessage(item.Namespace, "Pod", item.Name), RestartCount: item.Status.ContainerStatuses[0].RestartCount, CreateTime:item.CreationTimestamp.Format("2006-01-02 15:22:33"), )return

文章图片

/src/deployment/Deployment.go中Message也可以修改一下：

package serviceimport ( "fmt" "github.com/gin-gonic/gin" "k8s-demo1/src/core" v1 "k8s.io/api/apps/v1" "log" )type Deployment struct Namespacestring Namestring Replicasint32 AvailableReplicasint32 UnavailableReplicas int32 Imagesstring CreateTimestring Labelsmap[string]string Pods[]*Podfunc ListDeployment(g *gin.Context) ns := g.Query("ns") deplist, _ := 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(*item), CreateTime:item.CreationTimestamp.Format("2006-01-02 15:03:04"), )g.JSON(200, ret) returnfunc GetLabels(m map[string]string) string labels := "" // aa=xxx,xxx=xxfor k, v := range m if labels != "" labels += ","labels += fmt.Sprintf("%s=%s", k, v)return labelsfunc GetPodsByDep(dep v1.Deployment) []*Pod rsLabelsMap, err := core.RSMap.GetRsLabelsByDeployment(& dep) if err != nil log.Fatal(err)pods, err := core.PodMap.ListByRsLabels(dep.Namespace, rsLabelsMap) if err != nil log.Fatal(err)ret := make([]*Pod, 0)for _, pod := range pods if core.RSMap.GetRsLabelsByDeploymentname(& dep) == pod.OwnerReferences[0].Name ret = append(ret, & Pod Name:pod.Name, Namespace: pod.Namespace, Images:pod.Spec.Containers[0].Image, NodeName:pod.Spec.NodeName, Labels:pod.Labels, Status:string(pod.Status.Phase), //IsReady:GetPodIsReady(*pod), //Message:GetPodMessage(*pod), Message:core.EventMap.GetMessage(pod.Namespace,"Pod",pod.Name), HostIp:pod.Status.HostIP, PodIp:pod.Status.PodIP, RestartCount: pod.Status.ContainerStatuses[0].RestartCount, CreateTime:pod.CreationTimestamp.Format("2006-01-02 15:04:05"), )return ret

关于Pod IP

[zhangpeng@zhangpeng k8s]$ kubectl edit pod nginx1-85b98978db-wmvck

文章图片
pod相关字段有两个 podIPhostIP pod struct 添加相关字段HostIp PodIp：
/src/service/Pod.go

package serviceimport ( "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 Pod struct Namespacestring Namestring Statusstring Imagesstring NodeNamestring CreateTime string Messagestring HostIpstring PodIpstring Labelsmap[string]stringfunc ListallPod(g *gin.Context) ns := g.Query("ns")//pods, err := K8sClient.CoreV1().Pods(ns).List(context.Background(), metav1.ListOptions) pods, err := core.PodMap.ListByNS(ns) if err != nil g.Error(err)ret := make([]*Pod, 0) for _, item := range pods ret = append(ret, & Pod Namespace: item.Namespace, Name:item.Name, Status:string(item.Status.Phase), Labels:item.Labels, NodeName:item.Spec.NodeName, Images:item.Spec.Containers[0].Image, Message:GetPodMessage(*item), HostIp:item.Status.HostIP, PodIp:item.Status.PodIP, CreateTime: item.CreationTimestamp.Format("2006-01-02 15:04:05"), )g.JSON(200, ret) returnfunc ListPodsByLabel(ns string, labels []map[string]string) (ret []*Pod) list, err := core.PodMap.ListByRsLabels(ns, labels) if err != nil return nilfor _, item := range list ret = append(ret, & Pod Name:item.Name, Namespace: item.Namespace, Images:item.Spec.Containers[0].Image, NodeName:item.Spec.NodeName, Status:string(item.Status.Phase), //Message: GetPodMessage(*item), Message:core.EventMap.GetMessage(item.Namespace, "Pod", item.Name), CreateTime: item.CreationTimestamp.Format("2006-01-02 15:22:33"), )return

/src/service/Deployment.go

package serviceimport ( "fmt" "github.com/gin-gonic/gin" "k8s-demo1/src/core" v1 "k8s.io/api/apps/v1" "log" )type Deployment struct Namespacestring Namestring Replicasint32 AvailableReplicasint32 UnavailableReplicas int32 Imagesstring CreateTimestring Labelsmap[string]string Pods[]*Podfunc ListDeployment(g *gin.Context) ns := g.Query("ns") deplist, _ := 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(*item), CreateTime:item.CreationTimestamp.Format("2006-01-02 15:03:04"), )g.JSON(200, ret) returnfunc GetLabels(m map[string]string) string labels := "" // aa=xxx,xxx=xxfor k, v := range m if labels != "" labels += ","labels += fmt.Sprintf("%s=%s", k, v)return labelsfunc GetPodsByDep(dep v1.Deployment) []*Pod rsLabelsMap, err := core.RSMap.GetRsLabelsByDeployment(& dep) if err != nil log.Fatal(err)pods, err := core.PodMap.ListByRsLabels(dep.Namespace, rsLabelsMap) if err != nil log.Fatal(err)ret := make([]*Pod, 0)for _, pod := range pods if core.RSMap.GetRsLabelsByDeploymentname(& dep) == pod.OwnerReferences[0].Name ret = append(ret, & Pod Name:pod.Name, Namespace: pod.Namespace, Images:pod.Spec.Containers[0].Image, NodeName:pod.Spec.NodeName, Labels:pod.Labels, Status:string(pod.Status.Phase), Message:GetPodMessage(*pod), HostIp:pod.Status.HostIP, PodIp:pod.Status.PodIP, CreateTime: pod.CreationTimestamp.Format("2006-01-02 15:04:05"), )return ret

http://127.0.0.1:8080/deployments?ns=default

文章图片

http://127.0.0.1:8080/pods?ns=default
文章图片

Pod重启次数

[zhangpeng@zhangpeng k8s]$ kubectl edit pod nginx3-9df8ff7bf-mzddn

文章图片

/src/service/Pod.go,Pod struct增加RestartCount int32,取值字段item.Status.ContainerStatuses[0].RestartCount，如下（多个容器后面是不是要考虑循环取值？以后在说吧......）：

type Pod struct Namespacestring Namestring Statusstring Imagesstring NodeNamestring CreateTime string //IsReadybool Messagestring HostIpstring PodIpstring RestartCount int32 Labelsmap[string]stringfunc ListallPod(g *gin.Context) ns := g.Query("ns")//pods, err := K8sClient.CoreV1().Pods(ns).List(context.Background(), metav1.ListOptions) pods, err := core.PodMap.ListByNS(ns) if err != nil g.Error(err)ret := make([]*Pod, 0) for _, item := range pods ret = append(ret, & Pod Namespace: item.Namespace, Name:item.Name, Status:string(item.Status.Phase), Labels:item.Labels, NodeName:item.Spec.NodeName, Images:item.Spec.Containers[0].Image, //IsReady:GetPodIsReady(*item), Message: GetPodMessage(*item), //Message:core.EventMap.GetMessage(item.Namespace, "Pod", item.Name), HostIp:item.Status.HostIP, PodIp:item.Status.PodIP, RestartCount: item.Status.ContainerStatuses[0].RestartCount, CreateTime:item.CreationTimestamp.Format("2006-01-02 15:04:05"), )g.JSON(200, ret) return

文章图片

接下来的问题：先删除nginx3 deployment:

[zhangpeng@zhangpeng k8s]$ kubectl delete -f nginx3.yaml deployment.apps "nginx3" deleted

创建一个正常的nginx3.yaml

apiVersion: apps/v1 kind: Deployment metadata: creationTimestamp: null labels: app: nginx name: nginx3 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 nginx3.yaml deployment.apps/nginx3 created [zhangpeng@zhangpeng k8s]$ kubectl get pods NAMEREADYSTATUSRESTARTSAGE nginx-85b98978db-xk7kc1/1Running023d nginx1-85b98978db-wmvck1/1Running03d23h nginx2-6b5fb95cd4-77lk51/1Running04d nginx3-6f97cd4f65-k7ffx0/1ContainerCreating04s

文章图片

[zhangpeng@zhangpeng k8s]$ cp nginx3.yaml nginx33.yaml

vim nginx33.yaml继续创建一个无法成功启动的Pod:

apiVersion: apps/v1 kind: Deployment metadata: creationTimestamp: null labels: app: nginx name: nginx3 spec: replicas: 1 selector: matchLabels: app: nginx strategy: template: metadata: creationTimestamp: null labels: app: nginx spec: containers: - image: nginx name: nginx command: ["/abc"] resources: status:

[zhangpeng@zhangpeng k8s]$ kubectl apply -f nginx33.yaml deployment.apps/nginx3 configured

文章图片

but:

文章图片

恩 我这里做的还是有问题，deployment中数量显示了 但是没有能显示那个没有成功的pod......(貌似只有重启后才发现最新的，但是也还是显示一个......).这里没有想好怎么处理......也希望有大佬能给指点迷津！
总结：

1. event实现了list watch
2. ip restartcount如何在pod中获取
3. 怎么样显示nginx3示例中两个pod？要好好想一下！

推荐阅读

• 

  南宁：房贷利率新政实施后买房能省多少钱？
• 

  drive|希捷推出 Xbox 专用外置 SSD：1TB 约 1095元，USB 3.2 Gen1 接口
• 

  农户贷款如何界定 「一般农户指什么」
• 

  java用什么软件写代码，JAVA用什么软件编写
• 

  不要吃发物 不要吃过甜过咸和酸性的食物
• 

  八角金盘的介绍-八角金盘的作用
• 

  flutter添加横线，flutter虚线边框
• 

  为什么戒烟后会发胖？
• 

  佛珠多肉烂根怎么办 佛珠多肉烂了怎么办
• 

  中国知名菜刀有什么牌子？中国十大菜刀品牌排行
• 

  从入门到精通，轻松应对各种错误 打印机1700代码解析
• 

  水果礼盒制作步骤大全图解 水果礼盒的制作技巧是怎么样的
• 

  支付宝花呗当面花怎么使用？使用方法及店铺详细介绍
• 

  恒为科技的军方服务器具有怎样的性能？ 恒为科技军方服务器怎么样
• 

  gis中画的图成无效的书签，gis图没了
• 

  工商银行主要业务有哪些
• 

  iphone皮套
• 

  爱普生1430喷墨机清零
• 

  关于vb.neteval的信息
• 

  非诚勿扰影视产业分析

• HDU - 1301Jungle Roads（并查集+最小生成树）（内附最小生成树两种算法 克鲁斯特尔算法&&普里姆算法）
• 全链路监控pinpoint安装部署
• 金蝶云星空与钉钉集成解决方案（钉钉审批）
• Mysqldump使用手册
• 1行Python代码，获取对方的IP地址
• HDU - 3172Virtual Friends（带权并查集--权为集合元素个数）
• outlook2019启动长时间卡在加载配置文件问题定位
• 教你搭建一个Telegraf+Influxdb+Grafana 监控系统
• HDU - 1276士兵队列训练问题 （报数问题 模拟）