From 1911a1c0d822d80df9bb744366edeee7f935679b Mon Sep 17 00:00:00 2001
From: zhangwei <894646498@qq.com>
Date: Mon, 28 Aug 2023 15:05:33 +0800
Subject: [PATCH] =?UTF-8?q?=E6=9F=A5=E8=AF=A2=E8=B5=84=E6=BA=90=E8=8A=82?=
 =?UTF-8?q?=E7=82=B9=E4=BF=A1=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Former-commit-id: 7721b3b6ff0d79b666ccb0378a7828885c08633d
---
 api/desc/core/pcm-core.api                    |  19 +-
 api/desc/hpc/pcm-hpc.api                      |  28 ++-
 api/desc/pcm.api                              |   7 +
 .../handler/core/nodeassetshandler.go         |  17 ++
 .../handler/hpc/queueassetshandler.go         |  17 ++
 api/internal/handler/routes.go                |  10 +
 api/internal/logic/core/nodeassetslogic.go    |  41 ++++
 api/internal/logic/hpc/queueassetslogic.go    |  40 ++++
 api/internal/types/types.go                   |  42 ++++
 model/scnodeavailinfomodel_gen.go             |  36 ++--
 .../reportavailablelogic.go                   |   2 +-
 rpc/pb/pcmCore.proto                          |   2 +-
 rpc/pcmCore/pcmCore.pb.go                     | 186 +++++++++---------
 rpc/pcmCore/pcmCore_grpc.pb.go                |   2 +-
 14 files changed, 333 insertions(+), 116 deletions(-)
 create mode 100644 api/internal/handler/core/nodeassetshandler.go
 create mode 100644 api/internal/handler/hpc/queueassetshandler.go
 create mode 100644 api/internal/logic/core/nodeassetslogic.go
 create mode 100644 api/internal/logic/hpc/queueassetslogic.go

diff --git a/api/desc/core/pcm-core.api b/api/desc/core/pcm-core.api
index 6070d68b..01681774 100644
--- a/api/desc/core/pcm-core.api
+++ b/api/desc/core/pcm-core.api
@@ -424,4 +424,21 @@ type ResultData struct {
     Status string `json:"status"`
     Data MetricData `json:"data"`
 }
-    //jccSchedule容器集群资源监控 >end
\ No newline at end of file
+
+type NodeAssetsResp{
+    NodeAssets  []NodeAsset `json:"nodeAssets"`
+
+}
+
+type  NodeAsset{
+    NodeName           string        `db:"node_name"`            // 节点名称
+    CpuTotal           int64         `db:"cpu_total"`            // cpu核数
+    CpuUsable          float64       `db:"cpu_usable"`           // cpu可用率
+    DiskTotal          int64         `db:"disk_total"`           // 磁盘空间
+    DiskAvail          int64         `db:"disk_avail"`           // 磁盘可用空间
+    MemTotal           int64         `db:"mem_total"`            // 内存总数
+    MemAvail           int64         `db:"mem_avail"`            // 内存可用数
+    GpuTotal           int64         `db:"gpu_total"`            // gpu总数
+    GpuAvail           int64         `db:"gpu_avail"`            // gpu可用数
+    ParticipantId int64         `db:"participant_id"` // 集群动态信息id
+}
\ No newline at end of file
diff --git a/api/desc/hpc/pcm-hpc.api b/api/desc/hpc/pcm-hpc.api
index c1ad0eea..2adf6347 100644
--- a/api/desc/hpc/pcm-hpc.api
+++ b/api/desc/hpc/pcm-hpc.api
@@ -44,4 +44,30 @@ type (
         RecordCount int32 `json:"recordCount"`
         HistoryJobs []HistoryJob `json:"jobInfoDbs"`
     }
-)
\ No newline at end of file
+)
+
+
+type QueueAssetsResp {
+    QueueAssets []QueueAsset `json:"queueAsset"`
+
+}
+type QueueAsset{
+    ParticipantId int64 `json:"participantId"`
+    AclHosts string `json:"aclHosts"`
+    QueNodes string `json:"queNodes"`                       //队列节点总数
+    QueMinNodect string `json:"queMinNodect,omitempty"`     //队列最小节点数
+    QueMaxNgpus string `json:"queMaxNgpus,omitempty"`       //队列最大GPU卡数
+    QueMaxPPN string `json:"queMaxPPN,omitempty"`           //使用该队列作业最大CPU核心数
+    QueChargeRate string `json:"queChargeRate,omitempty"`   //费率
+    QueMaxNcpus string `json:"queMaxNcpus,omitempty"`       //用户最大可用核心数
+    QueMaxNdcus string `json:"queMaxNdcus,omitempty"`       //队列总DCU卡数
+    QueueName string `json:"queueName,omitempty"`           //队列名称
+    QueMinNcpus string `json:"queMinNcpus,omitempty"`       //队列最小CPU核数
+    QueFreeNodes string `json:"queFreeNodes,omitempty"`     //队列空闲节点数
+    QueMaxNodect string `json:"queMaxNodect,omitempty"`     //队列作业最大节点数
+    QueMaxGpuPN string `json:"queMaxGpuPN,omitempty"`       //队列单作业最大GPU卡数
+    QueMaxWalltime string `json:"queMaxWalltime,omitempty"` //队列最大运行时间
+    QueMaxDcuPN string `json:"queMaxDcuPN,omitempty"`       //队列单作业最大DCU卡数
+    QueFreeNcpus string `json:"queFreeNcpus"`               //队列空闲cpu数
+    QueNcpus string `json:"queNcpus"`                       //队列cpu数
+}
\ No newline at end of file
diff --git a/api/desc/pcm.api b/api/desc/pcm.api
index 32e405a6..86631bd7 100644
--- a/api/desc/pcm.api
+++ b/api/desc/pcm.api
@@ -62,6 +62,10 @@ service pcm {
 
 	@handler putResourcePanelConfigHandler
 	put /core/resourcePanelConfigHandler (ResourcePanelConfigReq) returns ()
+
+	@handler nodeAssetsHandler
+	get /core/assets () returns (NodeAssetsResp)
+
 }
 
 //hpc二级接口
@@ -75,6 +79,9 @@ service pcm {
 
 	@handler listHistoryJobHandler
 	get /hpc/listHistoryJob (listHistoryJobReq) returns (listHistoryJobResp)
+
+	@handler queueAssetsHandler
+	get /queue/assets () returns (QueueAssetsResp)
 }
 
 //智算二级接口
diff --git a/api/internal/handler/core/nodeassetshandler.go b/api/internal/handler/core/nodeassetshandler.go
new file mode 100644
index 00000000..7a9e7e28
--- /dev/null
+++ b/api/internal/handler/core/nodeassetshandler.go
@@ -0,0 +1,17 @@
+package core
+
+import (
+	"gitlink.org.cn/jcce-pcm/utils/result"
+	"net/http"
+
+	"gitlink.org.cn/jcce-pcm/pcm-coordinator/api/internal/logic/core"
+	"gitlink.org.cn/jcce-pcm/pcm-coordinator/api/internal/svc"
+)
+
+func NodeAssetsHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
+	return func(w http.ResponseWriter, r *http.Request) {
+		l := core.NewNodeAssetsLogic(r.Context(), svcCtx)
+		resp, err := l.NodeAssets()
+		result.HttpResult(r, w, resp, err)
+	}
+}
diff --git a/api/internal/handler/hpc/queueassetshandler.go b/api/internal/handler/hpc/queueassetshandler.go
new file mode 100644
index 00000000..0345f90c
--- /dev/null
+++ b/api/internal/handler/hpc/queueassetshandler.go
@@ -0,0 +1,17 @@
+package hpc
+
+import (
+	"gitlink.org.cn/jcce-pcm/utils/result"
+	"net/http"
+
+	"gitlink.org.cn/jcce-pcm/pcm-coordinator/api/internal/logic/hpc"
+	"gitlink.org.cn/jcce-pcm/pcm-coordinator/api/internal/svc"
+)
+
+func QueueAssetsHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
+	return func(w http.ResponseWriter, r *http.Request) {
+		l := hpc.NewQueueAssetsLogic(r.Context(), svcCtx)
+		resp, err := l.QueueAssets()
+		result.HttpResult(r, w, resp, err)
+	}
+}
diff --git a/api/internal/handler/routes.go b/api/internal/handler/routes.go
index aef5e7da..bdc1c79e 100644
--- a/api/internal/handler/routes.go
+++ b/api/internal/handler/routes.go
@@ -87,6 +87,11 @@ func RegisterHandlers(server *rest.Server, serverCtx *svc.ServiceContext) {
 				Path:    "/core/resourcePanelConfigHandler",
 				Handler: core.PutResourcePanelConfigHandler(serverCtx),
 			},
+			{
+				Method:  http.MethodGet,
+				Path:    "/core/assets",
+				Handler: core.NodeAssetsHandler(serverCtx),
+			},
 		},
 		rest.WithPrefix("/pcm/v1"),
 	)
@@ -103,6 +108,11 @@ func RegisterHandlers(server *rest.Server, serverCtx *svc.ServiceContext) {
 				Path:    "/hpc/listHistoryJob",
 				Handler: hpc.ListHistoryJobHandler(serverCtx),
 			},
+			{
+				Method:  http.MethodGet,
+				Path:    "/queue/assets",
+				Handler: hpc.QueueAssetsHandler(serverCtx),
+			},
 		},
 		rest.WithPrefix("/pcm/v1"),
 	)
diff --git a/api/internal/logic/core/nodeassetslogic.go b/api/internal/logic/core/nodeassetslogic.go
new file mode 100644
index 00000000..0522874c
--- /dev/null
+++ b/api/internal/logic/core/nodeassetslogic.go
@@ -0,0 +1,41 @@
+package core
+
+import (
+	"context"
+	"gitlink.org.cn/jcce-pcm/pcm-coordinator/model"
+
+	"gitlink.org.cn/jcce-pcm/pcm-coordinator/api/internal/svc"
+	"gitlink.org.cn/jcce-pcm/pcm-coordinator/api/internal/types"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type NodeAssetsLogic struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+func NewNodeAssetsLogic(ctx context.Context, svcCtx *svc.ServiceContext) *NodeAssetsLogic {
+	return &NodeAssetsLogic{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx,
+	}
+}
+
+func (l *NodeAssetsLogic) NodeAssets() (resp *types.NodeAssetsResp, err error) {
+	// todo: add your logic here and delete this line
+	// 查询数据库系节点动态资源信息
+	var nodeAvailInfos []model.ScNodeAvailInfo
+	tx := l.svcCtx.DbEngin.Find(&nodeAvailInfos).Group("participant_id")
+	if tx.Error != nil {
+		logx.Error(err)
+		return nil, tx.Error
+	}
+
+	//queueResp := types.QueueAssetsResp{}
+	//tool.Convert(queuePhyInfos, &queueResp.QueueAssets)
+	//return &queueResp, nil
+	return
+}
diff --git a/api/internal/logic/hpc/queueassetslogic.go b/api/internal/logic/hpc/queueassetslogic.go
new file mode 100644
index 00000000..9a9dda7d
--- /dev/null
+++ b/api/internal/logic/hpc/queueassetslogic.go
@@ -0,0 +1,40 @@
+package hpc
+
+import (
+	"context"
+	"gitlink.org.cn/jcce-pcm/pcm-coordinator/model"
+	"gitlink.org.cn/jcce-pcm/utils/tool"
+
+	"gitlink.org.cn/jcce-pcm/pcm-coordinator/api/internal/svc"
+	"gitlink.org.cn/jcce-pcm/pcm-coordinator/api/internal/types"
+
+	"github.com/zeromicro/go-zero/core/logx"
+)
+
+type QueueAssetsLogic struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+func NewQueueAssetsLogic(ctx context.Context, svcCtx *svc.ServiceContext) *QueueAssetsLogic {
+	return &QueueAssetsLogic{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx,
+	}
+}
+
+func (l *QueueAssetsLogic) QueueAssets() (resp *types.QueueAssetsResp, err error) {
+	// 查询数据库队列资源信息
+	var queuePhyInfos []model.ScQueuePhyInfo
+	tx := l.svcCtx.DbEngin.Find(&queuePhyInfos)
+	if tx.Error != nil {
+		logx.Error(err)
+		return nil, tx.Error
+	}
+
+	queueResp := types.QueueAssetsResp{}
+	tool.Convert(queuePhyInfos, &queueResp.QueueAssets)
+	return &queueResp, nil
+}
diff --git a/api/internal/types/types.go b/api/internal/types/types.go
index 57c35616..4b669b38 100644
--- a/api/internal/types/types.go
+++ b/api/internal/types/types.go
@@ -395,6 +395,23 @@ type ResultData struct {
 	Data   MetricData `json:"data"`
 }
 
+type NodeAssetsResp struct {
+	NodeAssets []NodeAsset `json:"nodeAssets"`
+}
+
+type NodeAsset struct {
+	NodeName      string  `db:"node_name"`      // 节点名称
+	CpuTotal      int64   `db:"cpu_total"`      // cpu核数
+	CpuUsable     float64 `db:"cpu_usable"`     // cpu可用率
+	DiskTotal     int64   `db:"disk_total"`     // 磁盘空间
+	DiskAvail     int64   `db:"disk_avail"`     // 磁盘可用空间
+	MemTotal      int64   `db:"mem_total"`      // 内存总数
+	MemAvail      int64   `db:"mem_avail"`      // 内存可用数
+	GpuTotal      int64   `db:"gpu_total"`      // gpu总数
+	GpuAvail      int64   `db:"gpu_avail"`      // gpu可用数
+	ParticipantId int64   `db:"participant_id"` // 集群动态信息id
+}
+
 type Job struct {
 	SlurmVersion string `json:"slurmVersion"`
 	Name         string `json:"name"`
@@ -431,6 +448,31 @@ type ListHistoryJobResp struct {
 	HistoryJobs []HistoryJob `json:"jobInfoDbs"`
 }
 
+type QueueAssetsResp struct {
+	QueueAssets []QueueAsset `json:"queueAsset"`
+}
+
+type QueueAsset struct {
+	ParticipantId  int64  `json:"participantId"`
+	AclHosts       string `json:"aclHosts"`
+	QueNodes       string `json:"queNodes"`                 //队列节点总数
+	QueMinNodect   string `json:"queMinNodect,omitempty"`   //队列最小节点数
+	QueMaxNgpus    string `json:"queMaxNgpus,omitempty"`    //队列最大GPU卡数
+	QueMaxPPN      string `json:"queMaxPPN,omitempty"`      //使用该队列作业最大CPU核心数
+	QueChargeRate  string `json:"queChargeRate,omitempty"`  //费率
+	QueMaxNcpus    string `json:"queMaxNcpus,omitempty"`    //用户最大可用核心数
+	QueMaxNdcus    string `json:"queMaxNdcus,omitempty"`    //队列总DCU卡数
+	QueueName      string `json:"queueName,omitempty"`      //队列名称
+	QueMinNcpus    string `json:"queMinNcpus,omitempty"`    //队列最小CPU核数
+	QueFreeNodes   string `json:"queFreeNodes,omitempty"`   //队列空闲节点数
+	QueMaxNodect   string `json:"queMaxNodect,omitempty"`   //队列作业最大节点数
+	QueMaxGpuPN    string `json:"queMaxGpuPN,omitempty"`    //队列单作业最大GPU卡数
+	QueMaxWalltime string `json:"queMaxWalltime,omitempty"` //队列最大运行时间
+	QueMaxDcuPN    string `json:"queMaxDcuPN,omitempty"`    //队列单作业最大DCU卡数
+	QueFreeNcpus   string `json:"queFreeNcpus"`             //队列空闲cpu数
+	QueNcpus       string `json:"queNcpus"`                 //队列cpu数
+}
+
 type DataSets struct {
 	DatasetId        string        `json:"datasetId" copier:"DatasetId"`
 	DataFormat       string        `json:"dataFormat" copier:"DataFormat"`
diff --git a/model/scnodeavailinfomodel_gen.go b/model/scnodeavailinfomodel_gen.go
index 27bdae9f..e5276813 100755
--- a/model/scnodeavailinfomodel_gen.go
+++ b/model/scnodeavailinfomodel_gen.go
@@ -39,22 +39,22 @@ type (
 	}
 
 	ScNodeAvailInfo struct {
-		Id                 int64         `db:"id"`                   // id
-		NodeName           string        `db:"node_name"`            // 节点名称
-		CpuTotal           int64         `db:"cpu_total"`            // cpu核数
-		CpuUsable          float64       `db:"cpu_usable"`           // cpu可用率
-		DiskTotal          int64         `db:"disk_total"`           // 磁盘空间
-		DiskAvail          int64         `db:"disk_avail"`           // 磁盘可用空间
-		MemTotal           int64         `db:"mem_total"`            // 内存总数
-		MemAvail           int64         `db:"mem_avail"`            // 内存可用数
-		GpuTotal           int64         `db:"gpu_total"`            // gpu总数
-		GpuAvail           int64         `db:"gpu_avail"`            // gpu可用数
-		ParticipantAvailId int64         `db:"participant_avail_id"` // 集群动态信息id
-		DeletedFlag        int64         `db:"deleted_flag"`         // 是否删除
-		CreatedBy          sql.NullInt64 `db:"created_by"`           // 创建人
-		CreatedTime        time.Time     `db:"created_time"`         // 创建时间
-		UpdatedBy          sql.NullInt64 `db:"updated_by"`           // 更新人
-		UpdatedTime        sql.NullTime  `db:"updated_time"`         // 更新时间
+		Id            int64         `db:"id"`             // id
+		NodeName      string        `db:"node_name"`      // 节点名称
+		CpuTotal      int64         `db:"cpu_total"`      // cpu核数
+		CpuUsable     float64       `db:"cpu_usable"`     // cpu可用率
+		DiskTotal     int64         `db:"disk_total"`     // 磁盘空间
+		DiskAvail     int64         `db:"disk_avail"`     // 磁盘可用空间
+		MemTotal      int64         `db:"mem_total"`      // 内存总数
+		MemAvail      int64         `db:"mem_avail"`      // 内存可用数
+		GpuTotal      int64         `db:"gpu_total"`      // gpu总数
+		GpuAvail      int64         `db:"gpu_avail"`      // gpu可用数
+		ParticipantId int64         `db:"participant_id"` // 集群动态信息id
+		DeletedFlag   int64         `db:"deleted_flag"`   // 是否删除
+		CreatedBy     sql.NullInt64 `db:"created_by"`     // 创建人
+		CreatedTime   time.Time     `db:"created_time"`   // 创建时间
+		UpdatedBy     sql.NullInt64 `db:"updated_by"`     // 更新人
+		UpdatedTime   sql.NullTime  `db:"updated_time"`   // 更新时间
 	}
 )
 
@@ -102,7 +102,7 @@ func (m *defaultScNodeAvailInfoModel) Insert(ctx context.Context, data *ScNodeAv
 	pcmScNodeAvailInfoIdKey := fmt.Sprintf("%s%v", cachePcmScNodeAvailInfoIdPrefix, data.Id)
 	ret, err := m.ExecCtx(ctx, func(ctx context.Context, conn sqlx.SqlConn) (result sql.Result, err error) {
 		query := fmt.Sprintf("insert into %s (%s) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)", m.table, scNodeAvailInfoRowsExpectAutoSet)
-		return conn.ExecCtx(ctx, query, data.Id, data.NodeName, data.CpuTotal, data.CpuUsable, data.DiskTotal, data.DiskAvail, data.MemTotal, data.MemAvail, data.GpuTotal, data.GpuAvail, data.ParticipantAvailId, data.DeletedFlag, data.CreatedBy, data.CreatedTime, data.UpdatedBy, data.UpdatedTime)
+		return conn.ExecCtx(ctx, query, data.Id, data.NodeName, data.CpuTotal, data.CpuUsable, data.DiskTotal, data.DiskAvail, data.MemTotal, data.MemAvail, data.GpuTotal, data.GpuAvail, data.ParticipantId, data.DeletedFlag, data.CreatedBy, data.CreatedTime, data.UpdatedBy, data.UpdatedTime)
 	}, pcmScNodeAvailInfoIdKey)
 	return ret, err
 }
@@ -111,7 +111,7 @@ func (m *defaultScNodeAvailInfoModel) Update(ctx context.Context, data *ScNodeAv
 	pcmScNodeAvailInfoIdKey := fmt.Sprintf("%s%v", cachePcmScNodeAvailInfoIdPrefix, data.Id)
 	_, err := m.ExecCtx(ctx, func(ctx context.Context, conn sqlx.SqlConn) (result sql.Result, err error) {
 		query := fmt.Sprintf("update %s set %s where `id` = ?", m.table, scNodeAvailInfoRowsWithPlaceHolder)
-		return conn.ExecCtx(ctx, query, data.NodeName, data.CpuTotal, data.CpuUsable, data.DiskTotal, data.DiskAvail, data.MemTotal, data.MemAvail, data.GpuTotal, data.GpuAvail, data.ParticipantAvailId, data.DeletedFlag, data.CreatedBy, data.CreatedTime, data.UpdatedBy, data.UpdatedTime, data.Id)
+		return conn.ExecCtx(ctx, query, data.NodeName, data.CpuTotal, data.CpuUsable, data.DiskTotal, data.DiskAvail, data.MemTotal, data.MemAvail, data.GpuTotal, data.GpuAvail, data.ParticipantId, data.DeletedFlag, data.CreatedBy, data.CreatedTime, data.UpdatedBy, data.UpdatedTime, data.Id)
 	}, pcmScNodeAvailInfoIdKey)
 	return err
 }
diff --git a/rpc/internal/logic/participantservice/reportavailablelogic.go b/rpc/internal/logic/participantservice/reportavailablelogic.go
index 3af73ab9..36ca3dc3 100644
--- a/rpc/internal/logic/participantservice/reportavailablelogic.go
+++ b/rpc/internal/logic/participantservice/reportavailablelogic.go
@@ -75,7 +75,7 @@ func (l *ReportAvailableLogic) ReportAvailable(in *pcmCore.ParticipantAvailReq)
 		nodeInfo := &model.ScNodeAvailInfo{}
 		tool.Convert(info, nodeInfo)
 		nodeInfo.CreatedTime = time.Now()
-		nodeInfo.ParticipantAvailId = participantAvailInfo.Id
+		nodeInfo.ParticipantId = participantAvailInfo.Id
 		if nodeInfo.Id == 0 {
 			nodeInfo.Id = tool.GenSnowflakeID()
 		}
diff --git a/rpc/pb/pcmCore.proto b/rpc/pb/pcmCore.proto
index 1e9b1975..165df918 100644
--- a/rpc/pb/pcmCore.proto
+++ b/rpc/pb/pcmCore.proto
@@ -220,7 +220,7 @@ message NodeAvailInfo {
   int64 memAvail = 8;            // 内存可用数
   int64 gpuTotal = 9;            // gpu总数
   int64 gpuAvail = 10;           // gpu可用数
-  int64 participantAvailId = 11; // 集群动态信息id
+  int64 participantId = 11; // 集群动态信息id
 }
 
 // 集群可用信息
diff --git a/rpc/pcmCore/pcmCore.pb.go b/rpc/pcmCore/pcmCore.pb.go
index 804199fb..c304d00c 100644
--- a/rpc/pcmCore/pcmCore.pb.go
+++ b/rpc/pcmCore/pcmCore.pb.go
@@ -1,7 +1,7 @@
 // Code generated by protoc-gen-go. DO NOT EDIT.
 // versions:
 // 	protoc-gen-go v1.30.0
-// 	protoc        v4.23.4
+// 	protoc        v3.19.4
 // source: pb/pcmCore.proto
 
 package pcmCore
@@ -1786,17 +1786,17 @@ type NodeAvailInfo struct {
 	sizeCache     protoimpl.SizeCache
 	unknownFields protoimpl.UnknownFields
 
-	Id                 int64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`                                  // id
-	NodeName           string  `protobuf:"bytes,2,opt,name=nodeName,proto3" json:"nodeName,omitempty"`                       // 节点名称
-	CpuTotal           int64   `protobuf:"varint,3,opt,name=cpuTotal,proto3" json:"cpuTotal,omitempty"`                      // cpu核数
-	CpuUsable          float64 `protobuf:"fixed64,4,opt,name=cpuUsable,proto3" json:"cpuUsable,omitempty"`                   // cpu可用率
-	DiskTotal          int64   `protobuf:"varint,5,opt,name=diskTotal,proto3" json:"diskTotal,omitempty"`                    // 磁盘空间
-	DiskAvail          int64   `protobuf:"varint,6,opt,name=diskAvail,proto3" json:"diskAvail,omitempty"`                    // 磁盘可用空间
-	MemTotal           int64   `protobuf:"varint,7,opt,name=memTotal,proto3" json:"memTotal,omitempty"`                      // 内存总数
-	MemAvail           int64   `protobuf:"varint,8,opt,name=memAvail,proto3" json:"memAvail,omitempty"`                      // 内存可用数
-	GpuTotal           int64   `protobuf:"varint,9,opt,name=gpuTotal,proto3" json:"gpuTotal,omitempty"`                      // gpu总数
-	GpuAvail           int64   `protobuf:"varint,10,opt,name=gpuAvail,proto3" json:"gpuAvail,omitempty"`                     // gpu可用数
-	ParticipantAvailId int64   `protobuf:"varint,11,opt,name=participantAvailId,proto3" json:"participantAvailId,omitempty"` // 集群动态信息id
+	Id            int64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`                        // id
+	NodeName      string  `protobuf:"bytes,2,opt,name=nodeName,proto3" json:"nodeName,omitempty"`             // 节点名称
+	CpuTotal      int64   `protobuf:"varint,3,opt,name=cpuTotal,proto3" json:"cpuTotal,omitempty"`            // cpu核数
+	CpuUsable     float64 `protobuf:"fixed64,4,opt,name=cpuUsable,proto3" json:"cpuUsable,omitempty"`         // cpu可用率
+	DiskTotal     int64   `protobuf:"varint,5,opt,name=diskTotal,proto3" json:"diskTotal,omitempty"`          // 磁盘空间
+	DiskAvail     int64   `protobuf:"varint,6,opt,name=diskAvail,proto3" json:"diskAvail,omitempty"`          // 磁盘可用空间
+	MemTotal      int64   `protobuf:"varint,7,opt,name=memTotal,proto3" json:"memTotal,omitempty"`            // 内存总数
+	MemAvail      int64   `protobuf:"varint,8,opt,name=memAvail,proto3" json:"memAvail,omitempty"`            // 内存可用数
+	GpuTotal      int64   `protobuf:"varint,9,opt,name=gpuTotal,proto3" json:"gpuTotal,omitempty"`            // gpu总数
+	GpuAvail      int64   `protobuf:"varint,10,opt,name=gpuAvail,proto3" json:"gpuAvail,omitempty"`           // gpu可用数
+	ParticipantId int64   `protobuf:"varint,11,opt,name=participantId,proto3" json:"participantId,omitempty"` // 集群动态信息id
 }
 
 func (x *NodeAvailInfo) Reset() {
@@ -1901,9 +1901,9 @@ func (x *NodeAvailInfo) GetGpuAvail() int64 {
 	return 0
 }
 
-func (x *NodeAvailInfo) GetParticipantAvailId() int64 {
+func (x *NodeAvailInfo) GetParticipantId() int64 {
 	if x != nil {
-		return x.ParticipantAvailId
+		return x.ParticipantId
 	}
 	return 0
 }
@@ -2095,10 +2095,10 @@ type ClientInfo struct {
 	sizeCache     protoimpl.SizeCache
 	unknownFields protoimpl.UnknownFields
 
-	Address       string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty" redis:"address"`
-	ParticipantId int64  `protobuf:"varint,2,opt,name=participantId,proto3" json:"participantId,omitempty" redis:"participantId"`
-	ClientState   string `protobuf:"bytes,3,opt,name=clientState,proto3" json:"clientState,omitempty" redis:"clientState"`
-	LastHeartbeat int64  `protobuf:"varint,4,opt,name=lastHeartbeat,proto3" json:"lastHeartbeat,omitempty" redis:"lastHeartbeat"`
+	Address       string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`              // @gotags: redis:"address"
+	ParticipantId int64  `protobuf:"varint,2,opt,name=participantId,proto3" json:"participantId,omitempty"` // @gotags: redis:"participantId"
+	ClientState   string `protobuf:"bytes,3,opt,name=clientState,proto3" json:"clientState,omitempty"`      // @gotags: redis:"clientState"
+	LastHeartbeat int64  `protobuf:"varint,4,opt,name=lastHeartbeat,proto3" json:"lastHeartbeat,omitempty"` // @gotags: redis:"lastHeartbeat"
 }
 
 func (x *ClientInfo) Reset() {
@@ -2438,7 +2438,7 @@ var file_pb_pcmCore_proto_rawDesc = []byte{
 	0x41, 0x76, 0x61, 0x69, 0x6c, 0x49, 0x6e, 0x66, 0x6f, 0x18, 0x07, 0x20, 0x03, 0x28, 0x0b, 0x32,
 	0x16, 0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x2e, 0x4e, 0x6f, 0x64, 0x65, 0x41, 0x76,
 	0x61, 0x69, 0x6c, 0x49, 0x6e, 0x66, 0x6f, 0x52, 0x0d, 0x6e, 0x6f, 0x64, 0x65, 0x41, 0x76, 0x61,
-	0x69, 0x6c, 0x49, 0x6e, 0x66, 0x6f, 0x22, 0xd1, 0x02, 0x0a, 0x0d, 0x4e, 0x6f, 0x64, 0x65, 0x41,
+	0x69, 0x6c, 0x49, 0x6e, 0x66, 0x6f, 0x22, 0xc7, 0x02, 0x0a, 0x0d, 0x4e, 0x6f, 0x64, 0x65, 0x41,
 	0x76, 0x61, 0x69, 0x6c, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01,
 	0x20, 0x01, 0x28, 0x03, 0x52, 0x02, 0x69, 0x64, 0x12, 0x1a, 0x0a, 0x08, 0x6e, 0x6f, 0x64, 0x65,
 	0x4e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x6e, 0x6f, 0x64, 0x65,
@@ -2456,83 +2456,83 @@ var file_pb_pcmCore_proto_rawDesc = []byte{
 	0x69, 0x6c, 0x12, 0x1a, 0x0a, 0x08, 0x67, 0x70, 0x75, 0x54, 0x6f, 0x74, 0x61, 0x6c, 0x18, 0x09,
 	0x20, 0x01, 0x28, 0x03, 0x52, 0x08, 0x67, 0x70, 0x75, 0x54, 0x6f, 0x74, 0x61, 0x6c, 0x12, 0x1a,
 	0x0a, 0x08, 0x67, 0x70, 0x75, 0x41, 0x76, 0x61, 0x69, 0x6c, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x03,
-	0x52, 0x08, 0x67, 0x70, 0x75, 0x41, 0x76, 0x61, 0x69, 0x6c, 0x12, 0x2e, 0x0a, 0x12, 0x70, 0x61,
-	0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x41, 0x76, 0x61, 0x69, 0x6c, 0x49, 0x64,
-	0x18, 0x0b, 0x20, 0x01, 0x28, 0x03, 0x52, 0x12, 0x70, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70,
-	0x61, 0x6e, 0x74, 0x41, 0x76, 0x61, 0x69, 0x6c, 0x49, 0x64, 0x22, 0x8c, 0x01, 0x0a, 0x18, 0x4c,
-	0x69, 0x73, 0x74, 0x50, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x41, 0x76,
-	0x61, 0x69, 0x6c, 0x52, 0x65, 0x73, 0x70, 0x12, 0x12, 0x0a, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x18,
-	0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x12, 0x10, 0x0a, 0x03, 0x6d,
-	0x73, 0x67, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6d, 0x73, 0x67, 0x12, 0x4a, 0x0a,
-	0x11, 0x50, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x41, 0x76, 0x61, 0x69,
-	0x6c, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1c, 0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f,
-	0x72, 0x65, 0x2e, 0x50, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x41, 0x76,
-	0x61, 0x69, 0x6c, 0x52, 0x65, 0x71, 0x52, 0x11, 0x50, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70,
-	0x61, 0x6e, 0x74, 0x41, 0x76, 0x61, 0x69, 0x6c, 0x73, 0x22, 0x37, 0x0a, 0x0f, 0x50, 0x61, 0x72,
-	0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x52, 0x65, 0x73, 0x70, 0x12, 0x12, 0x0a, 0x04,
-	0x63, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x04, 0x63, 0x6f, 0x64, 0x65,
-	0x12, 0x10, 0x0a, 0x03, 0x6d, 0x73, 0x67, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6d,
-	0x73, 0x67, 0x22, 0x67, 0x0a, 0x16, 0x50, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e,
-	0x74, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x52, 0x65, 0x73, 0x70, 0x12, 0x12, 0x0a, 0x04,
-	0x63, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x04, 0x63, 0x6f, 0x64, 0x65,
-	0x12, 0x10, 0x0a, 0x03, 0x6d, 0x73, 0x67, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6d,
-	0x73, 0x67, 0x12, 0x27, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b,
-	0x32, 0x13, 0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x2e, 0x43, 0x6c, 0x69, 0x65, 0x6e,
-	0x74, 0x49, 0x6e, 0x66, 0x6f, 0x52, 0x04, 0x64, 0x61, 0x74, 0x61, 0x22, 0x94, 0x01, 0x0a, 0x0a,
-	0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x18, 0x0a, 0x07, 0x61, 0x64,
-	0x64, 0x72, 0x65, 0x73, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x61, 0x64, 0x64,
-	0x72, 0x65, 0x73, 0x73, 0x12, 0x24, 0x0a, 0x0d, 0x70, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70,
-	0x61, 0x6e, 0x74, 0x49, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0d, 0x70, 0x61, 0x72,
-	0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x49, 0x64, 0x12, 0x20, 0x0a, 0x0b, 0x63, 0x6c,
-	0x69, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x61, 0x74, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52,
-	0x0b, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x61, 0x74, 0x65, 0x12, 0x24, 0x0a, 0x0d,
-	0x6c, 0x61, 0x73, 0x74, 0x48, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x18, 0x04, 0x20,
-	0x01, 0x28, 0x03, 0x52, 0x0d, 0x6c, 0x61, 0x73, 0x74, 0x48, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65,
-	0x61, 0x74, 0x2a, 0x33, 0x0a, 0x0d, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x53, 0x74, 0x61,
-	0x74, 0x75, 0x73, 0x12, 0x08, 0x0a, 0x04, 0x46, 0x41, 0x49, 0x4c, 0x10, 0x00, 0x12, 0x0b, 0x0a,
-	0x07, 0x53, 0x55, 0x43, 0x43, 0x45, 0x53, 0x53, 0x10, 0x01, 0x12, 0x0b, 0x0a, 0x07, 0x55, 0x4e,
-	0x4b, 0x4e, 0x4f, 0x57, 0x4e, 0x10, 0x02, 0x32, 0x7b, 0x0a, 0x07, 0x70, 0x63, 0x6d, 0x43, 0x6f,
-	0x72, 0x65, 0x12, 0x37, 0x0a, 0x08, 0x53, 0x79, 0x6e, 0x63, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x14,
-	0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x2e, 0x53, 0x79, 0x6e, 0x63, 0x49, 0x6e, 0x66,
-	0x6f, 0x52, 0x65, 0x71, 0x1a, 0x15, 0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x2e, 0x53,
-	0x79, 0x6e, 0x63, 0x49, 0x6e, 0x66, 0x6f, 0x52, 0x65, 0x73, 0x70, 0x12, 0x37, 0x0a, 0x08, 0x49,
-	0x6e, 0x66, 0x6f, 0x4c, 0x69, 0x73, 0x74, 0x12, 0x14, 0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72,
-	0x65, 0x2e, 0x49, 0x6e, 0x66, 0x6f, 0x4c, 0x69, 0x73, 0x74, 0x52, 0x65, 0x71, 0x1a, 0x15, 0x2e,
-	0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x2e, 0x49, 0x6e, 0x66, 0x6f, 0x4c, 0x69, 0x73, 0x74,
-	0x52, 0x65, 0x73, 0x70, 0x32, 0x80, 0x04, 0x0a, 0x12, 0x70, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69,
-	0x70, 0x61, 0x6e, 0x74, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x50, 0x0a, 0x13, 0x72,
-	0x65, 0x67, 0x69, 0x73, 0x74, 0x65, 0x72, 0x50, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61,
-	0x6e, 0x74, 0x12, 0x1a, 0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x2e, 0x50, 0x61, 0x72,
-	0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x50, 0x68, 0x79, 0x52, 0x65, 0x71, 0x1a, 0x1b,
+	0x52, 0x08, 0x67, 0x70, 0x75, 0x41, 0x76, 0x61, 0x69, 0x6c, 0x12, 0x24, 0x0a, 0x0d, 0x70, 0x61,
+	0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x49, 0x64, 0x18, 0x0b, 0x20, 0x01, 0x28,
+	0x03, 0x52, 0x0d, 0x70, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x49, 0x64,
+	0x22, 0x8c, 0x01, 0x0a, 0x18, 0x4c, 0x69, 0x73, 0x74, 0x50, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69,
+	0x70, 0x61, 0x6e, 0x74, 0x41, 0x76, 0x61, 0x69, 0x6c, 0x52, 0x65, 0x73, 0x70, 0x12, 0x12, 0x0a,
+	0x04, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x04, 0x63, 0x6f, 0x64,
+	0x65, 0x12, 0x10, 0x0a, 0x03, 0x6d, 0x73, 0x67, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03,
+	0x6d, 0x73, 0x67, 0x12, 0x4a, 0x0a, 0x11, 0x50, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61,
+	0x6e, 0x74, 0x41, 0x76, 0x61, 0x69, 0x6c, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1c,
 	0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x2e, 0x50, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69,
-	0x70, 0x61, 0x6e, 0x74, 0x50, 0x68, 0x79, 0x52, 0x65, 0x73, 0x70, 0x22, 0x00, 0x12, 0x4f, 0x0a,
-	0x0f, 0x72, 0x65, 0x70, 0x6f, 0x72, 0x74, 0x48, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74,
-	0x12, 0x20, 0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x2e, 0x50, 0x61, 0x72, 0x74, 0x69,
-	0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x48, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x52,
-	0x65, 0x71, 0x1a, 0x18, 0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x2e, 0x48, 0x65, 0x61,
-	0x6c, 0x74, 0x68, 0x43, 0x68, 0x65, 0x63, 0x6b, 0x52, 0x65, 0x73, 0x70, 0x22, 0x00, 0x12, 0x4b,
-	0x0a, 0x0f, 0x72, 0x65, 0x70, 0x6f, 0x72, 0x74, 0x41, 0x76, 0x61, 0x69, 0x6c, 0x61, 0x62, 0x6c,
-	0x65, 0x12, 0x1c, 0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x2e, 0x50, 0x61, 0x72, 0x74,
-	0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x41, 0x76, 0x61, 0x69, 0x6c, 0x52, 0x65, 0x71, 0x1a,
-	0x18, 0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x2e, 0x50, 0x61, 0x72, 0x74, 0x69, 0x63,
-	0x69, 0x70, 0x61, 0x6e, 0x74, 0x52, 0x65, 0x73, 0x70, 0x22, 0x00, 0x12, 0x50, 0x0a, 0x0f, 0x6c,
-	0x69, 0x73, 0x74, 0x50, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x12, 0x1a,
+	0x70, 0x61, 0x6e, 0x74, 0x41, 0x76, 0x61, 0x69, 0x6c, 0x52, 0x65, 0x71, 0x52, 0x11, 0x50, 0x61,
+	0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x41, 0x76, 0x61, 0x69, 0x6c, 0x73, 0x22,
+	0x37, 0x0a, 0x0f, 0x50, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x52, 0x65,
+	0x73, 0x70, 0x12, 0x12, 0x0a, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03,
+	0x52, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x12, 0x10, 0x0a, 0x03, 0x6d, 0x73, 0x67, 0x18, 0x02, 0x20,
+	0x01, 0x28, 0x09, 0x52, 0x03, 0x6d, 0x73, 0x67, 0x22, 0x67, 0x0a, 0x16, 0x50, 0x61, 0x72, 0x74,
+	0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x52, 0x65,
+	0x73, 0x70, 0x12, 0x12, 0x0a, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03,
+	0x52, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x12, 0x10, 0x0a, 0x03, 0x6d, 0x73, 0x67, 0x18, 0x02, 0x20,
+	0x01, 0x28, 0x09, 0x52, 0x03, 0x6d, 0x73, 0x67, 0x12, 0x27, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61,
+	0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x13, 0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65,
+	0x2e, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x49, 0x6e, 0x66, 0x6f, 0x52, 0x04, 0x64, 0x61, 0x74,
+	0x61, 0x22, 0x94, 0x01, 0x0a, 0x0a, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x49, 0x6e, 0x66, 0x6f,
+	0x12, 0x18, 0x0a, 0x07, 0x61, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28,
+	0x09, 0x52, 0x07, 0x61, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x12, 0x24, 0x0a, 0x0d, 0x70, 0x61,
+	0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x49, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28,
+	0x03, 0x52, 0x0d, 0x70, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x49, 0x64,
+	0x12, 0x20, 0x0a, 0x0b, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x61, 0x74, 0x65, 0x18,
+	0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x61,
+	0x74, 0x65, 0x12, 0x24, 0x0a, 0x0d, 0x6c, 0x61, 0x73, 0x74, 0x48, 0x65, 0x61, 0x72, 0x74, 0x62,
+	0x65, 0x61, 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0d, 0x6c, 0x61, 0x73, 0x74, 0x48,
+	0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x2a, 0x33, 0x0a, 0x0d, 0x4d, 0x65, 0x73, 0x73,
+	0x61, 0x67, 0x65, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x08, 0x0a, 0x04, 0x46, 0x41, 0x49,
+	0x4c, 0x10, 0x00, 0x12, 0x0b, 0x0a, 0x07, 0x53, 0x55, 0x43, 0x43, 0x45, 0x53, 0x53, 0x10, 0x01,
+	0x12, 0x0b, 0x0a, 0x07, 0x55, 0x4e, 0x4b, 0x4e, 0x4f, 0x57, 0x4e, 0x10, 0x02, 0x32, 0x7b, 0x0a,
+	0x07, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x12, 0x37, 0x0a, 0x08, 0x53, 0x79, 0x6e, 0x63,
+	0x49, 0x6e, 0x66, 0x6f, 0x12, 0x14, 0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x2e, 0x53,
+	0x79, 0x6e, 0x63, 0x49, 0x6e, 0x66, 0x6f, 0x52, 0x65, 0x71, 0x1a, 0x15, 0x2e, 0x70, 0x63, 0x6d,
+	0x43, 0x6f, 0x72, 0x65, 0x2e, 0x53, 0x79, 0x6e, 0x63, 0x49, 0x6e, 0x66, 0x6f, 0x52, 0x65, 0x73,
+	0x70, 0x12, 0x37, 0x0a, 0x08, 0x49, 0x6e, 0x66, 0x6f, 0x4c, 0x69, 0x73, 0x74, 0x12, 0x14, 0x2e,
+	0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x2e, 0x49, 0x6e, 0x66, 0x6f, 0x4c, 0x69, 0x73, 0x74,
+	0x52, 0x65, 0x71, 0x1a, 0x15, 0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x2e, 0x49, 0x6e,
+	0x66, 0x6f, 0x4c, 0x69, 0x73, 0x74, 0x52, 0x65, 0x73, 0x70, 0x32, 0x80, 0x04, 0x0a, 0x12, 0x70,
+	0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63,
+	0x65, 0x12, 0x50, 0x0a, 0x13, 0x72, 0x65, 0x67, 0x69, 0x73, 0x74, 0x65, 0x72, 0x50, 0x61, 0x72,
+	0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x12, 0x1a, 0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f,
+	0x72, 0x65, 0x2e, 0x50, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x50, 0x68,
+	0x79, 0x52, 0x65, 0x71, 0x1a, 0x1b, 0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x2e, 0x50,
+	0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x50, 0x68, 0x79, 0x52, 0x65, 0x73,
+	0x70, 0x22, 0x00, 0x12, 0x4f, 0x0a, 0x0f, 0x72, 0x65, 0x70, 0x6f, 0x72, 0x74, 0x48, 0x65, 0x61,
+	0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x12, 0x20, 0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65,
+	0x2e, 0x50, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x48, 0x65, 0x61, 0x72,
+	0x74, 0x62, 0x65, 0x61, 0x74, 0x52, 0x65, 0x71, 0x1a, 0x18, 0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f,
+	0x72, 0x65, 0x2e, 0x48, 0x65, 0x61, 0x6c, 0x74, 0x68, 0x43, 0x68, 0x65, 0x63, 0x6b, 0x52, 0x65,
+	0x73, 0x70, 0x22, 0x00, 0x12, 0x4b, 0x0a, 0x0f, 0x72, 0x65, 0x70, 0x6f, 0x72, 0x74, 0x41, 0x76,
+	0x61, 0x69, 0x6c, 0x61, 0x62, 0x6c, 0x65, 0x12, 0x1c, 0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72,
+	0x65, 0x2e, 0x50, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x41, 0x76, 0x61,
+	0x69, 0x6c, 0x52, 0x65, 0x71, 0x1a, 0x18, 0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x2e,
+	0x50, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x52, 0x65, 0x73, 0x70, 0x22,
+	0x00, 0x12, 0x50, 0x0a, 0x0f, 0x6c, 0x69, 0x73, 0x74, 0x50, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69,
+	0x70, 0x61, 0x6e, 0x74, 0x12, 0x1a, 0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x2e, 0x50,
+	0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x54, 0x65, 0x6e, 0x61, 0x6e, 0x74,
+	0x1a, 0x1f, 0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x2e, 0x50, 0x61, 0x72, 0x74, 0x69,
+	0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x52, 0x65, 0x73,
+	0x70, 0x22, 0x00, 0x12, 0x53, 0x0a, 0x10, 0x6c, 0x69, 0x73, 0x74, 0x50, 0x68, 0x79, 0x41, 0x76,
+	0x61, 0x69, 0x6c, 0x61, 0x62, 0x6c, 0x65, 0x12, 0x1a, 0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72,
+	0x65, 0x2e, 0x50, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x54, 0x65, 0x6e,
+	0x61, 0x6e, 0x74, 0x1a, 0x21, 0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x2e, 0x4c, 0x69,
+	0x73, 0x74, 0x50, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x41, 0x76, 0x61,
+	0x69, 0x6c, 0x52, 0x65, 0x73, 0x70, 0x22, 0x00, 0x12, 0x53, 0x0a, 0x12, 0x6c, 0x69, 0x73, 0x74,
+	0x50, 0x68, 0x79, 0x49, 0x6e, 0x66, 0x6f, 0x72, 0x6d, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x1a,
 	0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x2e, 0x50, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69,
 	0x70, 0x61, 0x6e, 0x74, 0x54, 0x65, 0x6e, 0x61, 0x6e, 0x74, 0x1a, 0x1f, 0x2e, 0x70, 0x63, 0x6d,
-	0x43, 0x6f, 0x72, 0x65, 0x2e, 0x50, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74,
-	0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x52, 0x65, 0x73, 0x70, 0x22, 0x00, 0x12, 0x53, 0x0a,
-	0x10, 0x6c, 0x69, 0x73, 0x74, 0x50, 0x68, 0x79, 0x41, 0x76, 0x61, 0x69, 0x6c, 0x61, 0x62, 0x6c,
-	0x65, 0x12, 0x1a, 0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x2e, 0x50, 0x61, 0x72, 0x74,
-	0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x54, 0x65, 0x6e, 0x61, 0x6e, 0x74, 0x1a, 0x21, 0x2e,
-	0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x50, 0x61, 0x72, 0x74,
-	0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x41, 0x76, 0x61, 0x69, 0x6c, 0x52, 0x65, 0x73, 0x70,
-	0x22, 0x00, 0x12, 0x53, 0x0a, 0x12, 0x6c, 0x69, 0x73, 0x74, 0x50, 0x68, 0x79, 0x49, 0x6e, 0x66,
-	0x6f, 0x72, 0x6d, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x1a, 0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f,
-	0x72, 0x65, 0x2e, 0x50, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x54, 0x65,
-	0x6e, 0x61, 0x6e, 0x74, 0x1a, 0x1f, 0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x2e, 0x4c,
-	0x69, 0x73, 0x74, 0x50, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x50, 0x68,
-	0x79, 0x52, 0x65, 0x73, 0x70, 0x22, 0x00, 0x42, 0x0a, 0x5a, 0x08, 0x2f, 0x70, 0x63, 0x6d, 0x43,
-	0x6f, 0x72, 0x65, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
+	0x43, 0x6f, 0x72, 0x65, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x50, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69,
+	0x70, 0x61, 0x6e, 0x74, 0x50, 0x68, 0x79, 0x52, 0x65, 0x73, 0x70, 0x22, 0x00, 0x42, 0x0a, 0x5a,
+	0x08, 0x2f, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f,
+	0x33,
 }
 
 var (
diff --git a/rpc/pcmCore/pcmCore_grpc.pb.go b/rpc/pcmCore/pcmCore_grpc.pb.go
index eb63b990..3659c9e1 100644
--- a/rpc/pcmCore/pcmCore_grpc.pb.go
+++ b/rpc/pcmCore/pcmCore_grpc.pb.go
@@ -1,7 +1,7 @@
 // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
 // versions:
 // - protoc-gen-go-grpc v1.3.0
-// - protoc             v4.23.4
+// - protoc             v3.19.4
 // source: pb/pcmCore.proto
 
 package pcmCore