Mirrors/DKube
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Update pod.go

Browse Source
This commit is contained in:
dqzboy 2022-09-25 21:07:16 +08:00 committed by GitHub
parent bd491cbde4
commit d46261fa99
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
controller/pod.go
View File

@ -11,20 +11,14 @@ var Pod pod
type pod struct{}
//Controller中的方法入参是gin.Context，用于从上下文中获取请求参数以及定义响应内容
//流程：绑定参数 --> 调用service代码 --> 根据调用结果响应具体内容
// GetPods 获取Pod列表，支持分页、过滤、排序
func (p *pod) GetPods(ctx *gin.Context) {
//处理入参
//匿名结构体用于定义入参，get请求为form格式，其他请求为json格式
params := new(struct {
FilterName string `form:"filter_name"`
Namespace string `form:"namespace"`
Limit int `form:"limit"`
Page int `form:"page"`
})
//form格式使用Bind方法，json格式使用ShouldBindJSON方法
if err := ctx.Bind(params); err != nil {
logger.Error("Bind绑定参数失败" + err.Error())
ctx.JSON(http.StatusInternalServerError, gin.H{
@ -50,13 +44,10 @@ func (p *pod) GetPods(ctx *gin.Context) {
//获取Pod详情
func (p *pod) GetPodDetail(ctx *gin.Context) {
//处理入参
//匿名结构体用于定义入参，get请求为form格式，其他请求为json格式
params := new(struct {
PodName string `form:"pod_name"`
Namespace string `form:"namespace"`
})
//form格式使用Bind方法，json格式使用ShouldBindJSON方法
if err := ctx.Bind(params); err != nil {
logger.Error("Bind绑定参数失败" + err.Error())
ctx.JSON(http.StatusInternalServerError, gin.H{
@ -82,13 +73,11 @@ func (p *pod) GetPodDetail(ctx *gin.Context) {
//删除Pod
func (p *pod) DeletePod(ctx *gin.Context) {
//处理入参
//匿名结构体用于定义入参，get请求为form格式，其他请求为json格式
params := new(struct {
PodName string `json:"pod_name"`
Namespace string `json:"namespace"`
})
//form格式使用Bind方法，json格式使用ShouldBindJSON方法
if err := ctx.ShouldBindJSON(params); err != nil {
logger.Error("Bind绑定参数失败" + err.Error())
ctx.JSON(http.StatusInternalServerError, gin.H{
@ -114,13 +103,11 @@ func (p *pod) DeletePod(ctx *gin.Context) {
//更新Pod
func (p *pod) UpdatePod(ctx *gin.Context) {
//处理入参
//匿名结构体用于定义入参，get请求为form格式，其他请求为json格式
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{
@ -146,12 +133,10 @@ func (p *pod) UpdatePod(ctx *gin.Context) {
//获取Pod容器
func (p *pod) GetPodContainer(ctx *gin.Context) {
//处理入参
params := new(struct {
PodName string `form:"pod_name"`
Namespace string `form:"namespace"`
})
//GET请求，绑定参数方法改为ctx.Bind方法
if err := ctx.Bind(params); err != nil {
logger.Error("Bind请求参数失败" + err.Error())
ctx.JSON(http.StatusInternalServerError, gin.H{
@ -177,13 +162,11 @@ func (p *pod) GetPodContainer(ctx *gin.Context) {
//获取Pod容器日志
func (p *pod) GetPodLog(ctx *gin.Context) {
//处理入参
params := new(struct {
ContainerName string `form:"container_name"`
PodName string `form:"pod_name"`
Namespace string `form:"namespace"`
})
//GET请求，绑定参数方法改为ctx.Bind方法
if err := ctx.Bind(params); err != nil {
logger.Error("Bind请求参数失败" + err.Error())
ctx.JSON(http.StatusInternalServerError, gin.H{