#yyds干货盘点#什么是MVC模式

package v1alpha2

import (
"container_cloud/pkg/api"
"container_cloud/pkg/apiserver/query"
"container_cloud/pkg/apiserver/runtime"
"container_cloud/pkg/controller"
"container_cloud/pkg/domain"
"github.com/emicklei/go-restful"
batchv1 "k8s.io/api/batch/v1"
"k8s.io/apimachinery/pkg/runtime/schema"
"net/http"
)

const (
GroupName = "job.ictnj.io"
Version = "v1alpha2"
Ok = "OK"
)

var GroupVersion = schema.GroupVersion{Group: GroupName, Version: Version}

func AddToContainer() *restful.WebService {
ws := runtime.NewWebService(GroupVersion)
job := controller.NewSingleClusterJob()
ws.Route(ws.GET("clusters/{cluster}/namespaces/{namespace}/jobName/{name}").
To(job.IsExist).
Doc("Check duplicate names").
Param(ws.PathParameter("cluster", "cluster used to do filtering")).
Param(ws.PathParameter("namespace", "namespace used to do filtering")).
Param(ws.PathParameter("name", "name used to do filtering")).
Returns(http.StatusOK, "ok", domain.Exist{}))
ws.Route(ws.POST("/namespaces/{namespace}/jobs").
To(job.CreateSingleClusterJobs).
Doc("Create a job for a specified federatednamespaces.").
Param(ws.PathParameter("namespace", "the watching namespace of the job")).
Returns(http.StatusOK, "ok", batchv1.Job{}))

ws.Route(ws.DELETE("/clusters/{cluster}/namespaces/{namespace}/jobs/{name}").
To(job.DeleteSingleClusterJob).
Doc("delete a specified job").
Param(ws.PathParameter("cluster", "cluster used to do filtering")).
Param(ws.PathParameter("namespace", "namespace used to do filtering")).
Param(ws.PathParameter("name", "name used to do filtering")).
Returns(http.StatusOK, Ok, batchv1.Job{}))

ws.Route(ws.GET("/jobs").
To(job.GetSingleClusterJobList).
Doc("get job list").
Param(ws.QueryParameter(query.ParameterName, "name used to do filtering").Required(false)).
Param(ws.QueryParameter(query.ParameterPage, "page").Required(false).DataFormat("page=%d").DefaultValue("page=1")).
Param(ws.QueryParameter(query.ParameterLimit, "limit").Required(false)).
Param(ws.QueryParameter(query.ParameterAscending, "sort parameters, e.g. reverse=true").Required(false).DefaultValue("ascending=false")).
Param(ws.QueryParameter(query.ParameterOrderBy, "sort parameters, e.g. orderBy=createTime")).
Returns(http.StatusOK, Ok, api.ListResult{}))

ws.Route(ws.GET("/clusters/{cluster}/namespaces/{namespace}/jobs/{name}").
To(job.GetJob).
Doc("get a job").
Param(ws.PathParameter("cluster", "cluster used to do filtering")).
Param(ws.PathParameter("namespace", "namespace used to do filtering")).
Param(ws.PathParameter("name", "name used to do filtering")).
Returns(http.StatusOK, Ok, domain.Job{}))

return ws
}

package vpc

import metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"

/*
@Time : 2022/3/10 14:44
@Author :dengfeng_hu
@File : subnet
@Software: GoLand
*/

type Subnet struct {

//uuid
Id string `json:"subnetId,omitempty"`

//subnet名称
SubnetName string `json:"subnetName,omitempty"`

//vpc名称
VpcName string `json:"vpcName,omitempty"`

//vpcId
VpcId string `json:"vpcId,omitempty"`

//集群名称
ClusterName string `json:"clusterName,omitempty"`

//关联命名空间
Namespace string `json:"namespaces,omitempty"`

//子网网段
SubnetNetwork string `json:"subnetNetwork,omitempty"`
}

type SubnetItem struct {

//集群名称
ClusterName string `json:"clusterName"`

//vpc名称
VpcName string `json:"vpcName"`

//命名空间
Namespace string `json:"namespace"`

//vpc网段
VpcNetwork string `json:"vpcNetwork"`

//子网网段
SubnetNetwork string `json:"subnetNetwork"`

//子网名称，前端
SubnetName string `json:"subnetName"`

//用户名
UserName string `json:"userName"`

//vpcId
VpcId string `json:"vpcId"`

//返回给前端用的
CreateTime string `json:"createTime"`
}
type SubnetTemplate struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec SubnetSpec `json:"spec"`
}
type SubnetSpec struct {
CidrBlock string `json:"cidrBlock,omitempty"`
Vpc string `json:"vpc,omitempty"`
}