client-go gin的简单整合八Service-list初步收尾

分类：菜鸟笔记作者：对你无可奈何

背景：

完成了client-go gin的简单整合七-继续完善，准备整合一下前面的代码（当然了关于上一节的坑还是先留着......没有想好怎么搞：https://www.yuque.com/duiniwukenaihe/hg6ymd/ipd4bf#R0XxW）。这里以service为例也实现一下list watch......

list watch实现service list:

模仿/src/core/deployment_int.go写一个/src/core/service_int.go:

/src/core/service_int.go

package core

import (
	"fmt"
	corev1 "k8s.io/api/core/v1"
	"log"
	"sync"
)

type ServiceMap struct {
	data sync.Map
}

func (svcmap *ServiceMap) Add(dep *corev1.Service) {
	if list, ok := svcmap.data.Load(dep.Namespace); ok {
		list = append(list.([]*corev1.Service), dep)
		svcmap.data.Store(dep.Namespace, list)
	} else {
		svcmap.data.Store(dep.Namespace, []*corev1.Service{dep})
	}
}
func (svcmap *ServiceMap) Update(dep *corev1.Service) error {
	if list, ok := svcmap.data.Load(dep.Namespace); ok {
		for i, range_dep := range list.([]*corev1.Service) {
			if range_dep.Name == dep.Name {
				list.([]*corev1.Service)[i] = dep
				svcmap.data.Store(dep.Namespace, list)
			}
		}
		return nil
	}
	return fmt.Errorf("Service-%s not found", dep.Name)
}

// 删除
func (svcmap *ServiceMap) Delete(dep *corev1.Service) {
	if list, ok := svcmap.data.Load(dep.Namespace); ok {
		for i, range_dep := range list.([]*corev1.Service) {
			if range_dep.Name == dep.Name {
				newList := append(list.([]*corev1.Service)[:i], list.([]*corev1.Service)[i+1:]...)
				svcmap.data.Store(dep.Namespace, newList)
				break
			}
		}
	}
}
func (svcmap *ServiceMap) ListByNS(ns string) ([]*corev1.Service, error) {
	if list, ok := svcmap.data.Load(ns); ok {
		return list.([]*corev1.Service), nil
	}
	return nil, fmt.Errorf("record not found")
}
func (svcmap *ServiceMap) GetService(ns string, name string) (*corev1.Service, error) {
	depList, err := svcmap.ListByNS(ns)
	if err != nil {
		return nil, fmt.Errorf("Service not found")
	}
	for _, item := range depList {
		if item.Name == name {
			return item, nil
		}
	}
	return nil, fmt.Errorf("Service not found")
}

var svcmap *ServiceMap

func init() {
	svcmap = &ServiceMap{}
}

type SvcHandler struct {
}

func (d *SvcHandler) OnAdd(obj interface{}) {
	//fmt.Println(obj.(*corev1.Service).Name)
	svcmap.Add(obj.(*corev1.Service))
}
func (d *SvcHandler) OnUpdate(oldObj, newObj interface{}) {
	err := svcmap.Update(newObj.(*corev1.Service))
	if err != nil {
		log.Println(err)
	}
}
func (d *SvcHandler) OnDelete(obj interface{}) {
	if d, ok := obj.(*corev1.Service); ok {
		svcmap.Delete(d)
	}
}

Int

/src/core/deployment_init.go Init中增加ServiceInformer相关配置：

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{})
	ServiceInformer := factory.Core().V1().Services()
	ServiceInformer.Informer().AddEventHandler(&SvcHandler{})
	factory.Start(wait.NeverStop)
}

注意：只截取了相关配置，没有复制整个文件！

修改Service.go为list watch模式

/src/service/Service.go not list-watch原代码：

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
	Type       string
	ClusterIp  string
	ExternalIp []string
	Ports      []string
	Select     map[string]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,
			Type:       string(item.Spec.Type),
			ClusterIp:  item.Spec.ClusterIP,
			ExternalIp: item.Spec.ExternalIPs,
			Select:     item.Spec.Selector,
		})

	}
	g.JSON(200, ret)
	return
}

修改成list watch方式：

package service

import (
	"github.com/gin-gonic/gin"
	"k8s-demo1/src/core"
	corev1 "k8s.io/api/core/v1"
)

type Service struct {
	Name       string
	Type       string
	ClusterIp  string
	ExternalIp []string
	Ports      []corev1.ServicePort
	Select     map[string]string
}

func ListService(g *gin.Context) {
	ns := g.Query("ns")
	//svc, err := K8sClient.CoreV1().Services(ns).List(context.Background(), metav1.ListOptions{})
	svclist, _ := core.SVCMap.ListByNS(ns)
	ret := make([]*Service, 0)
	for _, item := range svclist {
		ret = append(ret, &Service{
			Name:       item.Name,
			Type:       string(item.Spec.Type),
			ClusterIp:  item.Spec.ClusterIP,
			ExternalIp: item.Spec.ExternalIPs,
			Ports:      item.Spec.Ports,
			Select:     item.Spec.Selector,
		})

	}
	g.JSON(200, ret)
	return
}

运行main.go

package main

import (
	"github.com/gin-gonic/gin"
	"k8s-demo1/src/core"
	"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.GET("pods", service.ListallPod)
	core.InitDeployment()
	r.Run()
}

image.png

做一个svc

[zhangpeng@zhangpeng k8s]$ cat nginx1-deployment.yaml 
apiVersion: v1
kind: Service
metadata:
  name: nginx1
  labels:
    app: nginx
spec:
  ports:
  - port: 80
    protocol: TCP
    targetPort: 80
  selector:
    app: nginx
[zhangpeng@zhangpeng k8s]$ kubectl apply -f  nginx1-deployment.yaml 
service/nginx1 created
[zhangpeng@zhangpeng k8s]$ kubectl get svc
NAME         TYPE        CLUSTER-IP     EXTERNAL-IP   PORT(S)   AGE
kubernetes   ClusterIP   10.96.0.1      <none>        443/TCP   47d
nginx1       ClusterIP   10.111.134.5   <none>        80/TCP    48s

image.png

注：访问 svc就免了，我这里肯定会有问题的。我的app label都是nginx。所以我不能精确指定到deployment1的（我的初衷），所以尽量是app label去区分deployment！。随便修改一下nginx中index.html就发现他都会调度的几个deployments。所以我前面整deployment的时候也是一种耍流氓了...不过我还是想区分一下搞出来！

image.png

总结：

  1. list watch 就实现一个service了 statefulset configmap 其他的最后实现吧,curd先实现一下简单的
  2. deployment 的坑还是先留着......
  3. 下面继续准备实现一下create delete update的方法......

原文地址：https://cloud.tencent.com/developer/article/2024034

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。

相关推荐

如何学习编程？新手菜鸟如何学编程？
学习编程是顺着互联网的发展潮流，是一件好事。新手如何学习编程？其实不难，不过在学习编程之前你得先了解你的目的是什么？这个很重要，因为目的决定你的发展方向、决定你的发展速度。
it行业都是什么工作？it行业主要做什么？
IT行业是什么工作做什么？IT行业的工作有：产品策划类、页面设计类、前端与移动、开发与测试、营销推广类、数据运营类、运营维护类、游戏相关类等，根据不同的分类下面有细分了不同的岗位。
女生学Java好就业吗？女生适合学Java编程吗？
女生学Java好就业吗？女生适合学Java编程吗？目前有不少女生学习Java开发，但要结合自身的情况，先了解自己适不适合去学习Java，不要盲目的选择不适合自己的Java培训班进行学习。只要肯下功夫钻研，多看、多想、多练
mysql-connect-confused
Can’t connect to local MySQL server through socket \'/var/lib/mysql/mysql.sock问题 1.进入mysql路径
oracle基本命令
oracle基本命令 一、登录操作 1.管理员登录 # 管理员登录 sqlplus / as sysdba 2.普通用户登录
shell判断服务是否启动
一、背景 因为项目中需要通北京网络，所以需要连vpn，但是服务器有时候会断掉，所以写个shell脚本每五分钟去判断是否连接，于是就有下面的shell脚本。
SQL BETWEEN 操作符
BETWEEN 操作符选取介于两个值之间的数据范围内的值。这些值可以是数值、文本或者日期。
​​windows上传ipa到开发者中心app store的方法
假如你已经使用过苹果开发者中心上架app，你肯定知道在苹果开发者中心的web界面，无法直接提交ipa文件，而是需要使用第三方工具，将ipa文件上传到构建版本，开...
SQL 入门篇之什么是别名？
下面的 SQL 语句指定了两个别名，一个是 name 列的别名，一个是 country 列的别名。**提示：**如果列名称包含空格，要求使用双引号或方括号：
windows上传ipa文件到app store的方法​
在使用H5混合开发的app打包后，需要将ipa文件上传到appstore进行发布，就需要去苹果开发者中心进行发布。​
SQL AND & OR 运算符
+----+--------------+---------------------------+-------+---------+
C++ 数组
数组的声明并不是声明一个个单独的变量，比如 number0、number1、...、number99，而是声明一个数组变量，比如 numbers，然后使用 nu...
最全iOS 应用上架流程提交到AppStore
第一步：到appuploader官网下载辅助工具和iCloud驱动，使用前面创建的AppID登录。
SQL ALTER TABLE 语句
如需删除表中的列，请使用下面的语法（请注意，某些数据库系统不允许这种在数据库表中删除列的方式）：
dism操作巨慢
前不久在制作win11pe，制作了一版，1.26GB，太大了，不满意，想再裁剪下，发现这次dism mount正常，commit或discard巨慢，以前都很快...
三种方法卸载Symantec Endpoint Protection 赛门铁克
赛门铁克各个版本概览：https://knowledge.broadcom.com/external/article?legacyId=tech163829
python3.6、python3.10用什么版本的pip
实测Python 3.6.6用pip 21.3.1，再高就报错了，Python 3.10.7用pip 22.3.1是可以的
博通和诺顿
Broadcom Corporation （博通公司，股票代号AVGO）是全球领先的有线和无线通信半导体公司。其产品实现向家庭、 办公室和移动环境以及在这些环境...
高版本c4d在低版本windows系统上打开后不显示窗格
发现个问题，server2016上安装了c4d这些版本，低版本的正常显示窗格，但红色圈出的高版本c4d打开后不显示窗格，
基础网络windows不要使用TAT、如何卸载TAT
TAT：https://cloud.tencent.com/document/product/1340
pythonJavaScriptjavaHTMLPHPreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-boot