clusterhandler

Documentation

Index

• Variables
• func CheckBeforeAdd(ctx context.Context, db *database.Database, cluster *models.Cluster) error
• func CompleteCluster(ctx context.Context, cluster *models.Cluster, restconfig *rest.Config, ...) error
• func ConfigClientCertExpire(cfg *rest.Config) *time.Time
• func DetectCRIRuntime(ctx context.Context, cs kubernetes.Interface) (string, error)
• func OnKubeConfig(ctx context.Context, cfgraw []byte, ...) error
• type ClusterHandler
  • func (h *ClusterHandler) DeleteCluster(c *gin.Context)
  • func (h *ClusterHandler) ListCluster(c *gin.Context)
  • func (h *ClusterHandler) ListClusterEnvironment(c *gin.Context)
  • func (h *ClusterHandler) ListClusterLogQueryHistory(c *gin.Context)
  • func (h *ClusterHandler) ListClusterLogQueryHistoryv2(c *gin.Context)
  • func (h *ClusterHandler) ListClusterLogQuerySnapshot(c *gin.Context)
  • func (h *ClusterHandler) ListClusterQuota(c *gin.Context)
  • func (h *ClusterHandler) ListClusterStatus(c *gin.Context)
  • func (h *ClusterHandler) PostCluster(c *gin.Context)
  • func (h *ClusterHandler) PutCluster(c *gin.Context)
  • func (h *ClusterHandler) RegistRouter(rg *gin.RouterGroup)
  • func (h *ClusterHandler) RetrieveCluster(c *gin.Context)
  • func (h *ClusterHandler) ValidateKubeConfig(c *gin.Context)
• type ClusterQuota
• type ValidateKubeConfigReq
• type ValidateKubeConfigResp

Variables

var (
	ModelName      = "Cluster"
	PrimaryKeyName = "cluster_id"
	SearchFields   = []string{"ClusterName"}
	FilterFields   = []string{"ClusterName"}
	PreloadFields  = []string{"Environments", "TenantResourceQuotas"}
)

Functions

func CheckBeforeAdd

func CheckBeforeAdd(ctx context.Context, db *database.Database, cluster *models.Cluster) error

func CompleteCluster

func CompleteCluster(ctx context.Context, cluster *models.Cluster, restconfig *rest.Config, clientSet kubernetes.Interface) error

func ConfigClientCertExpire

func ConfigClientCertExpire(cfg *rest.Config) *time.Time

func DetectCRIRuntime

func DetectCRIRuntime(ctx context.Context, cs kubernetes.Interface) (string, error)

func OnKubeConfig

func OnKubeConfig(ctx context.Context,
	cfgraw []byte,
	f func(ctx context.Context, cs *kubernetes.Clientset, cfg *rest.Config) error,
) error

Types

type ClusterHandler

type ClusterHandler struct {
	base.BaseHandler
}

func (*ClusterHandler) DeleteCluster

func (h *ClusterHandler) DeleteCluster(c *gin.Context)

DeleteCluster 删除 Cluster

@Tags			Cluster
@Summary		删除 Cluster
@Description	删除 Cluster
@Accept			json
@Produce		json
@Param			record_only	query		string					false	"only delete record in database"
@Param			cluster_id	path		uint					true	"cluster_id"
@Success		204			{object}	handlers.ResponseStruct	"resp"
@Router			/v1/cluster/{cluster_id} [delete]
@Security		JWT

func (*ClusterHandler) ListCluster

func (h *ClusterHandler) ListCluster(c *gin.Context)

ListCluster 列表 Cluster

@Tags			Cluster
@Summary		Cluster列表
@Description	Cluster列表
@Accept			json
@Produce		json
@Param			ClusterName	query		string																	false	"ClusterName"
@Param			preload		query		string																	false	"choices Environments,TenantResourceQuotas"
@Param			page		query		int																		false	"page"
@Param			size		query		int																		false	"page"
@Param			search		query		string																	false	"search in (ClusterName)"
@Success		200			{object}	handlers.ResponseStruct{Data=handlers.PageData{List=[]models.Cluster}}	"Cluster"
@Router			/v1/cluster [get]
@Security		JWT

func (*ClusterHandler) ListClusterEnvironment

func (h *ClusterHandler) ListClusterEnvironment(c *gin.Context)

ListClusterEnvironment 获取属于Cluster的 Environment 列表

@Tags			Cluster
@Summary		获取属于 Cluster 的 Environment 列表
@Description	获取属于 Cluster 的 Environment 列表
@Accept			json
@Produce		json
@Param			cluster_id	path		uint																		true	"cluster_id"
@Param			preload		query		string																		false	"choices Creator,Cluster,Project,Applications,Users"
@Param			page		query		int																			false	"page"
@Param			size		query		int																			false	"page"
@Param			search		query		string																		false	"search in (EnvironmentName)"
@Success		200			{object}	handlers.ResponseStruct{Data=handlers.PageData{List=[]models.Environment}}	"models.Environment"
@Router			/v1/cluster/{cluster_id}/environment [get]
@Security		JWT

func (*ClusterHandler) ListClusterLogQueryHistory

func (h *ClusterHandler) ListClusterLogQueryHistory(c *gin.Context)

ListClusterLogQueryHistory 获取属于Cluster的 LogQueryHistory 列表

@Tags			Cluster
@Summary		获取属于 Cluster 的 LogQueryHistory 列表
@Description	获取属于 Cluster 的 LogQueryHistory 列表
@Accept			json
@Produce		json
@Param			cluster_id	path		uint																			true	"cluster_id"
@Param			preload		query		string																			false	"choices Cluster,Creator"
@Param			page		query		int																				false	"page"
@Param			size		query		int																				false	"page"
@Param			search		query		string																			false	"search in (LogQL)"
@Success		200			{object}	handlers.ResponseStruct{Data=handlers.PageData{List=[]models.LogQueryHistory}}	"models.LogQueryHistory"
@Router			/v1/cluster/{cluster_id}/logqueryhistory [get]
@Security		JWT

func (*ClusterHandler) ListClusterLogQueryHistoryv2

func (h *ClusterHandler) ListClusterLogQueryHistoryv2(c *gin.Context)

ListLogQueryHistory 聚合查询日志查询历史[按照当前用户的查询历史聚合]

@Tags			Cluster
@Summary		聚合查询日志查询历史, unique logql desc 按照当前用户的查询历史聚合
@Description	聚合查询日志查询历史 unique logql desc 按照当前用户的查询历史聚合
@Accept			json
@Produce		json
@Success		200	{object}	handlers.ResponseStruct{Data=[]models.LogQueryHistoryWithCount}	"LogQueryHistory"
@Router			/v1/cluster/{cluster_id}/logqueryhistoryv2 [get]
@Security		JWT

func (*ClusterHandler) ListClusterLogQuerySnapshot

func (h *ClusterHandler) ListClusterLogQuerySnapshot(c *gin.Context)

ListClusterLogQuerySnapshot 获取属于Cluster的 LogQuerySnapshot 列表

@Tags			Cluster
@Summary		获取属于 Cluster 的 LogQuerySnapshot 列表
@Description	获取属于 Cluster 的 LogQuerySnapshot 列表
@Accept			json
@Produce		json
@Param			cluster_id	path		uint																			true	"cluster_id"
@Param			preload		query		string																			false	"choices Cluster,Creator"
@Param			page		query		int																				false	"page"
@Param			size		query		int																				false	"page"
@Param			search		query		string																			false	"search in (SnapshotName)"
@Success		200			{object}	handlers.ResponseStruct{Data=handlers.PageData{List=[]models.LogQuerySnapshot}}	"models.LogQuerySnapshot"
@Router			/v1/cluster/{cluster_id}/logquerysnapshot [get]
@Security		JWT

func (*ClusterHandler) ListClusterQuota

func (h *ClusterHandler) ListClusterQuota(c *gin.Context)

ClusterStatistics 集群资源状态

@Tags			Cluster
@Summary		集群资源状态
@Description	集群资源状态
@Accept			json
@Produce		json
@Param			cluster_id	path		int											true	"cluster_id"
@Success		200			{object}	handlers.ResponseStruct{Data=ClusterQuota}	"statistics"
@Router			/v1/cluster/{cluster_id}/quota [get]
@Security		JWT

func (*ClusterHandler) ListClusterStatus

func (h *ClusterHandler) ListClusterStatus(c *gin.Context)

ListClusterStatus 列出集群状态

@Tags			Cluster
@Summary		列出集群状态
@Description	列出集群状态
@Accept			json
@Produce		json
@Success		200	{object}	handlers.ResponseStruct{Data=map[string]bool}	"集群状态"
@Router			/v1/cluster/_/status [get]
@Security		JWT

func (*ClusterHandler) PostCluster

func (h *ClusterHandler) PostCluster(c *gin.Context)

PostCluster 创建Cluster

@Tags			Cluster
@Summary		创建Cluster
@Description	创建Cluster
@Accept			json
@Produce		json
@Param			param	body		models.Cluster									true	"表单"
@Success		200		{object}	handlers.ResponseStruct{Data=models.Cluster}	"Cluster"
@Router			/v1/cluster [post]
@Security		JWT

func (*ClusterHandler) PutCluster

func (h *ClusterHandler) PutCluster(c *gin.Context)

PutCluster 修改Cluster

@Tags			Cluster
@Summary		修改Cluster
@Description	修改Cluster
@Accept			json
@Produce		json
@Param			cluster_id	path		uint											true	"cluster_id"
@Param			param		body		models.Cluster									true	"表单"
@Success		200			{object}	handlers.ResponseStruct{Data=models.Cluster}	"Cluster"
@Router			/v1/cluster/{cluster_id} [put]
@Security		JWT

func (*ClusterHandler) RegistRouter

func (h *ClusterHandler) RegistRouter(rg *gin.RouterGroup)

func (*ClusterHandler) RetrieveCluster

func (h *ClusterHandler) RetrieveCluster(c *gin.Context)

RetrieveCluster Cluster详情

@Tags			Cluster
@Summary		Cluster详情
@Description	get Cluster详情
@Accept			json
@Produce		json
@Param			cluster_id	path		uint											true	"cluster_id"
@Success		200			{object}	handlers.ResponseStruct{Data=models.Cluster}	"Cluster"
@Router			/v1/cluster/{cluster_id} [get]
@Security		JWT

func (*ClusterHandler) ValidateKubeConfig

func (h *ClusterHandler) ValidateKubeConfig(c *gin.Context)

ValidateKubeConfig 添加cluster前的kubeconfig检测接口，验证kubeconfig，返回集群信息和可用的storageClass列表

@Tags			Cluster
@Summary		添加cluster前的kubeconfig检测接口，验证kubeconfig，返回集群信息和可用的storageClass列表
@Description	添加cluster前的kubeconfig检测接口，验证kubeconfig，返回集群信息和可用的storageClass列表
@Accept			json
@Produce		json
@Param			param	body		ValidateKubeConfigReq									true	"表单"
@Success		200		{object}	handlers.ResponseStruct{Data=ValidateKubeConfigResp}	"Cluster"
@Router			/v1/cluster/validate-kubeconfig [post]
@Security		JWT

type ClusterQuota

type ClusterQuota struct {
	statistics.ClusterStatistics
	OversoldConfig datatypes.JSON `json:"oversoldConfig"`
}

type ValidateKubeConfigReq

type ValidateKubeConfigReq struct {
	KubeConfig string `json:"kubeconfig" binding:"json"`
}

type ValidateKubeConfigResp

type ValidateKubeConfigResp struct {
	ServerInfo     *kversion.Info `json:"serverInfo,omitempty"`
	StorageClasses []string       `json:"storageClasses,omitempty"`

	// 判断是否存在installer，若存在即可加为控制集群
	ExistInstaller bool                       `json:"existInstaller"`
	GlobalValues   pluginmanager.GlobalValues `json:"globalValues"`
	ClusterName    string                     `json:"clusterName"`
	Connectable    bool                       `json:"connectable,omitempty"`
	Message        string                     `json:"message,omitempty"`
}