diff --git a/go.mod b/go.mod index 4bba8334..2812b4bd 100644 --- a/go.mod +++ b/go.mod @@ -16,7 +16,7 @@ require ( github.com/zeromicro/go-queue v1.1.8 github.com/zeromicro/go-zero v1.5.4 gitlink.org.cn/jcce-pcm/pcm-participant-ac v0.0.0-20230814074259-99e24e1194d1 - gitlink.org.cn/jcce-pcm/pcm-participant-ceph v0.0.0-20230811110436-43ae93ec1796 + gitlink.org.cn/jcce-pcm/pcm-participant-ceph v0.0.0-20230817103341-2459e5bfc835 gitlink.org.cn/jcce-pcm/pcm-participant-modelarts v0.0.0-20230719015658-08a29549d86a gitlink.org.cn/jcce-pcm/pcm-participant-octopus v0.0.0-20230714030856-601935bc30e2 gitlink.org.cn/jcce-pcm/pcm-participant-slurm v0.0.0-20230714030125-a52fa198ddf4 diff --git a/go.sum b/go.sum index fc6347f8..606ae80b 100644 --- a/go.sum +++ b/go.sum @@ -1029,8 +1029,8 @@ github.com/zeromicro/go-zero v1.5.4 h1:kRvcYuxcHOkUZvg7887KQl77Qv4klGL7MqGkTBgkp github.com/zeromicro/go-zero v1.5.4/go.mod h1:x/aUyLmSwRECvOyjOf+lhwThBOilJIY+s3slmPAeboA= gitlink.org.cn/jcce-pcm/pcm-participant-ac v0.0.0-20230814074259-99e24e1194d1 h1:eh5H8d2+YsvN6uhkwMg6UbihPEDZcU2yKpXVYE8hDE0= gitlink.org.cn/jcce-pcm/pcm-participant-ac v0.0.0-20230814074259-99e24e1194d1/go.mod h1:OflOWySJqYAygcwL7vT2yVtfcUs9TM3kmoD+89Tbu7c= -gitlink.org.cn/jcce-pcm/pcm-participant-ceph v0.0.0-20230811110436-43ae93ec1796 h1:NxIT12DfQW3ff8fUwrEhHFwe/c9sIlxUG3g0XUh7v90= -gitlink.org.cn/jcce-pcm/pcm-participant-ceph v0.0.0-20230811110436-43ae93ec1796/go.mod h1:Jk4srb1NAFSn/kMWeo71/I02luZ8OrmVnUFWb8abr7I= +gitlink.org.cn/jcce-pcm/pcm-participant-ceph v0.0.0-20230817103341-2459e5bfc835 h1:WDCPqD8IrepGJXankkpG14Ny6inh9AldB0RX9WWa+ck= +gitlink.org.cn/jcce-pcm/pcm-participant-ceph v0.0.0-20230817103341-2459e5bfc835/go.mod h1:r/KLzUpupCV5jdxSfgDhc2pVjP0fBi3VhAWRttsBn30= gitlink.org.cn/jcce-pcm/pcm-participant-modelarts v0.0.0-20230719015658-08a29549d86a h1:eSniMdLizPV3RNrz7/URgjT3Kpv1cTZ05jrWfxRJxHs= gitlink.org.cn/jcce-pcm/pcm-participant-modelarts v0.0.0-20230719015658-08a29549d86a/go.mod h1:BhOgwM1LC+BD46DjTaQyYQVZs1CikwI5Pl/6qzKUexc= gitlink.org.cn/jcce-pcm/pcm-participant-octopus v0.0.0-20230714030856-601935bc30e2 h1:RcGSqhsod6VXLksSLqNjV0q/SCeoUv6CbThKmV9NTZE= diff --git a/model/scqueuephyinfomodel.go b/model/scqueuephyinfomodel.go new file mode 100755 index 00000000..87160a60 --- /dev/null +++ b/model/scqueuephyinfomodel.go @@ -0,0 +1,27 @@ +package model + +import ( + "github.com/zeromicro/go-zero/core/stores/cache" + "github.com/zeromicro/go-zero/core/stores/sqlx" +) + +var _ ScQueuePhyInfoModel = (*customScQueuePhyInfoModel)(nil) + +type ( + // ScQueuePhyInfoModel is an interface to be customized, add more methods here, + // and implement the added methods in customScQueuePhyInfoModel. + ScQueuePhyInfoModel interface { + scQueuePhyInfoModel + } + + customScQueuePhyInfoModel struct { + *defaultScQueuePhyInfoModel + } +) + +// NewScQueuePhyInfoModel returns a model for the database table. +func NewScQueuePhyInfoModel(conn sqlx.SqlConn, c cache.CacheConf, opts ...cache.Option) ScQueuePhyInfoModel { + return &customScQueuePhyInfoModel{ + defaultScQueuePhyInfoModel: newScQueuePhyInfoModel(conn, c, opts...), + } +} diff --git a/model/scqueuephyinfomodel_gen.go b/model/scqueuephyinfomodel_gen.go new file mode 100755 index 00000000..c4018fcb --- /dev/null +++ b/model/scqueuephyinfomodel_gen.go @@ -0,0 +1,135 @@ +// Code generated by goctl. DO NOT EDIT. + +package model + +import ( + "context" + "database/sql" + "fmt" + "strings" + "time" + + "github.com/zeromicro/go-zero/core/stores/builder" + "github.com/zeromicro/go-zero/core/stores/cache" + "github.com/zeromicro/go-zero/core/stores/sqlc" + "github.com/zeromicro/go-zero/core/stores/sqlx" + "github.com/zeromicro/go-zero/core/stringx" +) + +var ( + scQueuePhyInfoFieldNames = builder.RawFieldNames(&ScQueuePhyInfo{}) + scQueuePhyInfoRows = strings.Join(scQueuePhyInfoFieldNames, ",") + scQueuePhyInfoRowsExpectAutoSet = strings.Join(stringx.Remove(scQueuePhyInfoFieldNames, "`create_at`", "`create_time`", "`created_at`", "`update_at`", "`update_time`", "`updated_at`"), ",") + scQueuePhyInfoRowsWithPlaceHolder = strings.Join(stringx.Remove(scQueuePhyInfoFieldNames, "`id`", "`create_at`", "`create_time`", "`created_at`", "`update_at`", "`update_time`", "`updated_at`"), "=?,") + "=?" + + cachePcmScQueuePhyInfoIdPrefix = "cache:pcm:scQueuePhyInfo:id:" +) + +type ( + scQueuePhyInfoModel interface { + Insert(ctx context.Context, data *ScQueuePhyInfo) (sql.Result, error) + FindOne(ctx context.Context, id int64) (*ScQueuePhyInfo, error) + Update(ctx context.Context, data *ScQueuePhyInfo) error + Delete(ctx context.Context, id int64) error + } + + defaultScQueuePhyInfoModel struct { + sqlc.CachedConn + table string + } + + ScQueuePhyInfo struct { + Id int64 `db:"id"` // id + QueueName string `db:"queue_name"` // 队列名称 + QueNodes int64 `db:"que_nodes"` // 队列节点总数 + QueMinNodect int64 `db:"que_min_nodect"` // 队列最小节点数 + QueMaxNgpus int64 `db:"que_max_ngpus"` // 队列最大GPU卡数 + QueMaxPpn int64 `db:"que_max_ppn"` // 使用该队列作业最大CPU核心数 + QueChargeRate string `db:"que_charge_rate"` // 费率 + QueMaxNcpus int64 `db:"que_max_ncpus"` // 用户最大可用核心数 + QueMaxNdcus int64 `db:"que_max_ndcus"` // 队列总DCU卡数 + QueMinNcpus int64 `db:"que_min_ncpus"` // 队列最小CPU核数 + QueFreeNodes int64 `db:"que_free_nodes"` // 队列空闲节点数 + QueMaxNodect int64 `db:"que_max_nodect"` // 队列作业最大节点数 + QueMaxGpuPN int64 `db:"que_max_gpu_PN"` // 队列单作业最大GPU卡数 + QueMaxWalltime string `db:"que_max_walltime"` // 队列最大运行时间 + QueMaxDcuPN int64 `db:"que_max_dcu_PN"` // 队列单作业最大DCU卡数 + 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"` // 更新时间 + } +) + +func newScQueuePhyInfoModel(conn sqlx.SqlConn, c cache.CacheConf, opts ...cache.Option) *defaultScQueuePhyInfoModel { + return &defaultScQueuePhyInfoModel{ + CachedConn: sqlc.NewConn(conn, c, opts...), + table: "`sc_queue_phy_info`", + } +} + +func (m *defaultScQueuePhyInfoModel) withSession(session sqlx.Session) *defaultScQueuePhyInfoModel { + return &defaultScQueuePhyInfoModel{ + CachedConn: m.CachedConn.WithSession(session), + table: "`sc_queue_phy_info`", + } +} + +func (m *defaultScQueuePhyInfoModel) Delete(ctx context.Context, id int64) error { + pcmScQueuePhyInfoIdKey := fmt.Sprintf("%s%v", cachePcmScQueuePhyInfoIdPrefix, id) + _, err := m.ExecCtx(ctx, func(ctx context.Context, conn sqlx.SqlConn) (result sql.Result, err error) { + query := fmt.Sprintf("delete from %s where `id` = ?", m.table) + return conn.ExecCtx(ctx, query, id) + }, pcmScQueuePhyInfoIdKey) + return err +} + +func (m *defaultScQueuePhyInfoModel) FindOne(ctx context.Context, id int64) (*ScQueuePhyInfo, error) { + pcmScQueuePhyInfoIdKey := fmt.Sprintf("%s%v", cachePcmScQueuePhyInfoIdPrefix, id) + var resp ScQueuePhyInfo + err := m.QueryRowCtx(ctx, &resp, pcmScQueuePhyInfoIdKey, func(ctx context.Context, conn sqlx.SqlConn, v any) error { + query := fmt.Sprintf("select %s from %s where `id` = ? limit 1", scQueuePhyInfoRows, m.table) + return conn.QueryRowCtx(ctx, v, query, id) + }) + switch err { + case nil: + return &resp, nil + case sqlc.ErrNotFound: + return nil, ErrNotFound + default: + return nil, err + } +} + +func (m *defaultScQueuePhyInfoModel) Insert(ctx context.Context, data *ScQueuePhyInfo) (sql.Result, error) { + pcmScQueuePhyInfoIdKey := fmt.Sprintf("%s%v", cachePcmScQueuePhyInfoIdPrefix, 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, scQueuePhyInfoRowsExpectAutoSet) + return conn.ExecCtx(ctx, query, data.Id, data.QueueName, data.QueNodes, data.QueMinNodect, data.QueMaxNgpus, data.QueMaxPpn, data.QueChargeRate, data.QueMaxNcpus, data.QueMaxNdcus, data.QueMinNcpus, data.QueFreeNodes, data.QueMaxNodect, data.QueMaxGpuPN, data.QueMaxWalltime, data.QueMaxDcuPN, data.ParticipantId, data.DeletedFlag, data.CreatedBy, data.CreatedTime, data.UpdatedBy, data.UpdatedTime) + }, pcmScQueuePhyInfoIdKey) + return ret, err +} + +func (m *defaultScQueuePhyInfoModel) Update(ctx context.Context, data *ScQueuePhyInfo) error { + pcmScQueuePhyInfoIdKey := fmt.Sprintf("%s%v", cachePcmScQueuePhyInfoIdPrefix, 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, scQueuePhyInfoRowsWithPlaceHolder) + return conn.ExecCtx(ctx, query, data.QueueName, data.QueNodes, data.QueMinNodect, data.QueMaxNgpus, data.QueMaxPpn, data.QueChargeRate, data.QueMaxNcpus, data.QueMaxNdcus, data.QueMinNcpus, data.QueFreeNodes, data.QueMaxNodect, data.QueMaxGpuPN, data.QueMaxWalltime, data.QueMaxDcuPN, data.ParticipantId, data.DeletedFlag, data.CreatedBy, data.CreatedTime, data.UpdatedBy, data.UpdatedTime, data.Id) + }, pcmScQueuePhyInfoIdKey) + return err +} + +func (m *defaultScQueuePhyInfoModel) formatPrimary(primary any) string { + return fmt.Sprintf("%s%v", cachePcmScQueuePhyInfoIdPrefix, primary) +} + +func (m *defaultScQueuePhyInfoModel) queryPrimary(ctx context.Context, conn sqlx.SqlConn, v, primary any) error { + query := fmt.Sprintf("select %s from %s where `id` = ? limit 1", scQueuePhyInfoRows, m.table) + return conn.QueryRowCtx(ctx, v, query, primary) +} + +func (m *defaultScQueuePhyInfoModel) tableName() string { + return m.table +} diff --git a/rpc/client/participantservice/participantservice.go b/rpc/client/participantservice/participantservice.go index 0bf052ca..ec03abaa 100644 --- a/rpc/client/participantservice/participantservice.go +++ b/rpc/client/participantservice/participantservice.go @@ -32,6 +32,7 @@ type ( ParticipantResp = pcmCore.ParticipantResp ParticipantServiceResp = pcmCore.ParticipantServiceResp ParticipantTenant = pcmCore.ParticipantTenant + QueuePhyInfo = pcmCore.QueuePhyInfo SyncInfoReq = pcmCore.SyncInfoReq SyncInfoResp = pcmCore.SyncInfoResp diff --git a/rpc/client/pcmcore/pcmcore.go b/rpc/client/pcmcore/pcmcore.go index 40caca8b..70e9bd25 100644 --- a/rpc/client/pcmcore/pcmcore.go +++ b/rpc/client/pcmcore/pcmcore.go @@ -32,6 +32,7 @@ type ( ParticipantResp = pcmCore.ParticipantResp ParticipantServiceResp = pcmCore.ParticipantServiceResp ParticipantTenant = pcmCore.ParticipantTenant + QueuePhyInfo = pcmCore.QueuePhyInfo SyncInfoReq = pcmCore.SyncInfoReq SyncInfoResp = pcmCore.SyncInfoResp diff --git a/rpc/internal/logic/participantservice/registerparticipantlogic.go b/rpc/internal/logic/participantservice/registerparticipantlogic.go index 9673d297..b3453990 100644 --- a/rpc/internal/logic/participantservice/registerparticipantlogic.go +++ b/rpc/internal/logic/participantservice/registerparticipantlogic.go @@ -70,6 +70,21 @@ func (l *RegisterParticipantLogic) RegisterParticipant(in *pcmCore.ParticipantPh nodeList = append(nodeList, nodeInfo) } result = db.Save(&nodeList) + //保存队列信息 + queueList := make([]*model.ScQueuePhyInfo, 0) + for _, info := range in.QueueInfo { + queueInfo := &model.ScQueuePhyInfo{} + tool.Convert(info, queueInfo) + queueInfo.CreatedTime = time.Now() + queueInfo.ParticipantId = participantInfo.Id + //查询队列name与ParticipantId是否存在 + queueErr := db.Where(&model.ScQueuePhyInfo{QueueName: queueInfo.QueueName, ParticipantId: in.ParticipantId}).Take(queueInfo) + if errors.Is(queueErr.Error, gorm.ErrRecordNotFound) { + queueInfo.Id = tool.GenSnowflakeID() + } + queueList = append(queueList, queueInfo) + } + result = db.Save(&queueList) //保存标签信息 labelList := make([]*model.ScParticipantLabelInfo, 0) for _, label := range in.LabelInfo { diff --git a/rpc/pb/pcmCore.proto b/rpc/pb/pcmCore.proto index 136fe9a7..47995479 100644 --- a/rpc/pb/pcmCore.proto +++ b/rpc/pb/pcmCore.proto @@ -24,9 +24,9 @@ message AiInfo { string createTime = 10; string imageUrl = 11; string command = 12; - string flavorId = 13; - string subscriptionId = 14; - string itemVersionId = 15; + string flavorId = 13; + string subscriptionId = 14; + string itemVersionId = 15; } message CloudInfo { @@ -67,43 +67,42 @@ message HpcInfo { uint32 assocId = 20; } -message SyncInfoResp{ +message SyncInfoResp { int64 code = 1; string msg = 2; } -message InfoListReq{ +message InfoListReq { string kind = 1; int64 participantId = 2; } -message InfoListResp{ +message InfoListResp { repeated HpcInfo HpcInfoList = 1; repeated CloudInfo CloudInfoList = 2; repeated AiInfo AiInfoList = 3; } - // pcm core services service pcmCore { - //SyncInfo Synchronous data information + // SyncInfo Synchronous data information rpc SyncInfo(SyncInfoReq) returns (SyncInfoResp); - //InfoList + // InfoList rpc InfoList(InfoListReq) returns (InfoListResp); } // participantTenant 租户信息 -message ParticipantTenant{ - string tenantName = 1; //租户名称 +message ParticipantTenant { + string tenantName = 1; // 租户名称 } // 集群标签 message ParticipantLabel { - int64 id = 1; //id - string key = 2; //标签名 - string value = 3; //标签值 + int64 id = 1; // id + string key = 2; // 标签名 + string value = 3; // 标签值 } enum MessageStatus { @@ -112,97 +111,117 @@ enum MessageStatus { UNKNOWN = 2; } -message HealthCheckResp{ +message HealthCheckResp { MessageStatus messageStatus = 1; int64 code = 2; string msg = 3; } message ParticipantPhyResp { - int64 code = 1; - string msg = 2; - int64 participantId = 3; //participant 唯一标识 + int64 code = 1; + string msg = 2; + int64 participantId = 3; // participant 唯一标识 } -//集群静态信息返回 +// 集群静态信息返回 message ListParticipantPhyResp { int64 code = 1; string msg = 2; - repeated ParticipantPhyReq ParticipantPhys=3; + repeated ParticipantPhyReq ParticipantPhys = 3; } -//participantPhy 静态信息 +// participantPhy 静态信息 message ParticipantPhyReq { - string name = 1; //名称 - string host = 2; //host - string port = 3; //端口号 - string networkType = 4; //集群网络类型 - string networkBandwidth = 5; //集群网络带宽 - string storageType = 6; //集群存储类型 - string storageSpace = 7; //集群存储空间 - string storageAvailSpace = 8; //集群存储可用空间 - string storageBandwidth = 9; //集群存储带宽 - string type = 10; //参与者类型:0-数算集群;1-智算集群;2-超算集群 - int64 tenantId = 11; //租户id - string tenantName = 12; //租户名称 - repeated NodePhyInfo nodeInfo = 13; //节点信息 - int64 participantId = 14; //participant id - repeated ParticipantLabel labelInfo = 15; //标签信息 - int64 id =16; //id + string name = 1; // 名称 + string host = 2; // host + string port = 3; // 端口号 + string networkType = 4; // 集群网络类型 + string networkBandwidth = 5; // 集群网络带宽 + string storageType = 6; // 集群存储类型 + string storageSpace = 7; // 集群存储空间 + string storageAvailSpace = 8; // 集群存储可用空间 + string storageBandwidth = 9; // 集群存储带宽 + string type = 10; // 参与者类型:0-数算集群;1-智算集群;2-超算集群 + int64 tenantId = 11; // 租户id + string tenantName = 12; // 租户名称 + repeated NodePhyInfo nodeInfo = 13; // 节点信息 + int64 participantId = 14; // participant id + repeated ParticipantLabel labelInfo = 15; // 标签信息 + repeated QueuePhyInfo queueInfo = 16; // 队列信息 + int64 id = 17; // id } // NodePhyInfo 节点信息 message NodePhyInfo { int64 id = 1; - string nodeName = 2; //节点名称 - string osName = 3; //系统名称 - string osVersion = 4; //系统版本 - string archType = 5; //架构类型 - string archName = 6; //架构名称 - string archFreq = 7; //架构频率 + string nodeName = 2; // 节点名称 + string osName = 3; // 系统名称 + string osVersion = 4; // 系统版本 + string archType = 5; // 架构类型 + string archName = 6; // 架构名称 + string archFreq = 7; // 架构频率 +} + +// QueuePhyInfo 队列信息 +message QueuePhyInfo { + int64 id = 1; // id + string queueName=2; //队列名称 + int64 queNodes = 3; // 队列节点总数 + int64 queMinNodect = 4; // 队列最小节点数 + int64 queMaxNgpus = 5; // 队列最大GPU卡数 + int64 queMaxPpn = 6; // 使用该队列作业最大CPU核心数 + string queChargeRate = 7; // 费率 + int64 queMaxNcpus = 8; // 用户最大可用核心数 + int64 queMaxNdcus = 9; // 队列总DCU卡数 + int64 queMinNcpus = 10; // 队列最小CPU核数 + int64 queFreeNodes = 11; // 队列空闲节点数 + int64 queMaxNodect = 12; // 队列作业最大节点数 + int64 queMaxGpuPN = 13; // 队列单作业最大GPU卡数 + string queMaxWalltime = 14; // 队列最大运行时间 + int64 queMaxDcuPN = 15; // 队列单作业最大DCU卡数 } // ParticipantHeartbeatReq 心跳请求 -message ParticipantHeartbeatReq{ - int64 participantId = 1; //participantId - string host = 2; //host - string port = 3; //port +message ParticipantHeartbeatReq { + int64 participantId = 1; // participantId + string host = 2; // host + string port = 3; // port } // ParticipantAvailInfo Participant可用信息 -message ParticipantAvailReq{ - int64 id = 1; //id - int64 availStorageSpace = 2; //集群存储可用空间 - int64 userNum = 3; //用户数量 - int64 pendingJobNum = 4; //待处理作业数量 - int64 runningJobNum = 5; //运行作业数量 - int64 participantId = 6; //集群静态信息id - repeated NodeAvailInfo nodeAvailInfo = 7; //节点可用信息 +message ParticipantAvailReq { + int64 id = 1; // id + int64 availStorageSpace = 2; // 集群存储可用空间 + int64 userNum = 3; // 用户数量 + int64 pendingJobNum = 4; // 待处理作业数量 + int64 runningJobNum = 5; // 运行作业数量 + int64 participantId = 6; // 集群静态信息id + repeated NodeAvailInfo nodeAvailInfo = 7; // 节点可用信息 } // NodeAvailInfo 节点可用信息 -message NodeAvailInfo{ - int64 id = 1; //id - string nodeName = 2; //节点名称 - int64 cpuTotal = 3; //cpu核数 - double cpuUsable = 4; //cpu可用率 - int64 diskTotal = 5; //磁盘空间 - int64 diskAvail = 6; //磁盘可用空间 - int64 memTotal = 7; //内存总数 - int64 memAvail = 8; //内存可用数 - int64 gpuTotal = 9; //gpu总数 - int64 gpuAvail = 10; //gpu可用数 - int64 participantAvailId = 11; //集群动态信息id +message NodeAvailInfo { + int64 id = 1; // id + string nodeName = 2; // 节点名称 + int64 cpuTotal = 3; // cpu核数 + double cpuUsable = 4; // cpu可用率 + int64 diskTotal = 5; // 磁盘空间 + int64 diskAvail = 6; // 磁盘可用空间 + int64 memTotal = 7; // 内存总数 + int64 memAvail = 8; // 内存可用数 + int64 gpuTotal = 9; // gpu总数 + int64 gpuAvail = 10; // gpu可用数 + int64 participantAvailId = 11; // 集群动态信息id } // 集群可用信息 -message ListParticipantAvailResp{ +message ListParticipantAvailResp { int64 code = 1; string msg = 2; - repeated ParticipantAvailReq ParticipantAvails=3; + repeated ParticipantAvailReq ParticipantAvails = 3; } -message ParticipantResp{ +message ParticipantResp { int64 code = 1; string msg = 2; } @@ -212,30 +231,30 @@ message ParticipantServiceResp { repeated ClientInfo data = 3; } -message ClientInfo{ - string host = 1; // @gotags: redis:"host" - string port = 2; // @gotags: redis:"port" - int64 participantId = 3; // @gotags: redis:"participantId" +message ClientInfo { + string host = 1; // @gotags: redis:"host" + string port = 2; // @gotags: redis:"port" + int64 participantId = 3; // @gotags: redis:"participantId" } // participant 参与者 service participantService { // registerParticipant Participant注册接口 - rpc registerParticipant (ParticipantPhyReq) returns (ParticipantPhyResp) {}; + rpc registerParticipant(ParticipantPhyReq) returns (ParticipantPhyResp) {}; // reportHeartbeat 心跳请求 - rpc reportHeartbeat (ParticipantHeartbeatReq) returns (HealthCheckResp) {}; + rpc reportHeartbeat(ParticipantHeartbeatReq) returns (HealthCheckResp) {}; // reportAvailable 监控数据上报 - rpc reportAvailable (ParticipantAvailReq) returns(ParticipantResp){} + rpc reportAvailable(ParticipantAvailReq) returns (ParticipantResp) {} // listParticipant 服务列表 - rpc listParticipant (ParticipantTenant) returns(ParticipantServiceResp){} + rpc listParticipant(ParticipantTenant) returns (ParticipantServiceResp) {} // listAvailable 集群动态信息列表 - rpc listPhyAvailable (ParticipantTenant) returns(ListParticipantAvailResp){} + rpc listPhyAvailable(ParticipantTenant) returns (ListParticipantAvailResp) {} // listPhyInformation 集群静态信息列表 - rpc listPhyInformation (ParticipantTenant) returns (ListParticipantPhyResp) {}; + rpc listPhyInformation(ParticipantTenant) returns (ListParticipantPhyResp) {}; } \ No newline at end of file diff --git a/rpc/pcmCore/pcmCore.pb.go b/rpc/pcmCore/pcmCore.pb.go index c3b5fc24..f9f2e317 100644 --- a/rpc/pcmCore/pcmCore.pb.go +++ b/rpc/pcmCore/pcmCore.pb.go @@ -812,7 +812,7 @@ type ParticipantTenant struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - TenantName string `protobuf:"bytes,1,opt,name=tenantName,proto3" json:"tenantName,omitempty"` //租户名称 + TenantName string `protobuf:"bytes,1,opt,name=tenantName,proto3" json:"tenantName,omitempty"` // 租户名称 } func (x *ParticipantTenant) Reset() { @@ -860,9 +860,9 @@ type ParticipantLabel struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` //id - Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` //标签名 - Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` //标签值 + Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // id + Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` // 标签名 + Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` // 标签值 } func (x *ParticipantLabel) Reset() { @@ -988,7 +988,7 @@ type ParticipantPhyResp struct { Code int64 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` - ParticipantId int64 `protobuf:"varint,3,opt,name=participantId,proto3" json:"participantId,omitempty"` //participant 唯一标识 + ParticipantId int64 `protobuf:"varint,3,opt,name=participantId,proto3" json:"participantId,omitempty"` // participant 唯一标识 } func (x *ParticipantPhyResp) Reset() { @@ -1114,22 +1114,23 @@ type ParticipantPhyReq struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` //名称 - Host string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"` //host - Port string `protobuf:"bytes,3,opt,name=port,proto3" json:"port,omitempty"` //端口号 - NetworkType string `protobuf:"bytes,4,opt,name=networkType,proto3" json:"networkType,omitempty"` //集群网络类型 - NetworkBandwidth string `protobuf:"bytes,5,opt,name=networkBandwidth,proto3" json:"networkBandwidth,omitempty"` //集群网络带宽 - StorageType string `protobuf:"bytes,6,opt,name=storageType,proto3" json:"storageType,omitempty"` //集群存储类型 - StorageSpace string `protobuf:"bytes,7,opt,name=storageSpace,proto3" json:"storageSpace,omitempty"` //集群存储空间 - StorageAvailSpace string `protobuf:"bytes,8,opt,name=storageAvailSpace,proto3" json:"storageAvailSpace,omitempty"` //集群存储可用空间 - StorageBandwidth string `protobuf:"bytes,9,opt,name=storageBandwidth,proto3" json:"storageBandwidth,omitempty"` //集群存储带宽 - Type string `protobuf:"bytes,10,opt,name=type,proto3" json:"type,omitempty"` //参与者类型:0-数算集群;1-智算集群;2-超算集群 - TenantId int64 `protobuf:"varint,11,opt,name=tenantId,proto3" json:"tenantId,omitempty"` //租户id - TenantName string `protobuf:"bytes,12,opt,name=tenantName,proto3" json:"tenantName,omitempty"` //租户名称 - NodeInfo []*NodePhyInfo `protobuf:"bytes,13,rep,name=nodeInfo,proto3" json:"nodeInfo,omitempty"` //节点信息 - ParticipantId int64 `protobuf:"varint,14,opt,name=participantId,proto3" json:"participantId,omitempty"` //participant id - LabelInfo []*ParticipantLabel `protobuf:"bytes,15,rep,name=labelInfo,proto3" json:"labelInfo,omitempty"` //标签信息 - Id int64 `protobuf:"varint,16,opt,name=id,proto3" json:"id,omitempty"` //id + Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // 名称 + Host string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"` // host + Port string `protobuf:"bytes,3,opt,name=port,proto3" json:"port,omitempty"` // 端口号 + NetworkType string `protobuf:"bytes,4,opt,name=networkType,proto3" json:"networkType,omitempty"` // 集群网络类型 + NetworkBandwidth string `protobuf:"bytes,5,opt,name=networkBandwidth,proto3" json:"networkBandwidth,omitempty"` // 集群网络带宽 + StorageType string `protobuf:"bytes,6,opt,name=storageType,proto3" json:"storageType,omitempty"` // 集群存储类型 + StorageSpace string `protobuf:"bytes,7,opt,name=storageSpace,proto3" json:"storageSpace,omitempty"` // 集群存储空间 + StorageAvailSpace string `protobuf:"bytes,8,opt,name=storageAvailSpace,proto3" json:"storageAvailSpace,omitempty"` // 集群存储可用空间 + StorageBandwidth string `protobuf:"bytes,9,opt,name=storageBandwidth,proto3" json:"storageBandwidth,omitempty"` // 集群存储带宽 + Type string `protobuf:"bytes,10,opt,name=type,proto3" json:"type,omitempty"` // 参与者类型:0-数算集群;1-智算集群;2-超算集群 + TenantId int64 `protobuf:"varint,11,opt,name=tenantId,proto3" json:"tenantId,omitempty"` // 租户id + TenantName string `protobuf:"bytes,12,opt,name=tenantName,proto3" json:"tenantName,omitempty"` // 租户名称 + NodeInfo []*NodePhyInfo `protobuf:"bytes,13,rep,name=nodeInfo,proto3" json:"nodeInfo,omitempty"` // 节点信息 + ParticipantId int64 `protobuf:"varint,14,opt,name=participantId,proto3" json:"participantId,omitempty"` // participant id + LabelInfo []*ParticipantLabel `protobuf:"bytes,15,rep,name=labelInfo,proto3" json:"labelInfo,omitempty"` // 标签信息 + QueueInfo []*QueuePhyInfo `protobuf:"bytes,16,rep,name=queueInfo,proto3" json:"queueInfo,omitempty"` // 队列信息 + Id int64 `protobuf:"varint,17,opt,name=id,proto3" json:"id,omitempty"` // id } func (x *ParticipantPhyReq) Reset() { @@ -1269,6 +1270,13 @@ func (x *ParticipantPhyReq) GetLabelInfo() []*ParticipantLabel { return nil } +func (x *ParticipantPhyReq) GetQueueInfo() []*QueuePhyInfo { + if x != nil { + return x.QueueInfo + } + return nil +} + func (x *ParticipantPhyReq) GetId() int64 { if x != nil { return x.Id @@ -1283,12 +1291,12 @@ type NodePhyInfo struct { unknownFields protoimpl.UnknownFields Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` - NodeName string `protobuf:"bytes,2,opt,name=nodeName,proto3" json:"nodeName,omitempty"` //节点名称 - OsName string `protobuf:"bytes,3,opt,name=osName,proto3" json:"osName,omitempty"` //系统名称 - OsVersion string `protobuf:"bytes,4,opt,name=osVersion,proto3" json:"osVersion,omitempty"` //系统版本 - ArchType string `protobuf:"bytes,5,opt,name=archType,proto3" json:"archType,omitempty"` //架构类型 - ArchName string `protobuf:"bytes,6,opt,name=archName,proto3" json:"archName,omitempty"` //架构名称 - ArchFreq string `protobuf:"bytes,7,opt,name=archFreq,proto3" json:"archFreq,omitempty"` //架构频率 + NodeName string `protobuf:"bytes,2,opt,name=nodeName,proto3" json:"nodeName,omitempty"` // 节点名称 + OsName string `protobuf:"bytes,3,opt,name=osName,proto3" json:"osName,omitempty"` // 系统名称 + OsVersion string `protobuf:"bytes,4,opt,name=osVersion,proto3" json:"osVersion,omitempty"` // 系统版本 + ArchType string `protobuf:"bytes,5,opt,name=archType,proto3" json:"archType,omitempty"` // 架构类型 + ArchName string `protobuf:"bytes,6,opt,name=archName,proto3" json:"archName,omitempty"` // 架构名称 + ArchFreq string `protobuf:"bytes,7,opt,name=archFreq,proto3" json:"archFreq,omitempty"` // 架构频率 } func (x *NodePhyInfo) Reset() { @@ -1372,21 +1380,181 @@ func (x *NodePhyInfo) GetArchFreq() string { return "" } +// QueuePhyInfo 队列信息 +type QueuePhyInfo struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // id + QueueName string `protobuf:"bytes,2,opt,name=queueName,proto3" json:"queueName,omitempty"` //队列名称 + QueNodes int64 `protobuf:"varint,3,opt,name=queNodes,proto3" json:"queNodes,omitempty"` // 队列节点总数 + QueMinNodect int64 `protobuf:"varint,4,opt,name=queMinNodect,proto3" json:"queMinNodect,omitempty"` // 队列最小节点数 + QueMaxNgpus int64 `protobuf:"varint,5,opt,name=queMaxNgpus,proto3" json:"queMaxNgpus,omitempty"` // 队列最大GPU卡数 + QueMaxPpn int64 `protobuf:"varint,6,opt,name=queMaxPpn,proto3" json:"queMaxPpn,omitempty"` // 使用该队列作业最大CPU核心数 + QueChargeRate string `protobuf:"bytes,7,opt,name=queChargeRate,proto3" json:"queChargeRate,omitempty"` // 费率 + QueMaxNcpus int64 `protobuf:"varint,8,opt,name=queMaxNcpus,proto3" json:"queMaxNcpus,omitempty"` // 用户最大可用核心数 + QueMaxNdcus int64 `protobuf:"varint,9,opt,name=queMaxNdcus,proto3" json:"queMaxNdcus,omitempty"` // 队列总DCU卡数 + QueMinNcpus int64 `protobuf:"varint,10,opt,name=queMinNcpus,proto3" json:"queMinNcpus,omitempty"` // 队列最小CPU核数 + QueFreeNodes int64 `protobuf:"varint,11,opt,name=queFreeNodes,proto3" json:"queFreeNodes,omitempty"` // 队列空闲节点数 + QueMaxNodect int64 `protobuf:"varint,12,opt,name=queMaxNodect,proto3" json:"queMaxNodect,omitempty"` // 队列作业最大节点数 + QueMaxGpuPN int64 `protobuf:"varint,13,opt,name=queMaxGpuPN,proto3" json:"queMaxGpuPN,omitempty"` // 队列单作业最大GPU卡数 + QueMaxWalltime string `protobuf:"bytes,14,opt,name=queMaxWalltime,proto3" json:"queMaxWalltime,omitempty"` // 队列最大运行时间 + QueMaxDcuPN int64 `protobuf:"varint,15,opt,name=queMaxDcuPN,proto3" json:"queMaxDcuPN,omitempty"` // 队列单作业最大DCU卡数 +} + +func (x *QueuePhyInfo) Reset() { + *x = QueuePhyInfo{} + if protoimpl.UnsafeEnabled { + mi := &file_pb_pcmCore_proto_msgTypes[14] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *QueuePhyInfo) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*QueuePhyInfo) ProtoMessage() {} + +func (x *QueuePhyInfo) ProtoReflect() protoreflect.Message { + mi := &file_pb_pcmCore_proto_msgTypes[14] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use QueuePhyInfo.ProtoReflect.Descriptor instead. +func (*QueuePhyInfo) Descriptor() ([]byte, []int) { + return file_pb_pcmCore_proto_rawDescGZIP(), []int{14} +} + +func (x *QueuePhyInfo) GetId() int64 { + if x != nil { + return x.Id + } + return 0 +} + +func (x *QueuePhyInfo) GetQueueName() string { + if x != nil { + return x.QueueName + } + return "" +} + +func (x *QueuePhyInfo) GetQueNodes() int64 { + if x != nil { + return x.QueNodes + } + return 0 +} + +func (x *QueuePhyInfo) GetQueMinNodect() int64 { + if x != nil { + return x.QueMinNodect + } + return 0 +} + +func (x *QueuePhyInfo) GetQueMaxNgpus() int64 { + if x != nil { + return x.QueMaxNgpus + } + return 0 +} + +func (x *QueuePhyInfo) GetQueMaxPpn() int64 { + if x != nil { + return x.QueMaxPpn + } + return 0 +} + +func (x *QueuePhyInfo) GetQueChargeRate() string { + if x != nil { + return x.QueChargeRate + } + return "" +} + +func (x *QueuePhyInfo) GetQueMaxNcpus() int64 { + if x != nil { + return x.QueMaxNcpus + } + return 0 +} + +func (x *QueuePhyInfo) GetQueMaxNdcus() int64 { + if x != nil { + return x.QueMaxNdcus + } + return 0 +} + +func (x *QueuePhyInfo) GetQueMinNcpus() int64 { + if x != nil { + return x.QueMinNcpus + } + return 0 +} + +func (x *QueuePhyInfo) GetQueFreeNodes() int64 { + if x != nil { + return x.QueFreeNodes + } + return 0 +} + +func (x *QueuePhyInfo) GetQueMaxNodect() int64 { + if x != nil { + return x.QueMaxNodect + } + return 0 +} + +func (x *QueuePhyInfo) GetQueMaxGpuPN() int64 { + if x != nil { + return x.QueMaxGpuPN + } + return 0 +} + +func (x *QueuePhyInfo) GetQueMaxWalltime() string { + if x != nil { + return x.QueMaxWalltime + } + return "" +} + +func (x *QueuePhyInfo) GetQueMaxDcuPN() int64 { + if x != nil { + return x.QueMaxDcuPN + } + return 0 +} + // ParticipantHeartbeatReq 心跳请求 type ParticipantHeartbeatReq struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - ParticipantId int64 `protobuf:"varint,1,opt,name=participantId,proto3" json:"participantId,omitempty"` //participantId - Host string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"` //host - Port string `protobuf:"bytes,3,opt,name=port,proto3" json:"port,omitempty"` //port + ParticipantId int64 `protobuf:"varint,1,opt,name=participantId,proto3" json:"participantId,omitempty"` // participantId + Host string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"` // host + Port string `protobuf:"bytes,3,opt,name=port,proto3" json:"port,omitempty"` // port } func (x *ParticipantHeartbeatReq) Reset() { *x = ParticipantHeartbeatReq{} if protoimpl.UnsafeEnabled { - mi := &file_pb_pcmCore_proto_msgTypes[14] + mi := &file_pb_pcmCore_proto_msgTypes[15] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1399,7 +1567,7 @@ func (x *ParticipantHeartbeatReq) String() string { func (*ParticipantHeartbeatReq) ProtoMessage() {} func (x *ParticipantHeartbeatReq) ProtoReflect() protoreflect.Message { - mi := &file_pb_pcmCore_proto_msgTypes[14] + mi := &file_pb_pcmCore_proto_msgTypes[15] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1412,7 +1580,7 @@ func (x *ParticipantHeartbeatReq) ProtoReflect() protoreflect.Message { // Deprecated: Use ParticipantHeartbeatReq.ProtoReflect.Descriptor instead. func (*ParticipantHeartbeatReq) Descriptor() ([]byte, []int) { - return file_pb_pcmCore_proto_rawDescGZIP(), []int{14} + return file_pb_pcmCore_proto_rawDescGZIP(), []int{15} } func (x *ParticipantHeartbeatReq) GetParticipantId() int64 { @@ -1442,19 +1610,19 @@ type ParticipantAvailReq struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` //id - AvailStorageSpace int64 `protobuf:"varint,2,opt,name=availStorageSpace,proto3" json:"availStorageSpace,omitempty"` //集群存储可用空间 - UserNum int64 `protobuf:"varint,3,opt,name=userNum,proto3" json:"userNum,omitempty"` //用户数量 - PendingJobNum int64 `protobuf:"varint,4,opt,name=pendingJobNum,proto3" json:"pendingJobNum,omitempty"` //待处理作业数量 - RunningJobNum int64 `protobuf:"varint,5,opt,name=runningJobNum,proto3" json:"runningJobNum,omitempty"` //运行作业数量 - ParticipantId int64 `protobuf:"varint,6,opt,name=participantId,proto3" json:"participantId,omitempty"` //集群静态信息id - NodeAvailInfo []*NodeAvailInfo `protobuf:"bytes,7,rep,name=nodeAvailInfo,proto3" json:"nodeAvailInfo,omitempty"` //节点可用信息 + Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // id + AvailStorageSpace int64 `protobuf:"varint,2,opt,name=availStorageSpace,proto3" json:"availStorageSpace,omitempty"` // 集群存储可用空间 + UserNum int64 `protobuf:"varint,3,opt,name=userNum,proto3" json:"userNum,omitempty"` // 用户数量 + PendingJobNum int64 `protobuf:"varint,4,opt,name=pendingJobNum,proto3" json:"pendingJobNum,omitempty"` // 待处理作业数量 + RunningJobNum int64 `protobuf:"varint,5,opt,name=runningJobNum,proto3" json:"runningJobNum,omitempty"` // 运行作业数量 + ParticipantId int64 `protobuf:"varint,6,opt,name=participantId,proto3" json:"participantId,omitempty"` // 集群静态信息id + NodeAvailInfo []*NodeAvailInfo `protobuf:"bytes,7,rep,name=nodeAvailInfo,proto3" json:"nodeAvailInfo,omitempty"` // 节点可用信息 } func (x *ParticipantAvailReq) Reset() { *x = ParticipantAvailReq{} if protoimpl.UnsafeEnabled { - mi := &file_pb_pcmCore_proto_msgTypes[15] + mi := &file_pb_pcmCore_proto_msgTypes[16] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1467,7 +1635,7 @@ func (x *ParticipantAvailReq) String() string { func (*ParticipantAvailReq) ProtoMessage() {} func (x *ParticipantAvailReq) ProtoReflect() protoreflect.Message { - mi := &file_pb_pcmCore_proto_msgTypes[15] + mi := &file_pb_pcmCore_proto_msgTypes[16] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1480,7 +1648,7 @@ func (x *ParticipantAvailReq) ProtoReflect() protoreflect.Message { // Deprecated: Use ParticipantAvailReq.ProtoReflect.Descriptor instead. func (*ParticipantAvailReq) Descriptor() ([]byte, []int) { - return file_pb_pcmCore_proto_rawDescGZIP(), []int{15} + return file_pb_pcmCore_proto_rawDescGZIP(), []int{16} } func (x *ParticipantAvailReq) GetId() int64 { @@ -1538,23 +1706,23 @@ 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可用数 + ParticipantAvailId int64 `protobuf:"varint,11,opt,name=participantAvailId,proto3" json:"participantAvailId,omitempty"` // 集群动态信息id } func (x *NodeAvailInfo) Reset() { *x = NodeAvailInfo{} if protoimpl.UnsafeEnabled { - mi := &file_pb_pcmCore_proto_msgTypes[16] + mi := &file_pb_pcmCore_proto_msgTypes[17] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1567,7 +1735,7 @@ func (x *NodeAvailInfo) String() string { func (*NodeAvailInfo) ProtoMessage() {} func (x *NodeAvailInfo) ProtoReflect() protoreflect.Message { - mi := &file_pb_pcmCore_proto_msgTypes[16] + mi := &file_pb_pcmCore_proto_msgTypes[17] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1580,7 +1748,7 @@ func (x *NodeAvailInfo) ProtoReflect() protoreflect.Message { // Deprecated: Use NodeAvailInfo.ProtoReflect.Descriptor instead. func (*NodeAvailInfo) Descriptor() ([]byte, []int) { - return file_pb_pcmCore_proto_rawDescGZIP(), []int{16} + return file_pb_pcmCore_proto_rawDescGZIP(), []int{17} } func (x *NodeAvailInfo) GetId() int64 { @@ -1674,7 +1842,7 @@ type ListParticipantAvailResp struct { func (x *ListParticipantAvailResp) Reset() { *x = ListParticipantAvailResp{} if protoimpl.UnsafeEnabled { - mi := &file_pb_pcmCore_proto_msgTypes[17] + mi := &file_pb_pcmCore_proto_msgTypes[18] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1687,7 +1855,7 @@ func (x *ListParticipantAvailResp) String() string { func (*ListParticipantAvailResp) ProtoMessage() {} func (x *ListParticipantAvailResp) ProtoReflect() protoreflect.Message { - mi := &file_pb_pcmCore_proto_msgTypes[17] + mi := &file_pb_pcmCore_proto_msgTypes[18] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1700,7 +1868,7 @@ func (x *ListParticipantAvailResp) ProtoReflect() protoreflect.Message { // Deprecated: Use ListParticipantAvailResp.ProtoReflect.Descriptor instead. func (*ListParticipantAvailResp) Descriptor() ([]byte, []int) { - return file_pb_pcmCore_proto_rawDescGZIP(), []int{17} + return file_pb_pcmCore_proto_rawDescGZIP(), []int{18} } func (x *ListParticipantAvailResp) GetCode() int64 { @@ -1736,7 +1904,7 @@ type ParticipantResp struct { func (x *ParticipantResp) Reset() { *x = ParticipantResp{} if protoimpl.UnsafeEnabled { - mi := &file_pb_pcmCore_proto_msgTypes[18] + mi := &file_pb_pcmCore_proto_msgTypes[19] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1749,7 +1917,7 @@ func (x *ParticipantResp) String() string { func (*ParticipantResp) ProtoMessage() {} func (x *ParticipantResp) ProtoReflect() protoreflect.Message { - mi := &file_pb_pcmCore_proto_msgTypes[18] + mi := &file_pb_pcmCore_proto_msgTypes[19] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1762,7 +1930,7 @@ func (x *ParticipantResp) ProtoReflect() protoreflect.Message { // Deprecated: Use ParticipantResp.ProtoReflect.Descriptor instead. func (*ParticipantResp) Descriptor() ([]byte, []int) { - return file_pb_pcmCore_proto_rawDescGZIP(), []int{18} + return file_pb_pcmCore_proto_rawDescGZIP(), []int{19} } func (x *ParticipantResp) GetCode() int64 { @@ -1792,7 +1960,7 @@ type ParticipantServiceResp struct { func (x *ParticipantServiceResp) Reset() { *x = ParticipantServiceResp{} if protoimpl.UnsafeEnabled { - mi := &file_pb_pcmCore_proto_msgTypes[19] + mi := &file_pb_pcmCore_proto_msgTypes[20] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1805,7 +1973,7 @@ func (x *ParticipantServiceResp) String() string { func (*ParticipantServiceResp) ProtoMessage() {} func (x *ParticipantServiceResp) ProtoReflect() protoreflect.Message { - mi := &file_pb_pcmCore_proto_msgTypes[19] + mi := &file_pb_pcmCore_proto_msgTypes[20] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1818,7 +1986,7 @@ func (x *ParticipantServiceResp) ProtoReflect() protoreflect.Message { // Deprecated: Use ParticipantServiceResp.ProtoReflect.Descriptor instead. func (*ParticipantServiceResp) Descriptor() ([]byte, []int) { - return file_pb_pcmCore_proto_rawDescGZIP(), []int{19} + return file_pb_pcmCore_proto_rawDescGZIP(), []int{20} } func (x *ParticipantServiceResp) GetCode() int64 { @@ -1855,7 +2023,7 @@ type ClientInfo struct { func (x *ClientInfo) Reset() { *x = ClientInfo{} if protoimpl.UnsafeEnabled { - mi := &file_pb_pcmCore_proto_msgTypes[20] + mi := &file_pb_pcmCore_proto_msgTypes[21] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1868,7 +2036,7 @@ func (x *ClientInfo) String() string { func (*ClientInfo) ProtoMessage() {} func (x *ClientInfo) ProtoReflect() protoreflect.Message { - mi := &file_pb_pcmCore_proto_msgTypes[20] + mi := &file_pb_pcmCore_proto_msgTypes[21] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1881,7 +2049,7 @@ func (x *ClientInfo) ProtoReflect() protoreflect.Message { // Deprecated: Use ClientInfo.ProtoReflect.Descriptor instead. func (*ClientInfo) Descriptor() ([]byte, []int) { - return file_pb_pcmCore_proto_rawDescGZIP(), []int{20} + return file_pb_pcmCore_proto_rawDescGZIP(), []int{21} } func (x *ClientInfo) GetHost() string { @@ -2056,7 +2224,7 @@ var file_pb_pcmCore_proto_rawDesc = []byte{ 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 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, 0x52, 0x0f, 0x50, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, - 0x50, 0x68, 0x79, 0x73, 0x22, 0xae, 0x04, 0x0a, 0x11, 0x50, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, + 0x50, 0x68, 0x79, 0x73, 0x22, 0xe3, 0x04, 0x0a, 0x11, 0x50, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x50, 0x68, 0x79, 0x52, 0x65, 0x71, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x68, 0x6f, 0x73, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x68, 0x6f, @@ -2090,135 +2258,171 @@ var file_pb_pcmCore_proto_rawDesc = []byte{ 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x49, 0x6e, 0x66, 0x6f, 0x18, 0x0f, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x2e, 0x50, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x52, 0x09, 0x6c, 0x61, 0x62, 0x65, - 0x6c, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x10, 0x20, 0x01, 0x28, - 0x03, 0x52, 0x02, 0x69, 0x64, 0x22, 0xc3, 0x01, 0x0a, 0x0b, 0x4e, 0x6f, 0x64, 0x65, 0x50, 0x68, - 0x79, 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, 0x4e, 0x61, 0x6d, - 0x65, 0x12, 0x16, 0x0a, 0x06, 0x6f, 0x73, 0x4e, 0x61, 0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, - 0x09, 0x52, 0x06, 0x6f, 0x73, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x6f, 0x73, 0x56, - 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x6f, 0x73, - 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x1a, 0x0a, 0x08, 0x61, 0x72, 0x63, 0x68, 0x54, - 0x79, 0x70, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x61, 0x72, 0x63, 0x68, 0x54, - 0x79, 0x70, 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x61, 0x72, 0x63, 0x68, 0x4e, 0x61, 0x6d, 0x65, 0x18, - 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x61, 0x72, 0x63, 0x68, 0x4e, 0x61, 0x6d, 0x65, 0x12, - 0x1a, 0x0a, 0x08, 0x61, 0x72, 0x63, 0x68, 0x46, 0x72, 0x65, 0x71, 0x18, 0x07, 0x20, 0x01, 0x28, - 0x09, 0x52, 0x08, 0x61, 0x72, 0x63, 0x68, 0x46, 0x72, 0x65, 0x71, 0x22, 0x67, 0x0a, 0x17, 0x50, - 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x48, 0x65, 0x61, 0x72, 0x74, 0x62, - 0x65, 0x61, 0x74, 0x52, 0x65, 0x71, 0x12, 0x24, 0x0a, 0x0d, 0x70, 0x61, 0x72, 0x74, 0x69, 0x63, - 0x69, 0x70, 0x61, 0x6e, 0x74, 0x49, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0d, 0x70, - 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x49, 0x64, 0x12, 0x12, 0x0a, 0x04, - 0x68, 0x6f, 0x73, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x68, 0x6f, 0x73, 0x74, - 0x12, 0x12, 0x0a, 0x04, 0x70, 0x6f, 0x72, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, - 0x70, 0x6f, 0x72, 0x74, 0x22, 0x9d, 0x02, 0x0a, 0x13, 0x50, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, - 0x70, 0x61, 0x6e, 0x74, 0x41, 0x76, 0x61, 0x69, 0x6c, 0x52, 0x65, 0x71, 0x12, 0x0e, 0x0a, 0x02, - 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x02, 0x69, 0x64, 0x12, 0x2c, 0x0a, 0x11, - 0x61, 0x76, 0x61, 0x69, 0x6c, 0x53, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x53, 0x70, 0x61, 0x63, - 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x11, 0x61, 0x76, 0x61, 0x69, 0x6c, 0x53, 0x74, - 0x6f, 0x72, 0x61, 0x67, 0x65, 0x53, 0x70, 0x61, 0x63, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x75, 0x73, - 0x65, 0x72, 0x4e, 0x75, 0x6d, 0x18, 0x03, 0x20, 0x01, 0x28, 0x03, 0x52, 0x07, 0x75, 0x73, 0x65, - 0x72, 0x4e, 0x75, 0x6d, 0x12, 0x24, 0x0a, 0x0d, 0x70, 0x65, 0x6e, 0x64, 0x69, 0x6e, 0x67, 0x4a, - 0x6f, 0x62, 0x4e, 0x75, 0x6d, 0x18, 0x04, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0d, 0x70, 0x65, 0x6e, - 0x64, 0x69, 0x6e, 0x67, 0x4a, 0x6f, 0x62, 0x4e, 0x75, 0x6d, 0x12, 0x24, 0x0a, 0x0d, 0x72, 0x75, - 0x6e, 0x6e, 0x69, 0x6e, 0x67, 0x4a, 0x6f, 0x62, 0x4e, 0x75, 0x6d, 0x18, 0x05, 0x20, 0x01, 0x28, - 0x03, 0x52, 0x0d, 0x72, 0x75, 0x6e, 0x6e, 0x69, 0x6e, 0x67, 0x4a, 0x6f, 0x62, 0x4e, 0x75, 0x6d, - 0x12, 0x24, 0x0a, 0x0d, 0x70, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x49, - 0x64, 0x18, 0x06, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0d, 0x70, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, - 0x70, 0x61, 0x6e, 0x74, 0x49, 0x64, 0x12, 0x3c, 0x0a, 0x0d, 0x6e, 0x6f, 0x64, 0x65, 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, 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, 0x4e, 0x61, - 0x6d, 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x63, 0x70, 0x75, 0x54, 0x6f, 0x74, 0x61, 0x6c, 0x18, 0x03, - 0x20, 0x01, 0x28, 0x03, 0x52, 0x08, 0x63, 0x70, 0x75, 0x54, 0x6f, 0x74, 0x61, 0x6c, 0x12, 0x1c, - 0x0a, 0x09, 0x63, 0x70, 0x75, 0x55, 0x73, 0x61, 0x62, 0x6c, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, - 0x01, 0x52, 0x09, 0x63, 0x70, 0x75, 0x55, 0x73, 0x61, 0x62, 0x6c, 0x65, 0x12, 0x1c, 0x0a, 0x09, - 0x64, 0x69, 0x73, 0x6b, 0x54, 0x6f, 0x74, 0x61, 0x6c, 0x18, 0x05, 0x20, 0x01, 0x28, 0x03, 0x52, - 0x09, 0x64, 0x69, 0x73, 0x6b, 0x54, 0x6f, 0x74, 0x61, 0x6c, 0x12, 0x1c, 0x0a, 0x09, 0x64, 0x69, - 0x73, 0x6b, 0x41, 0x76, 0x61, 0x69, 0x6c, 0x18, 0x06, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x64, - 0x69, 0x73, 0x6b, 0x41, 0x76, 0x61, 0x69, 0x6c, 0x12, 0x1a, 0x0a, 0x08, 0x6d, 0x65, 0x6d, 0x54, - 0x6f, 0x74, 0x61, 0x6c, 0x18, 0x07, 0x20, 0x01, 0x28, 0x03, 0x52, 0x08, 0x6d, 0x65, 0x6d, 0x54, - 0x6f, 0x74, 0x61, 0x6c, 0x12, 0x1a, 0x0a, 0x08, 0x6d, 0x65, 0x6d, 0x41, 0x76, 0x61, 0x69, 0x6c, - 0x18, 0x08, 0x20, 0x01, 0x28, 0x03, 0x52, 0x08, 0x6d, 0x65, 0x6d, 0x41, 0x76, 0x61, 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, 0x5a, 0x0a, 0x0a, 0x43, 0x6c, 0x69, - 0x65, 0x6e, 0x74, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x12, 0x0a, 0x04, 0x68, 0x6f, 0x73, 0x74, 0x18, - 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x68, 0x6f, 0x73, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x70, - 0x6f, 0x72, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x70, 0x6f, 0x72, 0x74, 0x12, - 0x24, 0x0a, 0x0d, 0x70, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x49, 0x64, - 0x18, 0x03, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0d, 0x70, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, - 0x61, 0x6e, 0x74, 0x49, 0x64, 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, + 0x6c, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x33, 0x0a, 0x09, 0x71, 0x75, 0x65, 0x75, 0x65, 0x49, 0x6e, + 0x66, 0x6f, 0x18, 0x10, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x15, 0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f, + 0x72, 0x65, 0x2e, 0x51, 0x75, 0x65, 0x75, 0x65, 0x50, 0x68, 0x79, 0x49, 0x6e, 0x66, 0x6f, 0x52, + 0x09, 0x71, 0x75, 0x65, 0x75, 0x65, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, + 0x18, 0x11, 0x20, 0x01, 0x28, 0x03, 0x52, 0x02, 0x69, 0x64, 0x22, 0xc3, 0x01, 0x0a, 0x0b, 0x4e, + 0x6f, 0x64, 0x65, 0x50, 0x68, 0x79, 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, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x6f, 0x73, 0x4e, 0x61, 0x6d, 0x65, + 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x6f, 0x73, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x1c, + 0x0a, 0x09, 0x6f, 0x73, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28, + 0x09, 0x52, 0x09, 0x6f, 0x73, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x1a, 0x0a, 0x08, + 0x61, 0x72, 0x63, 0x68, 0x54, 0x79, 0x70, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, + 0x61, 0x72, 0x63, 0x68, 0x54, 0x79, 0x70, 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x61, 0x72, 0x63, 0x68, + 0x4e, 0x61, 0x6d, 0x65, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x61, 0x72, 0x63, 0x68, + 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x61, 0x72, 0x63, 0x68, 0x46, 0x72, 0x65, 0x71, + 0x18, 0x07, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x61, 0x72, 0x63, 0x68, 0x46, 0x72, 0x65, 0x71, + 0x22, 0xfc, 0x03, 0x0a, 0x0c, 0x51, 0x75, 0x65, 0x75, 0x65, 0x50, 0x68, 0x79, 0x49, 0x6e, 0x66, + 0x6f, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x02, 0x69, + 0x64, 0x12, 0x1c, 0x0a, 0x09, 0x71, 0x75, 0x65, 0x75, 0x65, 0x4e, 0x61, 0x6d, 0x65, 0x18, 0x02, + 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x71, 0x75, 0x65, 0x75, 0x65, 0x4e, 0x61, 0x6d, 0x65, 0x12, + 0x1a, 0x0a, 0x08, 0x71, 0x75, 0x65, 0x4e, 0x6f, 0x64, 0x65, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, + 0x03, 0x52, 0x08, 0x71, 0x75, 0x65, 0x4e, 0x6f, 0x64, 0x65, 0x73, 0x12, 0x22, 0x0a, 0x0c, 0x71, + 0x75, 0x65, 0x4d, 0x69, 0x6e, 0x4e, 0x6f, 0x64, 0x65, 0x63, 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, + 0x03, 0x52, 0x0c, 0x71, 0x75, 0x65, 0x4d, 0x69, 0x6e, 0x4e, 0x6f, 0x64, 0x65, 0x63, 0x74, 0x12, + 0x20, 0x0a, 0x0b, 0x71, 0x75, 0x65, 0x4d, 0x61, 0x78, 0x4e, 0x67, 0x70, 0x75, 0x73, 0x18, 0x05, + 0x20, 0x01, 0x28, 0x03, 0x52, 0x0b, 0x71, 0x75, 0x65, 0x4d, 0x61, 0x78, 0x4e, 0x67, 0x70, 0x75, + 0x73, 0x12, 0x1c, 0x0a, 0x09, 0x71, 0x75, 0x65, 0x4d, 0x61, 0x78, 0x50, 0x70, 0x6e, 0x18, 0x06, + 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x71, 0x75, 0x65, 0x4d, 0x61, 0x78, 0x50, 0x70, 0x6e, 0x12, + 0x24, 0x0a, 0x0d, 0x71, 0x75, 0x65, 0x43, 0x68, 0x61, 0x72, 0x67, 0x65, 0x52, 0x61, 0x74, 0x65, + 0x18, 0x07, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x71, 0x75, 0x65, 0x43, 0x68, 0x61, 0x72, 0x67, + 0x65, 0x52, 0x61, 0x74, 0x65, 0x12, 0x20, 0x0a, 0x0b, 0x71, 0x75, 0x65, 0x4d, 0x61, 0x78, 0x4e, + 0x63, 0x70, 0x75, 0x73, 0x18, 0x08, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0b, 0x71, 0x75, 0x65, 0x4d, + 0x61, 0x78, 0x4e, 0x63, 0x70, 0x75, 0x73, 0x12, 0x20, 0x0a, 0x0b, 0x71, 0x75, 0x65, 0x4d, 0x61, + 0x78, 0x4e, 0x64, 0x63, 0x75, 0x73, 0x18, 0x09, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0b, 0x71, 0x75, + 0x65, 0x4d, 0x61, 0x78, 0x4e, 0x64, 0x63, 0x75, 0x73, 0x12, 0x20, 0x0a, 0x0b, 0x71, 0x75, 0x65, + 0x4d, 0x69, 0x6e, 0x4e, 0x63, 0x70, 0x75, 0x73, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0b, + 0x71, 0x75, 0x65, 0x4d, 0x69, 0x6e, 0x4e, 0x63, 0x70, 0x75, 0x73, 0x12, 0x22, 0x0a, 0x0c, 0x71, + 0x75, 0x65, 0x46, 0x72, 0x65, 0x65, 0x4e, 0x6f, 0x64, 0x65, 0x73, 0x18, 0x0b, 0x20, 0x01, 0x28, + 0x03, 0x52, 0x0c, 0x71, 0x75, 0x65, 0x46, 0x72, 0x65, 0x65, 0x4e, 0x6f, 0x64, 0x65, 0x73, 0x12, + 0x22, 0x0a, 0x0c, 0x71, 0x75, 0x65, 0x4d, 0x61, 0x78, 0x4e, 0x6f, 0x64, 0x65, 0x63, 0x74, 0x18, + 0x0c, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0c, 0x71, 0x75, 0x65, 0x4d, 0x61, 0x78, 0x4e, 0x6f, 0x64, + 0x65, 0x63, 0x74, 0x12, 0x20, 0x0a, 0x0b, 0x71, 0x75, 0x65, 0x4d, 0x61, 0x78, 0x47, 0x70, 0x75, + 0x50, 0x4e, 0x18, 0x0d, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0b, 0x71, 0x75, 0x65, 0x4d, 0x61, 0x78, + 0x47, 0x70, 0x75, 0x50, 0x4e, 0x12, 0x26, 0x0a, 0x0e, 0x71, 0x75, 0x65, 0x4d, 0x61, 0x78, 0x57, + 0x61, 0x6c, 0x6c, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x0e, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0e, 0x71, + 0x75, 0x65, 0x4d, 0x61, 0x78, 0x57, 0x61, 0x6c, 0x6c, 0x74, 0x69, 0x6d, 0x65, 0x12, 0x20, 0x0a, + 0x0b, 0x71, 0x75, 0x65, 0x4d, 0x61, 0x78, 0x44, 0x63, 0x75, 0x50, 0x4e, 0x18, 0x0f, 0x20, 0x01, + 0x28, 0x03, 0x52, 0x0b, 0x71, 0x75, 0x65, 0x4d, 0x61, 0x78, 0x44, 0x63, 0x75, 0x50, 0x4e, 0x22, + 0x67, 0x0a, 0x17, 0x50, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x48, 0x65, + 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x52, 0x65, 0x71, 0x12, 0x24, 0x0a, 0x0d, 0x70, 0x61, + 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x49, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, + 0x03, 0x52, 0x0d, 0x70, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x49, 0x64, + 0x12, 0x12, 0x0a, 0x04, 0x68, 0x6f, 0x73, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, + 0x68, 0x6f, 0x73, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x70, 0x6f, 0x72, 0x74, 0x18, 0x03, 0x20, 0x01, + 0x28, 0x09, 0x52, 0x04, 0x70, 0x6f, 0x72, 0x74, 0x22, 0x9d, 0x02, 0x0a, 0x13, 0x50, 0x61, 0x72, + 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x41, 0x76, 0x61, 0x69, 0x6c, 0x52, 0x65, 0x71, + 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x02, 0x69, 0x64, + 0x12, 0x2c, 0x0a, 0x11, 0x61, 0x76, 0x61, 0x69, 0x6c, 0x53, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, + 0x53, 0x70, 0x61, 0x63, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x11, 0x61, 0x76, 0x61, + 0x69, 0x6c, 0x53, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x53, 0x70, 0x61, 0x63, 0x65, 0x12, 0x18, + 0x0a, 0x07, 0x75, 0x73, 0x65, 0x72, 0x4e, 0x75, 0x6d, 0x18, 0x03, 0x20, 0x01, 0x28, 0x03, 0x52, + 0x07, 0x75, 0x73, 0x65, 0x72, 0x4e, 0x75, 0x6d, 0x12, 0x24, 0x0a, 0x0d, 0x70, 0x65, 0x6e, 0x64, + 0x69, 0x6e, 0x67, 0x4a, 0x6f, 0x62, 0x4e, 0x75, 0x6d, 0x18, 0x04, 0x20, 0x01, 0x28, 0x03, 0x52, + 0x0d, 0x70, 0x65, 0x6e, 0x64, 0x69, 0x6e, 0x67, 0x4a, 0x6f, 0x62, 0x4e, 0x75, 0x6d, 0x12, 0x24, + 0x0a, 0x0d, 0x72, 0x75, 0x6e, 0x6e, 0x69, 0x6e, 0x67, 0x4a, 0x6f, 0x62, 0x4e, 0x75, 0x6d, 0x18, + 0x05, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0d, 0x72, 0x75, 0x6e, 0x6e, 0x69, 0x6e, 0x67, 0x4a, 0x6f, + 0x62, 0x4e, 0x75, 0x6d, 0x12, 0x24, 0x0a, 0x0d, 0x70, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, + 0x61, 0x6e, 0x74, 0x49, 0x64, 0x18, 0x06, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0d, 0x70, 0x61, 0x72, + 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x49, 0x64, 0x12, 0x3c, 0x0a, 0x0d, 0x6e, 0x6f, + 0x64, 0x65, 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, 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, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x63, 0x70, 0x75, 0x54, 0x6f, 0x74, + 0x61, 0x6c, 0x18, 0x03, 0x20, 0x01, 0x28, 0x03, 0x52, 0x08, 0x63, 0x70, 0x75, 0x54, 0x6f, 0x74, + 0x61, 0x6c, 0x12, 0x1c, 0x0a, 0x09, 0x63, 0x70, 0x75, 0x55, 0x73, 0x61, 0x62, 0x6c, 0x65, 0x18, + 0x04, 0x20, 0x01, 0x28, 0x01, 0x52, 0x09, 0x63, 0x70, 0x75, 0x55, 0x73, 0x61, 0x62, 0x6c, 0x65, + 0x12, 0x1c, 0x0a, 0x09, 0x64, 0x69, 0x73, 0x6b, 0x54, 0x6f, 0x74, 0x61, 0x6c, 0x18, 0x05, 0x20, + 0x01, 0x28, 0x03, 0x52, 0x09, 0x64, 0x69, 0x73, 0x6b, 0x54, 0x6f, 0x74, 0x61, 0x6c, 0x12, 0x1c, + 0x0a, 0x09, 0x64, 0x69, 0x73, 0x6b, 0x41, 0x76, 0x61, 0x69, 0x6c, 0x18, 0x06, 0x20, 0x01, 0x28, + 0x03, 0x52, 0x09, 0x64, 0x69, 0x73, 0x6b, 0x41, 0x76, 0x61, 0x69, 0x6c, 0x12, 0x1a, 0x0a, 0x08, + 0x6d, 0x65, 0x6d, 0x54, 0x6f, 0x74, 0x61, 0x6c, 0x18, 0x07, 0x20, 0x01, 0x28, 0x03, 0x52, 0x08, + 0x6d, 0x65, 0x6d, 0x54, 0x6f, 0x74, 0x61, 0x6c, 0x12, 0x1a, 0x0a, 0x08, 0x6d, 0x65, 0x6d, 0x41, + 0x76, 0x61, 0x69, 0x6c, 0x18, 0x08, 0x20, 0x01, 0x28, 0x03, 0x52, 0x08, 0x6d, 0x65, 0x6d, 0x41, + 0x76, 0x61, 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, 0x5a, 0x0a, + 0x0a, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x12, 0x0a, 0x04, 0x68, + 0x6f, 0x73, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x68, 0x6f, 0x73, 0x74, 0x12, + 0x12, 0x0a, 0x04, 0x70, 0x6f, 0x72, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x70, + 0x6f, 0x72, 0x74, 0x12, 0x24, 0x0a, 0x0d, 0x70, 0x61, 0x72, 0x74, 0x69, 0x63, 0x69, 0x70, 0x61, + 0x6e, 0x74, 0x49, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0d, 0x70, 0x61, 0x72, 0x74, + 0x69, 0x63, 0x69, 0x70, 0x61, 0x6e, 0x74, 0x49, 0x64, 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, - 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, 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, + 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, 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 ( @@ -2234,7 +2438,7 @@ func file_pb_pcmCore_proto_rawDescGZIP() []byte { } var file_pb_pcmCore_proto_enumTypes = make([]protoimpl.EnumInfo, 1) -var file_pb_pcmCore_proto_msgTypes = make([]protoimpl.MessageInfo, 21) +var file_pb_pcmCore_proto_msgTypes = make([]protoimpl.MessageInfo, 22) var file_pb_pcmCore_proto_goTypes = []interface{}{ (MessageStatus)(0), // 0: pcmCore.MessageStatus (*SyncInfoReq)(nil), // 1: pcmCore.SyncInfoReq @@ -2251,13 +2455,14 @@ var file_pb_pcmCore_proto_goTypes = []interface{}{ (*ListParticipantPhyResp)(nil), // 12: pcmCore.ListParticipantPhyResp (*ParticipantPhyReq)(nil), // 13: pcmCore.ParticipantPhyReq (*NodePhyInfo)(nil), // 14: pcmCore.NodePhyInfo - (*ParticipantHeartbeatReq)(nil), // 15: pcmCore.ParticipantHeartbeatReq - (*ParticipantAvailReq)(nil), // 16: pcmCore.ParticipantAvailReq - (*NodeAvailInfo)(nil), // 17: pcmCore.NodeAvailInfo - (*ListParticipantAvailResp)(nil), // 18: pcmCore.ListParticipantAvailResp - (*ParticipantResp)(nil), // 19: pcmCore.ParticipantResp - (*ParticipantServiceResp)(nil), // 20: pcmCore.ParticipantServiceResp - (*ClientInfo)(nil), // 21: pcmCore.ClientInfo + (*QueuePhyInfo)(nil), // 15: pcmCore.QueuePhyInfo + (*ParticipantHeartbeatReq)(nil), // 16: pcmCore.ParticipantHeartbeatReq + (*ParticipantAvailReq)(nil), // 17: pcmCore.ParticipantAvailReq + (*NodeAvailInfo)(nil), // 18: pcmCore.NodeAvailInfo + (*ListParticipantAvailResp)(nil), // 19: pcmCore.ListParticipantAvailResp + (*ParticipantResp)(nil), // 20: pcmCore.ParticipantResp + (*ParticipantServiceResp)(nil), // 21: pcmCore.ParticipantServiceResp + (*ClientInfo)(nil), // 22: pcmCore.ClientInfo } var file_pb_pcmCore_proto_depIdxs = []int32{ 4, // 0: pcmCore.SyncInfoReq.HpcInfoList:type_name -> pcmCore.HpcInfo @@ -2270,30 +2475,31 @@ var file_pb_pcmCore_proto_depIdxs = []int32{ 13, // 7: pcmCore.ListParticipantPhyResp.ParticipantPhys:type_name -> pcmCore.ParticipantPhyReq 14, // 8: pcmCore.ParticipantPhyReq.nodeInfo:type_name -> pcmCore.NodePhyInfo 9, // 9: pcmCore.ParticipantPhyReq.labelInfo:type_name -> pcmCore.ParticipantLabel - 17, // 10: pcmCore.ParticipantAvailReq.nodeAvailInfo:type_name -> pcmCore.NodeAvailInfo - 16, // 11: pcmCore.ListParticipantAvailResp.ParticipantAvails:type_name -> pcmCore.ParticipantAvailReq - 21, // 12: pcmCore.ParticipantServiceResp.data:type_name -> pcmCore.ClientInfo - 1, // 13: pcmCore.pcmCore.SyncInfo:input_type -> pcmCore.SyncInfoReq - 6, // 14: pcmCore.pcmCore.InfoList:input_type -> pcmCore.InfoListReq - 13, // 15: pcmCore.participantService.registerParticipant:input_type -> pcmCore.ParticipantPhyReq - 15, // 16: pcmCore.participantService.reportHeartbeat:input_type -> pcmCore.ParticipantHeartbeatReq - 16, // 17: pcmCore.participantService.reportAvailable:input_type -> pcmCore.ParticipantAvailReq - 8, // 18: pcmCore.participantService.listParticipant:input_type -> pcmCore.ParticipantTenant - 8, // 19: pcmCore.participantService.listPhyAvailable:input_type -> pcmCore.ParticipantTenant - 8, // 20: pcmCore.participantService.listPhyInformation:input_type -> pcmCore.ParticipantTenant - 5, // 21: pcmCore.pcmCore.SyncInfo:output_type -> pcmCore.SyncInfoResp - 7, // 22: pcmCore.pcmCore.InfoList:output_type -> pcmCore.InfoListResp - 11, // 23: pcmCore.participantService.registerParticipant:output_type -> pcmCore.ParticipantPhyResp - 10, // 24: pcmCore.participantService.reportHeartbeat:output_type -> pcmCore.HealthCheckResp - 19, // 25: pcmCore.participantService.reportAvailable:output_type -> pcmCore.ParticipantResp - 20, // 26: pcmCore.participantService.listParticipant:output_type -> pcmCore.ParticipantServiceResp - 18, // 27: pcmCore.participantService.listPhyAvailable:output_type -> pcmCore.ListParticipantAvailResp - 12, // 28: pcmCore.participantService.listPhyInformation:output_type -> pcmCore.ListParticipantPhyResp - 21, // [21:29] is the sub-list for method output_type - 13, // [13:21] is the sub-list for method input_type - 13, // [13:13] is the sub-list for extension type_name - 13, // [13:13] is the sub-list for extension extendee - 0, // [0:13] is the sub-list for field type_name + 15, // 10: pcmCore.ParticipantPhyReq.queueInfo:type_name -> pcmCore.QueuePhyInfo + 18, // 11: pcmCore.ParticipantAvailReq.nodeAvailInfo:type_name -> pcmCore.NodeAvailInfo + 17, // 12: pcmCore.ListParticipantAvailResp.ParticipantAvails:type_name -> pcmCore.ParticipantAvailReq + 22, // 13: pcmCore.ParticipantServiceResp.data:type_name -> pcmCore.ClientInfo + 1, // 14: pcmCore.pcmCore.SyncInfo:input_type -> pcmCore.SyncInfoReq + 6, // 15: pcmCore.pcmCore.InfoList:input_type -> pcmCore.InfoListReq + 13, // 16: pcmCore.participantService.registerParticipant:input_type -> pcmCore.ParticipantPhyReq + 16, // 17: pcmCore.participantService.reportHeartbeat:input_type -> pcmCore.ParticipantHeartbeatReq + 17, // 18: pcmCore.participantService.reportAvailable:input_type -> pcmCore.ParticipantAvailReq + 8, // 19: pcmCore.participantService.listParticipant:input_type -> pcmCore.ParticipantTenant + 8, // 20: pcmCore.participantService.listPhyAvailable:input_type -> pcmCore.ParticipantTenant + 8, // 21: pcmCore.participantService.listPhyInformation:input_type -> pcmCore.ParticipantTenant + 5, // 22: pcmCore.pcmCore.SyncInfo:output_type -> pcmCore.SyncInfoResp + 7, // 23: pcmCore.pcmCore.InfoList:output_type -> pcmCore.InfoListResp + 11, // 24: pcmCore.participantService.registerParticipant:output_type -> pcmCore.ParticipantPhyResp + 10, // 25: pcmCore.participantService.reportHeartbeat:output_type -> pcmCore.HealthCheckResp + 20, // 26: pcmCore.participantService.reportAvailable:output_type -> pcmCore.ParticipantResp + 21, // 27: pcmCore.participantService.listParticipant:output_type -> pcmCore.ParticipantServiceResp + 19, // 28: pcmCore.participantService.listPhyAvailable:output_type -> pcmCore.ListParticipantAvailResp + 12, // 29: pcmCore.participantService.listPhyInformation:output_type -> pcmCore.ListParticipantPhyResp + 22, // [22:30] is the sub-list for method output_type + 14, // [14:22] is the sub-list for method input_type + 14, // [14:14] is the sub-list for extension type_name + 14, // [14:14] is the sub-list for extension extendee + 0, // [0:14] is the sub-list for field type_name } func init() { file_pb_pcmCore_proto_init() } @@ -2471,7 +2677,7 @@ func file_pb_pcmCore_proto_init() { } } file_pb_pcmCore_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ParticipantHeartbeatReq); i { + switch v := v.(*QueuePhyInfo); i { case 0: return &v.state case 1: @@ -2483,7 +2689,7 @@ func file_pb_pcmCore_proto_init() { } } file_pb_pcmCore_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ParticipantAvailReq); i { + switch v := v.(*ParticipantHeartbeatReq); i { case 0: return &v.state case 1: @@ -2495,7 +2701,7 @@ func file_pb_pcmCore_proto_init() { } } file_pb_pcmCore_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*NodeAvailInfo); i { + switch v := v.(*ParticipantAvailReq); i { case 0: return &v.state case 1: @@ -2507,7 +2713,7 @@ func file_pb_pcmCore_proto_init() { } } file_pb_pcmCore_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ListParticipantAvailResp); i { + switch v := v.(*NodeAvailInfo); i { case 0: return &v.state case 1: @@ -2519,7 +2725,7 @@ func file_pb_pcmCore_proto_init() { } } file_pb_pcmCore_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ParticipantResp); i { + switch v := v.(*ListParticipantAvailResp); i { case 0: return &v.state case 1: @@ -2531,7 +2737,7 @@ func file_pb_pcmCore_proto_init() { } } file_pb_pcmCore_proto_msgTypes[19].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ParticipantServiceResp); i { + switch v := v.(*ParticipantResp); i { case 0: return &v.state case 1: @@ -2543,6 +2749,18 @@ func file_pb_pcmCore_proto_init() { } } file_pb_pcmCore_proto_msgTypes[20].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*ParticipantServiceResp); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_pb_pcmCore_proto_msgTypes[21].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*ClientInfo); i { case 0: return &v.state @@ -2561,7 +2779,7 @@ func file_pb_pcmCore_proto_init() { GoPackagePath: reflect.TypeOf(x{}).PkgPath(), RawDescriptor: file_pb_pcmCore_proto_rawDesc, NumEnums: 1, - NumMessages: 21, + NumMessages: 22, NumExtensions: 0, NumServices: 2, },