package controller import ( "dkube/service" "github.com/gin-gonic/gin" "github.com/wonderivan/logger" "net/http" ) var Secret secret type secret struct{} 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, }) } 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, }) } func (s *secret) DeleteSecret(ctx *gin.Context) { params := new(struct { SecretName string `json:"secret_name"` Namespace string `json:"namespace"` }) 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, }) } func (s *secret) UpdateSecret(ctx *gin.Context) { params := new(struct { Namespace string `json:"namespace"` Content string `json:"content"` }) 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, }) }