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

news2025/7/28 7:39:18

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

1. 接口实现

service/dataselector.go

// secret
type secretCell corev1.Secret

func (s secretCell) GetCreation() time.Time {
	return s.CreationTimestamp.Time
}

func (s secretCell) GetName() string {
	return s.Name
}

2. Secret功能

service/secret.go

package service

import (
	"context"
	"encoding/json"
	"errors"

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

var Secret secret

type secret struct{}

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

// 获取secret列表，支持过滤、排序、分页
func (s *secret) GetSecrets(filterName, namespace string, limit, page int) (secretsResp *SecretsResp, err error) {
	//获取secretList类型的secret列表
	secretList, err := K8s.ClientSet.CoreV1().Secrets(namespace).List(context.TODO(), metav1.ListOptions{})
	if err != nil {
		logger.Error(errors.New("获取Secret列表失败, " + err.Error()))
		return nil, errors.New("获取Secret列表失败, " + err.Error())
	}
	//将secretList中的secret列表(Items)，放进dataselector对象中，进行排序
	selectableData := &dataSelector{
		GenericDataList: s.toCells(secretList.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类型的secret列表转为v1.secret列表
	secrets := s.fromCells(data.GenericDataList)

	return &SecretsResp{
		Items: secrets,
		Total: total,
	}, nil
}

// 获取secret详情
func (s *secret) GetSecretDetail(secretName, namespace string) (secret *corev1.Secret, err error) {
	secret, err = K8s.ClientSet.CoreV1().Secrets(namespace).Get(context.TODO(), secretName, metav1.GetOptions{})
	if err != nil {
		logger.Error(errors.New("获取Secret详情失败, " + err.Error()))
		return nil, errors.New("获取Secret详情失败, " + err.Error())
	}

	return secret, nil
}

// 删除secret
func (s *secret) DeleteSecret(secretName, namespace string) (err error) {
	err = K8s.ClientSet.CoreV1().Secrets(namespace).Delete(context.TODO(), secretName, metav1.DeleteOptions{})
	if err != nil {
		logger.Error(errors.New("删除Secret失败, " + err.Error()))
		return errors.New("删除Secret失败, " + err.Error())
	}

	return nil
}

// 更新secret
func (s *secret) UpdateSecret(namespace, content string) (err error) {
	var secret = &corev1.Secret{}

	err = json.Unmarshal([]byte(content), secret)
	if err != nil {
		logger.Error(errors.New("反序列化失败, " + err.Error()))
		return errors.New("反序列化失败, " + err.Error())
	}

	_, err = K8s.ClientSet.CoreV1().Secrets(namespace).Update(context.TODO(), secret, metav1.UpdateOptions{})
	if err != nil {
		logger.Error(errors.New("更新Secret失败, " + err.Error()))
		return errors.New("更新Secret失败, " + err.Error())
	}
	return nil
}

func (s *secret) toCells(std []corev1.Secret) []DataCell {
	cells := make([]DataCell, len(std))
	for i := range std {
		cells[i] = secretCell(std[i])
	}
	return cells
}

func (s *secret) fromCells(cells []DataCell) []corev1.Secret {
	secrets := make([]corev1.Secret, len(cells))
	for i := range cells {
		secrets[i] = corev1.Secret(cells[i].(secretCell))
	}

	return secrets
}

3. 获取Secret列表

controller/secret.go

package controller

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

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

var Secret secret

type secret struct{}

// 获取secret列表，支持过滤、排序、分页
func (s *secret) GetSecrets(ctx *gin.Context) {
	params := new(struct {
		FilterName string `form:"filter_name"`
		Namespace  string `form:"namespace"`
		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.Secret.GetSecrets(params.FilterName, params.Namespace, 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":  "获取Secret列表成功",
		"data": data,
	})
}

// 获取secret详情
func (s *secret) GetSecretDetail(ctx *gin.Context) {
	params := new(struct {
		SecretName string `form:"secret_name"`
		Namespace  string `form:"namespace"`
	})
	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.Secret.GetSecretDetail(params.SecretName, params.Namespace)
	if err != nil {
		ctx.JSON(http.StatusInternalServerError, gin.H{
			"msg":  err.Error(),
			"data": nil,
		})
		return
	}

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

// 删除secret
func (s *secret) DeleteSecret(ctx *gin.Context) {
	params := new(struct {
		SecretName string `json:"secret_name"`
		Namespace  string `json:"namespace"`
	})
	//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.Secret.DeleteSecret(params.SecretName, params.Namespace)
	if err != nil {
		ctx.JSON(http.StatusInternalServerError, gin.H{
			"msg":  err.Error(),
			"data": nil,
		})
		return
	}
	ctx.JSON(http.StatusOK, gin.H{
		"msg":  "删除Secret成功",
		"data": nil,
	})
}

// 更新secret
func (s *secret) UpdateSecret(ctx *gin.Context) {
	params := new(struct {
		Namespace string `json:"namespace"`
		Content   string `json:"content"`
	})
	//PUT请求，绑定参数方法改为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.Secret.UpdateSecret(params.Namespace, params.Content)
	if err != nil {
		ctx.JSON(http.StatusInternalServerError, gin.H{
			"msg":  err.Error(),
			"data": nil,
		})
		return
	}
	ctx.JSON(http.StatusOK, gin.H{
		"msg":  "更新Secret成功",
		"data": nil,
	})
}

4. 定义路由

controller/router.go

		// secret
		GET("/api/k8s/secrets", Secret.GetSecrets).
		GET("/api/k8s/secret/detail", Secret.GetSecretDetail).
		DELETE("/api/k8s/secret/del", Secret.DeleteSecret).
		PUT("/api/k8s/secret/update", Secret.UpdateSecret)

5. 测试Secret方法

5.1 获取Secrets

请添加图片描述

5.2 获取Secret详情

请添加图片描述

其余等做好前端一起测试

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

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

相关文章

浅谈BOM

浅谈BOM

什么是BOM BOM对于每个前端都不陌生，但是很多人都停留在表面，而没有深层次的研究过它。JavaScript有一个非常重要的运行环境就是浏览器，而且浏览器本身又作为一个应用程序需要对其本身进行操作，所以通常浏览器会有对应的对象模型…
阅读更多...
tidb ptca，ptcp考证

tidb ptca，ptcp考证

PingCAP 认证 TiDB 数据库专员 V6 考试（2023-02-23）https://learn.pingcap.com/learner/exam-market/list?categoryPCTA PingCAP 认证 TiDB 数据库管理专家（PCTP - DBA）认证考试范围指引 - ☄️ 学习与认证 - TiDB 的问答社区:lo…
阅读更多...
Linux部署的Java应用生成图片和二维码会出现中文乱码的解决办法

Linux部署的Java应用生成图片和二维码会出现中文乱码的解决办法

Linux部署的Java应用生成图片和二维码会出现中文乱码，这是因为没有中文字体的原因，需要安装字体库。下载字体库https://download.csdn.net/download/a506602491/87490755，将文件解压至 /usr/share/fonts 目录下，如果没有fonts文件…
阅读更多...
TRichView改进对HTML的支持并增强报告功能

TRichView改进对HTML的支持并增强报告功能

TRichView改进对HTML的支持并增强报告功能 TRichView v21.0新功能： HTML导入和导出改进。 加载和保存的新方法。 改进图像选择和插入。 RichView Actions v11.0新功能： 包括加载和保存HTML的新方法。 使用新的TRVAControlPanel.OnChoosePicture事件选择…
阅读更多...
[数据结构]链表OJ

[数据结构]链表OJ

目录 数据结构之链表OJ：： 1.移除链表元素 2.反转链表 3.链表的中间结点 4.链表中倒数第k个结点 5.合并两个有序链表 6.链表分割 7.链表的回文结构 8.相交链表 9.环形链表 10.环形链表II 11.复制带随机指针的链表 数据结构之链表OJ：&#xff…
阅读更多...
springboot自定义starter时使用@AutoConfigureBefore、@AutoConfigureAfter的细节问题

springboot自定义starter时使用@AutoConfigureBefore、@AutoConfigureAfter的细节问题

正常利用springboot的自动装配 ConfB Configuration(proxyBeanMethodsfalse) public class ConfB {public ConfB(){System.out.println("ConfB构造方式执行...");} }不加spring.factories 项目包结构 此时resources中没有spring.factories 执行结果 2023-02-24…
阅读更多...
运动蓝牙耳机什么牌子好，运动蓝牙耳机品牌推荐

运动蓝牙耳机什么牌子好，运动蓝牙耳机品牌推荐

现在市面上运动耳机的品牌越来越多，还不知道选择哪一些运动耳机品牌，可以看看下面的一些耳机分享，运动耳机需要注意耳机的参数配置以及佩戴舒适度，根据自己最根本的使用需求来选择运动耳机。 1、南卡Runner Pro4骨传导蓝牙运动耳…
阅读更多...
剑指 Offer 46. 把数字翻译成字符串

剑指 Offer 46. 把数字翻译成字符串

剑指 Offer 46. 把数字翻译成字符串 难度：middle\color{orange}{middle}middle 其实就是有条件的 青蛙跳格子 问题。 题目描述 给定一个数字，我们按照如下规则把它翻译为字符串：0 翻译成 “a” ，1 翻译成 “b”，………
阅读更多...
GitHub狂飙30K+star面试现场,专为程序员面试打造,现已开源可下载

GitHub狂飙30K+star面试现场,专为程序员面试打造,现已开源可下载

《程序员面试现场》上线2个月已经在GitHub上已经狂飙到30Kstar（能在在GitHub上拿到30K的star，有没有干货，我就不多说了）总结的很全面，主要是针对面试之前的准备工作，分为知彼、知己、问答、贯通、综合五部分…
阅读更多...
06- OpenCV查找图像轮廓 (OpenCV系列) (机器视觉)

06- OpenCV查找图像轮廓 (OpenCV系列) (机器视觉)

知识重点 灰度图转换: gray cv2.cvtColor(img, cv2.COLOR_BGR2GRAY)二值化: 返回两个东西，一个阈值， 一个是二值化的图: thresh, binary cv2.threshold(gray, 150, 255, cv2.THRESH_BINARY)查找轮廓: 返回两个结果，分别是轮廓和层级: c…
阅读更多...
白帽黑客入行应该怎么学？零基础小白也能轻松上手！

白帽黑客入行应该怎么学？零基础小白也能轻松上手！

这几年随着我国《国家网络空间安全战略》《网络安全法》《网络安全等级保护2.0》等一系列政策/法规/标准的持续落地，网络安全行业地位、薪资随之水涨船高。 1为什么网络安全行业是IT行业最后的红利？ 根据腾讯安全发布的《互联网安全报告》，…
阅读更多...
Python每日一练(20230224)

Python每日一练(20230224)

目录 1. 列表奇偶拆分 ★ 2. 二叉树的后序遍历 ★★ 3. 接雨水 ★★★ 附录 二叉树 特点 性质 特殊二叉树 满二叉树 完全二叉树 完全二叉树性质 二叉树的遍历 1. 列表奇偶拆分 【问题描述】 输入一个列表，包含若干个整数（允许为空&#xff…
阅读更多...
Spring Batch 高级篇-并行步骤

Spring Batch 高级篇-并行步骤

目录 引言 概念 案例 转视频版 引言 接着上篇：Spring Batch 高级篇-多线程步骤，了解Spring Batch多线程步骤后，接下来一起学习一下Spring Batch 高级功能-并行步骤 概念 并行步骤，指的是某2个或者多个步骤同时执行。比如下…
阅读更多...
Ask林曦｜来回答，30个你关心的日常问题（二）

Ask林曦｜来回答，30个你关心的日常问题（二）

在林曦老师的线上书法直播课上，上课前后的聊天时间里，时常有同学向林曦老师提问，这些问题涵盖了日常生活的诸多方面，从身体的保养，到快乐的法门，皆是大家感兴趣的，也都共同关切的。 　　暄桐教室…
阅读更多...
python+Vue学生作业系统 django课程在线学习网站系统

python+Vue学生作业系统 django课程在线学习网站系统

系统分为学生，教师，管理员三个角色： 学生功能： 1.学生注册登录系统 2.学生查看个人信息，修改个人信息 3.学生查看主页综合评价，查看今日值班信息 4.学生在线申请请假信息，查看请假的审核结果和请…
阅读更多...
180、【动态规划】leetcode ——583. 两个字符串的删除操作：两种动态规划思路（C++版本）

180、【动态规划】leetcode ——583. 两个字符串的删除操作：两种动态规划思路（C++版本）

题目描述 原题链接：583. 两个字符串的删除操作 解题思路 （1）基于求最长公共子序列思路 本题与 1143. 最长公共子序列 的区别在于，1143中求的是两个序列中的最长公共子序列，而本题是要找到最少删除多少个元素后可以得…
阅读更多...
PHP程序员适合创业吗？

PHP程序员适合创业吗？

创业是一件自然而然的事，不需要人为选择。 只要你是一个努力能干主动的人，当你在一个行业深耕5年之后，就会发现人生发展的下一步就是创业。当然如果行业合适的话。 什么叫行业合适呢？ 就是创业的成本并不那么高，不需…
阅读更多...
怎么在LinkedIn领英安全添加到3万个好友？

怎么在LinkedIn领英安全添加到3万个好友？

根据领英最新公布的数据：领英全球用户数已经达到8.3亿，超5800万个公司主页，可以说是世界上最-大的business database。 这就不难理解为什么越来越多的外贸人，开始认真尝试和重视在领英开发客户，因为领英确实是外贸人&a…
阅读更多...
鸿蒙3.0 APP混合开发闪退问题笔记

鸿蒙3.0 APP混合开发闪退问题笔记

APP采用cordova混合开发， 鸿蒙2.0以及安卓操作系统正常使用，但是在鸿蒙3.0中出现APP闪退，对APP进行真机调试发现，鸿蒙3.0系统对crosswork插件存在兼容问题，这些问题会导致APP页面加载失败，进而导致App闪退测…
阅读更多...
扬帆优配|“涨停敢死队”慌了？监管“盯紧”异常交易

扬帆优配|“涨停敢死队”慌了？监管“盯紧”异常交易

日前，沪深买卖所发布《主板股票反常买卖实时监控细则》，对反常买卖行为的类型和标准作出规则。其间，针对“打板”“封板”等反常行为的监控遭到商场重视，有商场传闻称，新规或导致高频买卖毁灭，“量价型股票…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023