status.go•1.51 kB
package cluster_status
import (
"github.com/gin-gonic/gin"
"github.com/weibaohui/k8m/pkg/comm/utils"
"github.com/weibaohui/k8m/pkg/comm/utils/amis"
"github.com/weibaohui/kom/kom"
)
type ClusterController struct{}
func RegisterClusterRoutes(api *gin.RouterGroup) {
ctrl := &ClusterController{}
api.GET("/status/resource_count/cache_seconds/:cache", ctrl.ClusterResourceCount)
}
// @Summary 获取集群资源数量统计
// @Security BearerAuth
// @Param cluster path string true "集群名称"
// @Param cache path string true "缓存时间（秒）"
// @Success 200 {object} string
// @Router /k8s/cluster/{cluster}/status/resource_count/cache_seconds/{cache} [get]
func (cc *ClusterController) ClusterResourceCount(c *gin.Context) {
selectedCluster, err := amis.GetSelectedCluster(c)
if err != nil {
amis.WriteJsonError(c, err)
return
}
cacheStr := c.Param("cache")
if cacheStr == "" {
cacheStr = "30"
}
cache := utils.ToInt(cacheStr)
sm, err := kom.Cluster(selectedCluster).Status().GetResourceCountSummary(cache)
if err != nil {
amis.WriteJsonError(c, err)
return
}
// 将sm的kv进行转换
var result = make([]struct {
Count int
Group string
Version string
Resource string
}, 0)
for gvr, count := range sm {
result = append(result,
struct {
Count int
Group string
Version string
Resource string
}{Count: count,
Group: gvr.Group,
Version: gvr.Version,
Resource: gvr.Resource})
}
amis.WriteJsonData(c, result)
}