【GO】 K8s 管理系统项目[API部分--Namespace]

news2024/11/18 20:35:08

K8s 管理系统项目[API部分–Namespace]

1. 接口实现

service/dataselector.go

type namespaceCell corev1.Namespace

func(n namespaceCell) GetCreation() time.Time {
	return n.CreationTimestamp.Time
}

func(n namespaceCell) GetName() string {
	return n.Name
}

2. Namespace功能

service/namespace.go

2.1 重写方法

func (n *namespace) toCells(std []corev1.Namespace) []DataCell {
	cells := make([]DataCell, len(std))
	for i := range std {
		cells[i] = namespaceCell(std[i])
	}
	return cells
}

func (n *namespace) fromCells(cells []DataCell) []corev1.Namespace {
	namespaces := make([]corev1.Namespace, len(cells))
	for i := range cells {
		namespaces[i] = corev1.Namespace(cells[i].(namespaceCell))
	}

	return namespaces
}

2.1 获取Namespace详情

// 获取namespace详情
func (n *namespace) GetNamespaceDetail(namespaceName string) (namespace *corev1.Namespace, err error) {
	namespace, err = K8s.ClientSet.CoreV1().Namespaces().Get(context.TODO(), namespaceName, metav1.GetOptions{})
	if err != nil {
		logger.Error(errors.New("获取Namespace详情失败, " + err.Error()))
		return nil, errors.New("获取Namespace详情失败, " + err.Error())
	}

	return namespace, nil
}

2.2 删除Namespace

// 删除namespace
func (n *namespace) DeleteNamespace(namespaceName string) (err error) {
	err = K8s.ClientSet.CoreV1().Namespaces().Delete(context.TODO(), namespaceName, metav1.DeleteOptions{})
	if err != nil {
		logger.Error(errors.New("删除Namespace失败, " + err.Error()))
		return errors.New("删除Namespace失败, " + err.Error())
	}

	return nil
}

2.3 Namespace完整

package service

import (
	"context"
	"errors"

	"github.com/wonderivan/logger"
	corev1 "k8s.io/api/core/v1"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)

var Namespace namespace

type namespace struct{}

type NamespacesResp struct {
	Items []corev1.Namespace `json:"items"`
	Total int                `json:"total"`
}

// 获取namespace列表，支持过滤、排序、分页
func (n *namespace) GetNamespaces(filterName string, limit, page int) (namespacesResp *NamespacesResp, err error) {
	//获取namespaceList类型的namespace列表
	namespaceList, err := K8s.ClientSet.CoreV1().Namespaces().List(context.TODO(), metav1.ListOptions{})
	if err != nil {
		logger.Error(errors.New("获取Namespace列表失败, " + err.Error()))
		return nil, errors.New("获取Namespace列表失败, " + err.Error())
	}
	//将namespaceList中的namespace列表(Items)，放进dataselector对象中，进行排序
	selectableData := &dataSelector{
		GenericDataList: n.toCells(namespaceList.Items),
		DataSelect: &DataSelectQuery{
			Filter: &FilterQuery{Name: filterName},
			Paginate: &PaginateQuery{
				Limit: limit,
				Page:  page,
			},
		},
	}

	filtered := selectableData.Filter()
	total := len(filtered.GenericDataList)
	data := filtered.Sort().Paginate()

	//将[]DataCell类型的namespace列表转为v1.namespace列表
	namespaces := n.fromCells(data.GenericDataList)

	return &NamespacesResp{
		Items: namespaces,
		Total: total,
	}, nil
}

// 获取namespace详情
func (n *namespace) GetNamespaceDetail(namespaceName string) (namespace *corev1.Namespace, err error) {
	namespace, err = K8s.ClientSet.CoreV1().Namespaces().Get(context.TODO(), namespaceName, metav1.GetOptions{})
	if err != nil {
		logger.Error(errors.New("获取Namespace详情失败, " + err.Error()))
		return nil, errors.New("获取Namespace详情失败, " + err.Error())
	}

	return namespace, nil
}

// 删除namespace
func (n *namespace) DeleteNamespace(namespaceName string) (err error) {
	err = K8s.ClientSet.CoreV1().Namespaces().Delete(context.TODO(), namespaceName, metav1.DeleteOptions{})
	if err != nil {
		logger.Error(errors.New("删除Namespace失败, " + err.Error()))
		return errors.New("删除Namespace失败, " + err.Error())
	}

	return nil
}

func (n *namespace) toCells(std []corev1.Namespace) []DataCell {
	cells := make([]DataCell, len(std))
	for i := range std {
		cells[i] = namespaceCell(std[i])
	}
	return cells
}

func (n *namespace) fromCells(cells []DataCell) []corev1.Namespace {
	namespaces := make([]corev1.Namespace, len(cells))
	for i := range cells {
		namespaces[i] = corev1.Namespace(cells[i].(namespaceCell))
	}

	return namespaces
}

3. 获取Namespace列表

controller/namespace.go

package controller

import (
	"k8s-plantform/service"
	"net/http"

	"github.com/gin-gonic/gin"
	"github.com/wonderivan/logger"
)

var Namespace namespace

type namespace struct{}

// 获取namespace列表，支持过滤、排序、分页
func (n *namespace) GetNamespaces(ctx *gin.Context) {
	params := new(struct {
		FilterName string `form:"filter_name"`
		Page       int    `form:"page"`
		Limit      int    `form:"limit"`
	})
	if err := ctx.Bind(params); err != nil {
		logger.Error("Bind请求参数失败, " + err.Error())
		ctx.JSON(http.StatusInternalServerError, gin.H{
			"msg":  err.Error(),
			"data": nil,
		})
		return
	}

	data, err := service.Namespace.GetNamespaces(params.FilterName, params.Limit, params.Page)
	if err != nil {
		ctx.JSON(http.StatusInternalServerError, gin.H{
			"msg":  err.Error(),
			"data": nil,
		})
		return
	}

	ctx.JSON(http.StatusOK, gin.H{
		"msg":  "获取Namespace列表成功",
		"data": data,
	})
}

// 获取namespace详情
func (n *namespace) GetNamespaceDetail(ctx *gin.Context) {
	params := new(struct {
		NamespaceName string `form:"namespace_name"`
	})
	if err := ctx.Bind(params); err != nil {
		logger.Error("Bind请求参数失败, " + err.Error())
		ctx.JSON(http.StatusInternalServerError, gin.H{
			"msg":  err.Error(),
			"data": nil,
		})
		return
	}

	data, err := service.Namespace.GetNamespaceDetail(params.NamespaceName)
	if err != nil {
		ctx.JSON(http.StatusInternalServerError, gin.H{
			"msg":  err.Error(),
			"data": nil,
		})
		return
	}

	ctx.JSON(http.StatusOK, gin.H{
		"msg":  "获取Namespace详情成功",
		"data": data,
	})
}

// 删除namespace
func (n *namespace) DeleteNamespace(ctx *gin.Context) {
	params := new(struct {
		NamespaceName string `json:"namespace_name"`
	})
	//DELETE请求，绑定参数方法改为ctx.ShouldBindJSON
	if err := ctx.ShouldBindJSON(params); err != nil {
		logger.Error("Bind请求参数失败, " + err.Error())
		ctx.JSON(http.StatusInternalServerError, gin.H{
			"msg":  err.Error(),
			"data": nil,
		})
		return
	}

	err := service.Namespace.DeleteNamespace(params.NamespaceName)
	if err != nil {
		ctx.JSON(http.StatusInternalServerError, gin.H{
			"msg":  err.Error(),
			"data": nil,
		})
		return
	}
	ctx.JSON(http.StatusOK, gin.H{
		"msg":  "删除Namespace成功",
		"data": nil,
	})
}

4. 定义路由

controller/router.go

		//namespace操作
		GET("/api/k8s/namespaces", Namespace.GetNamespaces).
		GET("/api/k8s/namespace/detail", Namespace.GetNamespaceDetail).
		DELETE("/api/k8s/namespace/del", Namespace.DeleteNamespace)

5. 测试Namespace方法

5.1 获取Namespace

/api/k8s/namespaces

请添加图片描述

5.2 获取Namespace详情

/api/k8s/namespace/detail

请添加图片描述

5.3 删除Namespace

/api/k8s/namespace/del

root@master-01:~# kubectl  get ns
NAME              STATUS   AGE
default           Active   3d20h
ingress-nginx     Active   3d17h
k8s               Active   19h
kube-flannel      Active   3d20h
kube-node-lease   Active   3d20h
kube-public       Active   3d20h
kube-system       Active   3d20h
wework            Active   3d17h
root@master-01:~# kubectl get pods -n k8s
NAME                                READY   STATUS    RESTARTS   AGE
nginx-deployment-66b6c48dd5-44scf   1/1     Running   0          18h
nginx-deployment-66b6c48dd5-9gtjt   1/1     Running   0          18h
nginx-deployment-66b6c48dd5-rkww9   1/1     Running   0          18h

请添加图片描述

这里可以看到k8s命名空间连同下面的资源都被一并删除

root@master-01:~# kubectl get pods -n k8s
No resources found in k8s namespace.
root@master-01:~# kubectl get ns
NAME              STATUS   AGE
default           Active   3d20h
ingress-nginx     Active   3d17h
kube-flannel      Active   3d20h
kube-node-lease   Active   3d20h
kube-public       Active   3d20h
kube-system       Active   3d20h
wework            Active   3d17h

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/125150.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

景联文科技：赋能智能安防，详谈其中运用到的数据标注类型

景联文科技：赋能智能安防，详谈其中运用到的数据标注类型

“数据显示，2013-2020年我国智能安防行业市场规模由101亿元增长至511亿元。随着智能安防在多个领域的深化应用，预计2023年我国智能安防行业市场规模将超1000亿元。 智能安防领域中,数据标注主要应用于计算机视觉与语音识别两个主要领域，具体…
阅读更多...
人口数据可视化，深圳是人口密度最高的城市，东莞上海位居二三名

人口数据可视化，深圳是人口密度最高的城市，东莞上海位居二三名

进入2022年以来，人口问题频频引起热议，人口老龄化、生育意愿再创新低、男女比例失衡等等问题频出。具体的人口问题如何，跟随可视化互动平台的数据可视化大屏一起来了解吧！ 我国各省人口数量从地图分布图看，广东省、山…
阅读更多...
安装Pytorch

安装Pytorch

太难了 之前在学校就没安装好 各种报错 终于安装好了 浅浅记录一下 撒花撒花 菜鸡经验： 1.本地python 与 Anaconda 是两个独立的东西 2.可直接在Anaconda中创建不同新的虚拟环境以适配不同的需求 3.cuda 的版本与 NVIDIA版本需要一致，与Python环境也需要…
阅读更多...
Echarts图表相关知识

Echarts图表相关知识

一个基于 JavaScript 的开源可视化图表库。目前我们的前端框架中已经集成了Echarts库v5.3.2），使用的时候不需要再次安装，直接使用即可，具体安装方法不再赘述。 有些时候官网的例子不满足我们的需求，这个时候就要求我们…
阅读更多...
cq：fast lookup argument

cq：fast lookup argument

1. 引言 Ariel Gabizon等人2022年论文《cq: Cached quotients for fast lookups》。 lookup argument的核心思想为： 对于特定的quotient多项式，经某种预处理之后，将更易于计算其commitments。 当前的lookup argument系列方案主要有&#…
阅读更多...
实拍视频、图片素材库，高质量、免费下载。

实拍视频、图片素材库，高质量、免费下载。

这几个网站的实拍素材，质量高，还可以免费下载。 1、菜鸟图库 https://www.sucai999.com/?vNTYwNDUx 菜鸟图库有超多设计类素材，像平面、UI、电商、办公类等等在这个网站都能找到，网站还有很多实拍视频素材，质量很高&a…
阅读更多...
k8s集群部署01

k8s集群部署01

k8s集群部署01Kubernetes简介Kubernetes部署节点部署关于yum缓存提示满了，Rhel7换源解决报错解决过程配置文件内容—要自己看链接是否过期集群初始化Kubernetes-kubectl命令出现错误【The connection to the server localhost:8080 was refused - did you specify t…
阅读更多...
git chrry pickup

git chrry pickup

git chrry pickup目录概述需求：设计思路实现思路分析1.java2.转移分支3.git merge4.cherry pick.切换到 master 分支Cherry pick 操作参考资料和推荐阅读Survive by day and develop by night. talk for import biz , show your perfect code,full busy，…
阅读更多...
基于MVC的在线影票售卖系统/基于ASP.NET的电影院售票系统

基于MVC的在线影票售卖系统/基于ASP.NET的电影院售票系统

摘 要 随着电影院规模的不断扩大，人流数量的急剧增加，有关电影院的各种信息量也在不断成倍增长。面对庞大的信息量，就需要有在线影票售卖系统来提高电影院工作的效率。通过这样的系统，我们可以做到信息的规范管理和快速查询&…
阅读更多...
副业项目分享，旧衣回收项目怎么做

副业项目分享，旧衣回收项目怎么做

大家好，我是蝶衣王的小编，今天分享一个简单的项目 我们每个家庭都有多余的旧衣服。许多人会直接把它们扔进垃圾桶。然而，这里隐藏着巨大的商机。说到这里，每个人都应该想到：旧衣服的回收。 事实上，目前国…
阅读更多...
《位图布隆过滤器》

《位图布隆过滤器》

【一】位图的概念 位图，就是用每一个比特位来存放某种状态，适用于海量数据，整数，数据无重复的场景，通常是用来判断某个数据存不存在的。例如：10个整数本应该存放四十个字节，此时用位图只需要十…
阅读更多...
Ajax（JavaWebAjax、源生Ajax、跨域）

Ajax（JavaWebAjax、源生Ajax、跨域）

1.JavaWeb - Ajax 概念：AJAX（Asynchronous Java JavaScript And Xml ）：异步的JavaScript和Xml AJAX作用： 与服务器进行数据交换：通过AJAX可以给服务器发送请求，并获取服务器响应的数据。 使用…
阅读更多...
2022-12-28-面试题整理

2022-12-28-面试题整理

1. Spring中Bean创建完成后执行指定代码的几种实现方式 实现ApplicationListener接口 实现ApplicationListener接口并实现方法onApplicationEvent()方法，Bean在创建完成后会执行onApplicationEvent()方法 Component public class DoByApplicationListener impleme…
阅读更多...
Java操作redis数据库之读取csv文件

Java操作redis数据库之读取csv文件

csv文件 要想对某个文件进行具体操作，首先要了解这个文件的结构。csv 全称“Comma-Separated Values”，是一种逗号分隔值格式的文件，是一种用来存储数据的纯文本格式文件。CSV 文件由任意数目的记录组成，记录间以某种换行符分隔&…
阅读更多...
FPGA再入门——UART IP核调用

FPGA再入门——UART IP核调用

我的工作偏向硬件设计与调试，但是经过几年的发展，发觉不会调程序发展真的很受限制。最近越来越被这种限制折磨的很难受，所以开始学习调调程序。其实，本科与研究生阶段都有过做写代码的经历，算是入过门。但是&#xff0…
阅读更多...
[3]ESP32连接MQTT服务端

[3]ESP32连接MQTT服务端

MQTT库&#xff1a;PubSubClient 连接MQTT服务端 #include <Arduino.h> #include <WiFi.h> #include <PubSubClient.h>const char *ssid "613专属"; const char *password "613613613"; const char *mqttServer "test.ranye-…
阅读更多...
CDGA|持续投入开展数据治理工作可以从这四大方向着手

CDGA|持续投入开展数据治理工作可以从这四大方向着手

数字化转型趋势下&#xff0c;外部监管以及内部数据使用都对数据治理提出更高效、更准确、更完备、更合规的要求&#xff0c;企业如何抓住新形势下的要求&#xff0c;开展自身数据治理工作&#xff1f; 纵观数据治理的发展历程&#xff0c;剖析数据治理的建设路径&#xff0c;持…
阅读更多...
3. 中断向量是（ ）。 ————计算机组成原理

3. 中断向量是（ ）。 ————计算机组成原理

中断向量是&#xff08; &#xff09; A.子程序入口地址 B.中断向量表的首地址 C.终端服务程序入口地址 D.终端服务入口地址的地址 答案&#xff1a; C 知识点&#xff1a; 终端的概念&#xff1a; 1 机器出现了一些紧急事务&#xff0c;CPU不得不停下当前正在执行的程序&…
阅读更多...
SQL经典练习：电脑商店

SQL经典练习：电脑商店

表结构 本文使用的表结构如下&#xff1a; 以下是创建表的语句&#xff1a; -- 厂商表 CREATE TABLE Manufacturers (Code INTEGER NOT NULL PRIMARY KEY, -- 编号&#xff0c;主键Name VARCHAR(255) NOT NULL, -- 名称 );-- 产品表 CREATE TABLE Products (Code INTEGER NO…
阅读更多...
深蓝学院-多传感器融合定位课程-第10章-基于图优化的建图方法

深蓝学院-多传感器融合定位课程-第10章-基于图优化的建图方法

专栏文章: 深蓝学院-多传感器融合定位课程-第1章-概述_goldqiu的博客-CSDN博客 深蓝学院-多传感器融合定位课程-第2章-3D激光里程计I_goldqiu的博客-CSDN博客 深蓝学院-多传感器融合定位课程-第3章-3D激光里程计II_goldqiu的博客-CSDN博客 深蓝学院-多传感器融合定位课程-第…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023