JCCE
/
PCM
28
0
Fork 8
Code Issues Pull Requests Projects Releases Wiki Activity

SyncInfo接口开发

This commit is contained in:
zw 2023-03-29 09:23:23 +08:00
parent 4c588d923d
commit 4cfd9cd37f
9 changed files with 333 additions and 138 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
adaptor/PCM-CORE/model/hpcmodel_gen.go
View File

@ -42,6 +42,8 @@ type (
TaskId sql.NullInt64 `db:"task_id"` // 任务id
JobId sql.NullString `db:"job_id"` // 作业id
ServiceName sql.NullString `db:"service_name"` // 服务名称
Name sql.NullString `db:"name"` // 名称
Status sql.NullString `db:"status"` // 状态
StartTime sql.NullString `db:"start_time"` // 开始时间
RunningTime sql.NullInt64 `db:"running_time"` // 运行时间
CardCount sql.NullInt64 `db:"card_count"` // 卡数
@ -89,8 +91,8 @@ func (m *defaultHpcModel) FindOne(ctx context.Context, id int64) (*Hpc, error) {
func (m *defaultHpcModel) Insert(ctx context.Context, data *Hpc) (sql.Result, error) {
pcmHpcIdKey := fmt.Sprintf("%s%v", cachePcmHpcIdPrefix, 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, hpcRowsExpectAutoSet)
return conn.ExecCtx(ctx, query, data.TaskId, data.JobId, data.ServiceName, data.StartTime, data.RunningTime, data.CardCount, data.CreatedBy, data.CreatedTime, data.UpdatedBy, data.UpdatedTime, data.DeletedFlag)
query := fmt.Sprintf("insert into %s (%s) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)", m.table, hpcRowsExpectAutoSet)
return conn.ExecCtx(ctx, query, data.TaskId, data.JobId, data.ServiceName, data.Name, data.Status, data.StartTime, data.RunningTime, data.CardCount, data.CreatedBy, data.CreatedTime, data.UpdatedBy, data.UpdatedTime, data.DeletedFlag)
}, pcmHpcIdKey)
return ret, err
}
@ -99,7 +101,7 @@ func (m *defaultHpcModel) Update(ctx context.Context, data *Hpc) error {
pcmHpcIdKey := fmt.Sprintf("%s%v", cachePcmHpcIdPrefix, 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, hpcRowsWithPlaceHolder)
return conn.ExecCtx(ctx, query, data.TaskId, data.JobId, data.ServiceName, data.StartTime, data.RunningTime, data.CardCount, data.CreatedBy, data.CreatedTime, data.UpdatedBy, data.UpdatedTime, data.DeletedFlag, data.Id)
return conn.ExecCtx(ctx, query, data.TaskId, data.JobId, data.ServiceName, data.Name, data.Status, data.StartTime, data.RunningTime, data.CardCount, data.CreatedBy, data.CreatedTime, data.UpdatedBy, data.UpdatedTime, data.DeletedFlag, data.Id)
}, pcmHpcIdKey)
return err
}

5
adaptor/PCM-CORE/rpc/etc/pcmcore.yaml
View File

@ -4,3 +4,8 @@ Etcd:
Hosts:
- 10.101.15.170:31890
Key: pcmcore.rpc
User: root
Pass: I9wLvrRufj
DB:
DataSource: root:uJpLd6u-J?HC1@(106.53.150.192:3306)/pcm?parseTime=true

35
adaptor/PCM-CORE/rpc/internal/logic/infolistlogic.go
View File

@ -1,11 +1,10 @@
package logic
import (
"context"
"fmt"
"PCM/adaptor/PCM-CORE/rpc/internal/svc"
"PCM/adaptor/PCM-CORE/rpc/pcmCore"
result2 "PCM/common/result"
"context"
"github.com/zeromicro/go-zero/core/logx"
)
@ -26,19 +25,37 @@ func NewInfoListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *InfoList
// InfoList
func (l *InfoListLogic) InfoList(in *pcmCore.InfoListReq) (*pcmCore.InfoListResp, error) {
var result *pcmCore.InfoListResp
result := pcmCore.InfoListResp{}
// 查询任务id集合
taskRows, err := l.svcCtx.Db.Query("select id,kind from task where status not in ('Succeed','Completed')")
taskRows, err := l.svcCtx.Db.Query("select id,kind from task where status not in ('Succeed','Completed') and service_name = ?", in.ServiceName)
if err != nil {
return nil, err
logx.Error(err)
return nil, result2.NewDefaultError(err.Error())
}
for taskRows.Next() {
taskInfo := pcmCore.TaskInfo{}
taskRows.Scan(&taskInfo.TaskId, &taskInfo.Kind)
// 查询云智超中的数据列表
sql := fmt.Sprintf("select id from %s where status not in ('Succeed','Completed')", taskInfo.Kind)
l.svcCtx.Db.Query(sql)
var sql string
switch in.Kind {
case "hpc":
sql = "select name,job_id as externalField,status from hpc where status not in ('Succeed','Completed') and task_id = ?"
case "cloud":
sql = "select name,namespace as externalField,status from cloud where status not in ('Succeed','Completed') and task_id = ?"
case "ai":
sql = "select name,project_id as externalField,status from ai where status not in ('Succeed','Completed') and task_id = ?"
}
rows, err := l.svcCtx.Db.Query(sql, taskInfo.TaskId)
if err != nil {
logx.Error(err)
return nil, result2.NewDefaultError(err.Error())
}
for rows.Next() {
externalInfo := pcmCore.ExternalInfo{}
rows.Scan(&externalInfo.Name, &externalInfo.ExternalField, &externalInfo.Status)
taskInfo.ExternalInfoList = append(taskInfo.ExternalInfoList, &externalInfo)
}
result.TaskInfoList = append(result.TaskInfoList, &taskInfo)
}
return &pcmCore.InfoListResp{}, nil
return &result, nil
}

31
adaptor/PCM-CORE/rpc/internal/logic/syncinfologic.go
View File

@ -1,10 +1,11 @@
package logic
import (
"context"
"PCM/adaptor/PCM-CORE/model"
"PCM/adaptor/PCM-CORE/rpc/internal/svc"
"PCM/adaptor/PCM-CORE/rpc/pcmCore"
"context"
"fmt"
"github.com/zeromicro/go-zero/core/logx"
)
@ -25,7 +26,31 @@ func NewSyncInfoLogic(ctx context.Context, svcCtx *svc.ServiceContext) *SyncInfo
// SyncInfo Synchronous data information
func (l *SyncInfoLogic) SyncInfo(in *pcmCore.SyncInfoReq) (*pcmCore.SyncInfoResp, error) {
// todo: add your logic here and delete this line
var tasks []model.Task
for _, info := range in.InfoList {
task := model.Task{
Id: info.TaskId,
StartTime: info.StartTime,
Status: info.Status,
RunningTime: info.RunningTime,
Result: info.Result,
}
tasks = append(tasks, task)
}
query := "INSERT INTO task (id, status,start_time,running_time,result) VALUES "
for i, t := range tasks {
if i > 0 {
query += ","
}
query += fmt.Sprintf("(%d,'%s', '%s', %d,'%s')", t.Id, t.Status, t.StartTime, t.RunningTime, t.Result)
}
query += " ON DUPLICATE KEY UPDATE status=VALUES(status),start_time=VALUES(start_time),running_time=VALUES(running_time),result=VALUES(result)"
_, err := l.svcCtx.Db.Exec(query)
if err != nil {
return nil, err
}
return &pcmCore.SyncInfoResp{}, nil
}

7
adaptor/PCM-CORE/rpc/internal/svc/servicecontext.go
View File

@ -2,16 +2,17 @@ package svc
import (
"PCM/adaptor/PCM-CORE/rpc/internal/config"
sql "github.com/jmoiron/sqlx"
_ "github.com/go-sql-driver/mysql"
"github.com/jmoiron/sqlx"
)
type ServiceContext struct {
Config config.Config
Db *sql.DB
Db *sqlx.DB
}
func NewServiceContext(c config.Config) *ServiceContext {
db, _ := sql.Open("mysql", c.DB.DataSource)
db, _ := sqlx.Open("mysql", c.DB.DataSource)
return &ServiceContext{
Config: c,
Db: db,

30
adaptor/PCM-CORE/rpc/pb/pcmCore.proto
View File

@ -8,20 +8,31 @@ message SyncInfoReq {
}
message Info {
string TaskId = 1;
string Status = 2;
string StartTime = 3;
int64 RunningTime = 4;
int64 taskId = 1;
string status = 2;
string startTime = 3;
string result = 4;
int64 runningTime = 5;
repeated LatestExternalInfo latestExternalInfoList = 6;
}
message LatestExternalInfo {
string externalField = 1;
string name = 2;
string status = 3;
string startTime = 4;
int64 runningTime = 5;
}
message SyncInfoResp{
int64 Code = 1;
string Msg = 2;
int64 code = 1;
string msg = 2;
}
message InfoListReq{
string Kind = 1;
string ServiceName = 2;
string kind = 1;
string serviceName = 2;
}
message InfoListResp{
@ -31,7 +42,8 @@ message InfoListResp{
message TaskInfo{
int64 taskId = 1;
string kind = 2;
repeated ExternalInfo ExternalInfoList = 3;
string yamlString = 3;
repeated ExternalInfo externalInfoList = 4;
}
message ExternalInfo {

325
adaptor/PCM-CORE/rpc/pcmCore/pcmCore.pb.go
View File

@ -1,6 +1,6 @@
// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// protoc-gen-go v1.30.0
// protoc-gen-go v1.28.1
// protoc v3.19.4
// source: pcmCore.proto
@ -72,10 +72,12 @@ type Info struct {
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
TaskId string `protobuf:"bytes,1,opt,name=TaskId,proto3" json:"TaskId,omitempty"`
Status string `protobuf:"bytes,2,opt,name=Status,proto3" json:"Status,omitempty"`
StartTime string `protobuf:"bytes,3,opt,name=StartTime,proto3" json:"StartTime,omitempty"`
RunningTime int64 `protobuf:"varint,4,opt,name=RunningTime,proto3" json:"RunningTime,omitempty"`
TaskId int64 `protobuf:"varint,1,opt,name=taskId,proto3" json:"taskId,omitempty"`
Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
StartTime string `protobuf:"bytes,3,opt,name=startTime,proto3" json:"startTime,omitempty"`
Result string `protobuf:"bytes,4,opt,name=result,proto3" json:"result,omitempty"`
RunningTime int64 `protobuf:"varint,5,opt,name=runningTime,proto3" json:"runningTime,omitempty"`
LatestExternalInfoList []*LatestExternalInfo `protobuf:"bytes,6,rep,name=latestExternalInfoList,proto3" json:"latestExternalInfoList,omitempty"`
}
func (x *Info) Reset() {
@ -110,11 +112,11 @@ func (*Info) Descriptor() ([]byte, []int) {
return file_pcmCore_proto_rawDescGZIP(), []int{1}
}
func (x *Info) GetTaskId() string {
func (x *Info) GetTaskId() int64 {
if x != nil {
return x.TaskId
}
return ""
return 0
}
func (x *Info) GetStatus() string {
@ -131,6 +133,13 @@ func (x *Info) GetStartTime() string {
return ""
}
func (x *Info) GetResult() string {
if x != nil {
return x.Result
}
return ""
}
func (x *Info) GetRunningTime() int64 {
if x != nil {
return x.RunningTime
@ -138,19 +147,105 @@ func (x *Info) GetRunningTime() int64 {
return 0
}
func (x *Info) GetLatestExternalInfoList() []*LatestExternalInfo {
if x != nil {
return x.LatestExternalInfoList
}
return nil
}
type LatestExternalInfo struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
ExternalField string `protobuf:"bytes,1,opt,name=externalField,proto3" json:"externalField,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Status string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
StartTime string `protobuf:"bytes,4,opt,name=startTime,proto3" json:"startTime,omitempty"`
RunningTime int64 `protobuf:"varint,5,opt,name=runningTime,proto3" json:"runningTime,omitempty"`
}
func (x *LatestExternalInfo) Reset() {
*x = LatestExternalInfo{}
if protoimpl.UnsafeEnabled {
mi := &file_pcmCore_proto_msgTypes[2]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *LatestExternalInfo) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*LatestExternalInfo) ProtoMessage() {}
func (x *LatestExternalInfo) ProtoReflect() protoreflect.Message {
mi := &file_pcmCore_proto_msgTypes[2]
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 LatestExternalInfo.ProtoReflect.Descriptor instead.
func (*LatestExternalInfo) Descriptor() ([]byte, []int) {
return file_pcmCore_proto_rawDescGZIP(), []int{2}
}
func (x *LatestExternalInfo) GetExternalField() string {
if x != nil {
return x.ExternalField
}
return ""
}
func (x *LatestExternalInfo) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *LatestExternalInfo) GetStatus() string {
if x != nil {
return x.Status
}
return ""
}
func (x *LatestExternalInfo) GetStartTime() string {
if x != nil {
return x.StartTime
}
return ""
}
func (x *LatestExternalInfo) GetRunningTime() int64 {
if x != nil {
return x.RunningTime
}
return 0
}
type SyncInfoResp struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Code int64 `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"`
Msg string `protobuf:"bytes,2,opt,name=Msg,proto3" json:"Msg,omitempty"`
Code int64 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
}
func (x *SyncInfoResp) Reset() {
*x = SyncInfoResp{}
if protoimpl.UnsafeEnabled {
mi := &file_pcmCore_proto_msgTypes[2]
mi := &file_pcmCore_proto_msgTypes[3]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@ -163,7 +258,7 @@ func (x *SyncInfoResp) String() string {
func (*SyncInfoResp) ProtoMessage() {}
func (x *SyncInfoResp) ProtoReflect() protoreflect.Message {
mi := &file_pcmCore_proto_msgTypes[2]
mi := &file_pcmCore_proto_msgTypes[3]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@ -176,7 +271,7 @@ func (x *SyncInfoResp) ProtoReflect() protoreflect.Message {
// Deprecated: Use SyncInfoResp.ProtoReflect.Descriptor instead.
func (*SyncInfoResp) Descriptor() ([]byte, []int) {
return file_pcmCore_proto_rawDescGZIP(), []int{2}
return file_pcmCore_proto_rawDescGZIP(), []int{3}
}
func (x *SyncInfoResp) GetCode() int64 {
@ -198,14 +293,14 @@ type InfoListReq struct {
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Kind string `protobuf:"bytes,1,opt,name=Kind,proto3" json:"Kind,omitempty"`
ServiceName string `protobuf:"bytes,2,opt,name=ServiceName,proto3" json:"ServiceName,omitempty"`
Kind string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
ServiceName string `protobuf:"bytes,2,opt,name=serviceName,proto3" json:"serviceName,omitempty"`
}
func (x *InfoListReq) Reset() {
*x = InfoListReq{}
if protoimpl.UnsafeEnabled {
mi := &file_pcmCore_proto_msgTypes[3]
mi := &file_pcmCore_proto_msgTypes[4]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@ -218,7 +313,7 @@ func (x *InfoListReq) String() string {
func (*InfoListReq) ProtoMessage() {}
func (x *InfoListReq) ProtoReflect() protoreflect.Message {
mi := &file_pcmCore_proto_msgTypes[3]
mi := &file_pcmCore_proto_msgTypes[4]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@ -231,7 +326,7 @@ func (x *InfoListReq) ProtoReflect() protoreflect.Message {
// Deprecated: Use InfoListReq.ProtoReflect.Descriptor instead.
func (*InfoListReq) Descriptor() ([]byte, []int) {
return file_pcmCore_proto_rawDescGZIP(), []int{3}
return file_pcmCore_proto_rawDescGZIP(), []int{4}
}
func (x *InfoListReq) GetKind() string {
@ -259,7 +354,7 @@ type InfoListResp struct {
func (x *InfoListResp) Reset() {
*x = InfoListResp{}
if protoimpl.UnsafeEnabled {
mi := &file_pcmCore_proto_msgTypes[4]
mi := &file_pcmCore_proto_msgTypes[5]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@ -272,7 +367,7 @@ func (x *InfoListResp) String() string {
func (*InfoListResp) ProtoMessage() {}
func (x *InfoListResp) ProtoReflect() protoreflect.Message {
mi := &file_pcmCore_proto_msgTypes[4]
mi := &file_pcmCore_proto_msgTypes[5]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@ -285,7 +380,7 @@ func (x *InfoListResp) ProtoReflect() protoreflect.Message {
// Deprecated: Use InfoListResp.ProtoReflect.Descriptor instead.
func (*InfoListResp) Descriptor() ([]byte, []int) {
return file_pcmCore_proto_rawDescGZIP(), []int{4}
return file_pcmCore_proto_rawDescGZIP(), []int{5}
}
func (x *InfoListResp) GetTaskInfoList() []*TaskInfo {
@ -302,13 +397,14 @@ type TaskInfo struct {
TaskId int64 `protobuf:"varint,1,opt,name=taskId,proto3" json:"taskId,omitempty"`
Kind string `protobuf:"bytes,2,opt,name=kind,proto3" json:"kind,omitempty"`
ExternalInfoList []*ExternalInfo `protobuf:"bytes,3,rep,name=ExternalInfoList,proto3" json:"ExternalInfoList,omitempty"`
YamlString string `protobuf:"bytes,3,opt,name=yamlString,proto3" json:"yamlString,omitempty"`
ExternalInfoList []*ExternalInfo `protobuf:"bytes,4,rep,name=externalInfoList,proto3" json:"externalInfoList,omitempty"`
}
func (x *TaskInfo) Reset() {
*x = TaskInfo{}
if protoimpl.UnsafeEnabled {
mi := &file_pcmCore_proto_msgTypes[5]
mi := &file_pcmCore_proto_msgTypes[6]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@ -321,7 +417,7 @@ func (x *TaskInfo) String() string {
func (*TaskInfo) ProtoMessage() {}
func (x *TaskInfo) ProtoReflect() protoreflect.Message {
mi := &file_pcmCore_proto_msgTypes[5]
mi := &file_pcmCore_proto_msgTypes[6]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@ -334,7 +430,7 @@ func (x *TaskInfo) ProtoReflect() protoreflect.Message {
// Deprecated: Use TaskInfo.ProtoReflect.Descriptor instead.
func (*TaskInfo) Descriptor() ([]byte, []int) {
return file_pcmCore_proto_rawDescGZIP(), []int{5}
return file_pcmCore_proto_rawDescGZIP(), []int{6}
}
func (x *TaskInfo) GetTaskId() int64 {
@ -351,6 +447,13 @@ func (x *TaskInfo) GetKind() string {
return ""
}
func (x *TaskInfo) GetYamlString() string {
if x != nil {
return x.YamlString
}
return ""
}
func (x *TaskInfo) GetExternalInfoList() []*ExternalInfo {
if x != nil {
return x.ExternalInfoList
@ -371,7 +474,7 @@ type ExternalInfo struct {
func (x *ExternalInfo) Reset() {
*x = ExternalInfo{}
if protoimpl.UnsafeEnabled {
mi := &file_pcmCore_proto_msgTypes[6]
mi := &file_pcmCore_proto_msgTypes[7]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@ -384,7 +487,7 @@ func (x *ExternalInfo) String() string {
func (*ExternalInfo) ProtoMessage() {}
func (x *ExternalInfo) ProtoReflect() protoreflect.Message {
mi := &file_pcmCore_proto_msgTypes[6]
mi := &file_pcmCore_proto_msgTypes[7]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@ -397,7 +500,7 @@ func (x *ExternalInfo) ProtoReflect() protoreflect.Message {
// Deprecated: Use ExternalInfo.ProtoReflect.Descriptor instead.
func (*ExternalInfo) Descriptor() ([]byte, []int) {
return file_pcmCore_proto_rawDescGZIP(), []int{6}
return file_pcmCore_proto_rawDescGZIP(), []int{7}
}
func (x *ExternalInfo) GetExternalField() string {
@ -429,49 +532,69 @@ var file_pcmCore_proto_rawDesc = []byte{
0x49, 0x6e, 0x66, 0x6f, 0x52, 0x65, 0x71, 0x12, 0x29, 0x0a, 0x08, 0x69, 0x6e, 0x66, 0x6f, 0x4c,
0x69, 0x73, 0x74, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x0d, 0x2e, 0x70, 0x63, 0x6d, 0x43,
0x6f, 0x72, 0x65, 0x2e, 0x49, 0x6e, 0x66, 0x6f, 0x52, 0x08, 0x69, 0x6e, 0x66, 0x6f, 0x4c, 0x69,
0x73, 0x74, 0x22, 0x76, 0x0a, 0x04, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x16, 0x0a, 0x06, 0x54, 0x61,
0x73, 0x6b, 0x49, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x54, 0x61, 0x73, 0x6b,
0x49, 0x64, 0x12, 0x16, 0x0a, 0x06, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x18, 0x02, 0x20, 0x01,
0x28, 0x09, 0x52, 0x06, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x1c, 0x0a, 0x09, 0x53, 0x74,
0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x53,
0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x20, 0x0a, 0x0b, 0x52, 0x75, 0x6e, 0x6e,
0x69, 0x6e, 0x67, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0b, 0x52,
0x75, 0x6e, 0x6e, 0x69, 0x6e, 0x67, 0x54, 0x69, 0x6d, 0x65, 0x22, 0x34, 0x0a, 0x0c, 0x53, 0x79,
0x6e, 0x63, 0x49, 0x6e, 0x66, 0x6f, 0x52, 0x65, 0x73, 0x70, 0x12, 0x12, 0x0a, 0x04, 0x43, 0x6f,
0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x04, 0x43, 0x6f, 0x64, 0x65, 0x12, 0x10,
0x0a, 0x03, 0x4d, 0x73, 0x67, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x4d, 0x73, 0x67,
0x22, 0x43, 0x0a, 0x0b, 0x49, 0x6e, 0x66, 0x6f, 0x4c, 0x69, 0x73, 0x74, 0x52, 0x65, 0x71, 0x12,
0x12, 0x0a, 0x04, 0x4b, 0x69, 0x6e, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x4b,
0x69, 0x6e, 0x64, 0x12, 0x20, 0x0a, 0x0b, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x4e, 0x61,
0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63,
0x65, 0x4e, 0x61, 0x6d, 0x65, 0x22, 0x45, 0x0a, 0x0c, 0x49, 0x6e, 0x66, 0x6f, 0x4c, 0x69, 0x73,
0x74, 0x52, 0x65, 0x73, 0x70, 0x12, 0x35, 0x0a, 0x0c, 0x74, 0x61, 0x73, 0x6b, 0x49, 0x6e, 0x66,
0x6f, 0x4c, 0x69, 0x73, 0x74, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x11, 0x2e, 0x70, 0x63,
0x6d, 0x43, 0x6f, 0x72, 0x65, 0x2e, 0x54, 0x61, 0x73, 0x6b, 0x49, 0x6e, 0x66, 0x6f, 0x52, 0x0c,
0x74, 0x61, 0x73, 0x6b, 0x49, 0x6e, 0x66, 0x6f, 0x4c, 0x69, 0x73, 0x74, 0x22, 0x79, 0x0a, 0x08,
0x54, 0x61, 0x73, 0x6b, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x16, 0x0a, 0x06, 0x74, 0x61, 0x73, 0x6b,
0x49, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x06, 0x74, 0x61, 0x73, 0x6b, 0x49, 0x64,
0x12, 0x12, 0x0a, 0x04, 0x6b, 0x69, 0x6e, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04,
0x6b, 0x69, 0x6e, 0x64, 0x12, 0x41, 0x0a, 0x10, 0x45, 0x78, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c,
0x49, 0x6e, 0x66, 0x6f, 0x4c, 0x69, 0x73, 0x74, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x15,
0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x2e, 0x45, 0x78, 0x74, 0x65, 0x72, 0x6e, 0x61,
0x6c, 0x49, 0x6e, 0x66, 0x6f, 0x52, 0x10, 0x45, 0x78, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x49,
0x6e, 0x66, 0x6f, 0x4c, 0x69, 0x73, 0x74, 0x22, 0x60, 0x0a, 0x0c, 0x45, 0x78, 0x74, 0x65, 0x72,
0x6e, 0x61, 0x6c, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x24, 0x0a, 0x0d, 0x65, 0x78, 0x74, 0x65, 0x72,
0x6e, 0x61, 0x6c, 0x46, 0x69, 0x65, 0x6c, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d,
0x65, 0x78, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x46, 0x69, 0x65, 0x6c, 0x64, 0x12, 0x12, 0x0a,
0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d,
0x65, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28,
0x09, 0x52, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 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, 0x42, 0x0a, 0x5a, 0x08, 0x2f, 0x70, 0x63, 0x6d, 0x43, 0x6f,
0x72, 0x65, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
0x73, 0x74, 0x22, 0xe3, 0x01, 0x0a, 0x04, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x16, 0x0a, 0x06, 0x74,
0x61, 0x73, 0x6b, 0x49, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x06, 0x74, 0x61, 0x73,
0x6b, 0x49, 0x64, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x18, 0x02, 0x20,
0x01, 0x28, 0x09, 0x52, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x1c, 0x0a, 0x09, 0x73,
0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09,
0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x72, 0x65, 0x73,
0x75, 0x6c, 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x72, 0x65, 0x73, 0x75, 0x6c,
0x74, 0x12, 0x20, 0x0a, 0x0b, 0x72, 0x75, 0x6e, 0x6e, 0x69, 0x6e, 0x67, 0x54, 0x69, 0x6d, 0x65,
0x18, 0x05, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0b, 0x72, 0x75, 0x6e, 0x6e, 0x69, 0x6e, 0x67, 0x54,
0x69, 0x6d, 0x65, 0x12, 0x53, 0x0a, 0x16, 0x6c, 0x61, 0x74, 0x65, 0x73, 0x74, 0x45, 0x78, 0x74,
0x65, 0x72, 0x6e, 0x61, 0x6c, 0x49, 0x6e, 0x66, 0x6f, 0x4c, 0x69, 0x73, 0x74, 0x18, 0x06, 0x20,
0x03, 0x28, 0x0b, 0x32, 0x1b, 0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x2e, 0x4c, 0x61,
0x74, 0x65, 0x73, 0x74, 0x45, 0x78, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x49, 0x6e, 0x66, 0x6f,
0x52, 0x16, 0x6c, 0x61, 0x74, 0x65, 0x73, 0x74, 0x45, 0x78, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c,
0x49, 0x6e, 0x66, 0x6f, 0x4c, 0x69, 0x73, 0x74, 0x22, 0xa6, 0x01, 0x0a, 0x12, 0x4c, 0x61, 0x74,
0x65, 0x73, 0x74, 0x45, 0x78, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x49, 0x6e, 0x66, 0x6f, 0x12,
0x24, 0x0a, 0x0d, 0x65, 0x78, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x46, 0x69, 0x65, 0x6c, 0x64,
0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x65, 0x78, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c,
0x46, 0x69, 0x65, 0x6c, 0x64, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20,
0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x74, 0x61,
0x74, 0x75, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75,
0x73, 0x12, 0x1c, 0x0a, 0x09, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x04,
0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x12,
0x20, 0x0a, 0x0b, 0x72, 0x75, 0x6e, 0x6e, 0x69, 0x6e, 0x67, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x05,
0x20, 0x01, 0x28, 0x03, 0x52, 0x0b, 0x72, 0x75, 0x6e, 0x6e, 0x69, 0x6e, 0x67, 0x54, 0x69, 0x6d,
0x65, 0x22, 0x34, 0x0a, 0x0c, 0x53, 0x79, 0x6e, 0x63, 0x49, 0x6e, 0x66, 0x6f, 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, 0x43, 0x0a, 0x0b, 0x49, 0x6e, 0x66, 0x6f, 0x4c,
0x69, 0x73, 0x74, 0x52, 0x65, 0x71, 0x12, 0x12, 0x0a, 0x04, 0x6b, 0x69, 0x6e, 0x64, 0x18, 0x01,
0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6b, 0x69, 0x6e, 0x64, 0x12, 0x20, 0x0a, 0x0b, 0x73, 0x65,
0x72, 0x76, 0x69, 0x63, 0x65, 0x4e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52,
0x0b, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x4e, 0x61, 0x6d, 0x65, 0x22, 0x45, 0x0a, 0x0c,
0x49, 0x6e, 0x66, 0x6f, 0x4c, 0x69, 0x73, 0x74, 0x52, 0x65, 0x73, 0x70, 0x12, 0x35, 0x0a, 0x0c,
0x74, 0x61, 0x73, 0x6b, 0x49, 0x6e, 0x66, 0x6f, 0x4c, 0x69, 0x73, 0x74, 0x18, 0x01, 0x20, 0x03,
0x28, 0x0b, 0x32, 0x11, 0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x2e, 0x54, 0x61, 0x73,
0x6b, 0x49, 0x6e, 0x66, 0x6f, 0x52, 0x0c, 0x74, 0x61, 0x73, 0x6b, 0x49, 0x6e, 0x66, 0x6f, 0x4c,
0x69, 0x73, 0x74, 0x22, 0x99, 0x01, 0x0a, 0x08, 0x54, 0x61, 0x73, 0x6b, 0x49, 0x6e, 0x66, 0x6f,
0x12, 0x16, 0x0a, 0x06, 0x74, 0x61, 0x73, 0x6b, 0x49, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03,
0x52, 0x06, 0x74, 0x61, 0x73, 0x6b, 0x49, 0x64, 0x12, 0x12, 0x0a, 0x04, 0x6b, 0x69, 0x6e, 0x64,
0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6b, 0x69, 0x6e, 0x64, 0x12, 0x1e, 0x0a, 0x0a,
0x79, 0x61, 0x6d, 0x6c, 0x53, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09,
0x52, 0x0a, 0x79, 0x61, 0x6d, 0x6c, 0x53, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x12, 0x41, 0x0a, 0x10,
0x65, 0x78, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x49, 0x6e, 0x66, 0x6f, 0x4c, 0x69, 0x73, 0x74,
0x18, 0x04, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x15, 0x2e, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65,
0x2e, 0x45, 0x78, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x49, 0x6e, 0x66, 0x6f, 0x52, 0x10, 0x65,
0x78, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x49, 0x6e, 0x66, 0x6f, 0x4c, 0x69, 0x73, 0x74, 0x22,
0x60, 0x0a, 0x0c, 0x45, 0x78, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x49, 0x6e, 0x66, 0x6f, 0x12,
0x24, 0x0a, 0x0d, 0x65, 0x78, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x46, 0x69, 0x65, 0x6c, 0x64,
0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x65, 0x78, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c,
0x46, 0x69, 0x65, 0x6c, 0x64, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20,
0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x74, 0x61,
0x74, 0x75, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75,
0x73, 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, 0x42, 0x0a,
0x5a, 0x08, 0x2f, 0x70, 0x63, 0x6d, 0x43, 0x6f, 0x72, 0x65, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74,
0x6f, 0x33,
}
var (
@ -486,29 +609,31 @@ func file_pcmCore_proto_rawDescGZIP() []byte {
return file_pcmCore_proto_rawDescData
}
var file_pcmCore_proto_msgTypes = make([]protoimpl.MessageInfo, 7)
var file_pcmCore_proto_msgTypes = make([]protoimpl.MessageInfo, 8)
var file_pcmCore_proto_goTypes = []interface{}{
(*SyncInfoReq)(nil), // 0: pcmCore.SyncInfoReq
(*Info)(nil), // 1: pcmCore.Info
(*SyncInfoResp)(nil), // 2: pcmCore.SyncInfoResp
(*InfoListReq)(nil), // 3: pcmCore.InfoListReq
(*InfoListResp)(nil), // 4: pcmCore.InfoListResp
(*TaskInfo)(nil), // 5: pcmCore.TaskInfo
(*ExternalInfo)(nil), // 6: pcmCore.ExternalInfo
(*SyncInfoReq)(nil), // 0: pcmCore.SyncInfoReq
(*Info)(nil), // 1: pcmCore.Info
(*LatestExternalInfo)(nil), // 2: pcmCore.LatestExternalInfo
(*SyncInfoResp)(nil), // 3: pcmCore.SyncInfoResp
(*InfoListReq)(nil), // 4: pcmCore.InfoListReq
(*InfoListResp)(nil), // 5: pcmCore.InfoListResp
(*TaskInfo)(nil), // 6: pcmCore.TaskInfo
(*ExternalInfo)(nil), // 7: pcmCore.ExternalInfo
}
var file_pcmCore_proto_depIdxs = []int32{
1, // 0: pcmCore.SyncInfoReq.infoList:type_name -> pcmCore.Info
5, // 1: pcmCore.InfoListResp.taskInfoList:type_name -> pcmCore.TaskInfo
6, // 2: pcmCore.TaskInfo.ExternalInfoList:type_name -> pcmCore.ExternalInfo
0, // 3: pcmCore.pcmCore.SyncInfo:input_type -> pcmCore.SyncInfoReq
3, // 4: pcmCore.pcmCore.InfoList:input_type -> pcmCore.InfoListReq
2, // 5: pcmCore.pcmCore.SyncInfo:output_type -> pcmCore.SyncInfoResp
4, // 6: pcmCore.pcmCore.InfoList:output_type -> pcmCore.InfoListResp
5, // [5:7] is the sub-list for method output_type
3, // [3:5] is the sub-list for method input_type
3, // [3:3] is the sub-list for extension type_name
3, // [3:3] is the sub-list for extension extendee
0, // [0:3] is the sub-list for field type_name
2, // 1: pcmCore.Info.latestExternalInfoList:type_name -> pcmCore.LatestExternalInfo
6, // 2: pcmCore.InfoListResp.taskInfoList:type_name -> pcmCore.TaskInfo
7, // 3: pcmCore.TaskInfo.externalInfoList:type_name -> pcmCore.ExternalInfo
0, // 4: pcmCore.pcmCore.SyncInfo:input_type -> pcmCore.SyncInfoReq
4, // 5: pcmCore.pcmCore.InfoList:input_type -> pcmCore.InfoListReq
3, // 6: pcmCore.pcmCore.SyncInfo:output_type -> pcmCore.SyncInfoResp
5, // 7: pcmCore.pcmCore.InfoList:output_type -> pcmCore.InfoListResp
6, // [6:8] is the sub-list for method output_type
4, // [4:6] is the sub-list for method input_type
4, // [4:4] is the sub-list for extension type_name
4, // [4:4] is the sub-list for extension extendee
0, // [0:4] is the sub-list for field type_name
}
func init() { file_pcmCore_proto_init() }
@ -542,7 +667,7 @@ func file_pcmCore_proto_init() {
}
}
file_pcmCore_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*SyncInfoResp); i {
switch v := v.(*LatestExternalInfo); i {
case 0:
return &v.state
case 1:
@ -554,7 +679,7 @@ func file_pcmCore_proto_init() {
}
}
file_pcmCore_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*InfoListReq); i {
switch v := v.(*SyncInfoResp); i {
case 0:
return &v.state
case 1:
@ -566,7 +691,7 @@ func file_pcmCore_proto_init() {
}
}
file_pcmCore_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*InfoListResp); i {
switch v := v.(*InfoListReq); i {
case 0:
return &v.state
case 1:
@ -578,7 +703,7 @@ func file_pcmCore_proto_init() {
}
}
file_pcmCore_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*TaskInfo); i {
switch v := v.(*InfoListResp); i {
case 0:
return &v.state
case 1:
@ -590,6 +715,18 @@ func file_pcmCore_proto_init() {
}
}
file_pcmCore_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*TaskInfo); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_pcmCore_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ExternalInfo); i {
case 0:
return &v.state
@ -608,7 +745,7 @@ func file_pcmCore_proto_init() {
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: file_pcmCore_proto_rawDesc,
NumEnums: 0,
NumMessages: 7,
NumMessages: 8,
NumExtensions: 0,
NumServices: 1,
},

15
adaptor/PCM-CORE/rpc/pcmCore/pcmCore_grpc.pb.go
View File

@ -1,6 +1,6 @@
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.3.0
// - protoc-gen-go-grpc v1.2.0
// - protoc v3.19.4
// source: pcmCore.proto
@ -18,11 +18,6 @@ import (
// Requires gRPC-Go v1.32.0 or later.
const _ = grpc.SupportPackageIsVersion7
const (
PcmCore_SyncInfo_FullMethodName = "/pcmCore.pcmCore/SyncInfo"
PcmCore_InfoList_FullMethodName = "/pcmCore.pcmCore/InfoList"
)
// PcmCoreClient is the client API for PcmCore service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
@ -43,7 +38,7 @@ func NewPcmCoreClient(cc grpc.ClientConnInterface) PcmCoreClient {
func (c *pcmCoreClient) SyncInfo(ctx context.Context, in *SyncInfoReq, opts ...grpc.CallOption) (*SyncInfoResp, error) {
out := new(SyncInfoResp)
err := c.cc.Invoke(ctx, PcmCore_SyncInfo_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, "/pcmCore.pcmCore/SyncInfo", in, out, opts...)
if err != nil {
return nil, err
}
@ -52,7 +47,7 @@ func (c *pcmCoreClient) SyncInfo(ctx context.Context, in *SyncInfoReq, opts ...g
func (c *pcmCoreClient) InfoList(ctx context.Context, in *InfoListReq, opts ...grpc.CallOption) (*InfoListResp, error) {
out := new(InfoListResp)
err := c.cc.Invoke(ctx, PcmCore_InfoList_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, "/pcmCore.pcmCore/InfoList", in, out, opts...)
if err != nil {
return nil, err
}
@ -103,7 +98,7 @@ func _PcmCore_SyncInfo_Handler(srv interface{}, ctx context.Context, dec func(in
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: PcmCore_SyncInfo_FullMethodName,
FullMethod: "/pcmCore.pcmCore/SyncInfo",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(PcmCoreServer).SyncInfo(ctx, req.(*SyncInfoReq))
@ -121,7 +116,7 @@ func _PcmCore_InfoList_Handler(srv interface{}, ctx context.Context, dec func(in
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: PcmCore_InfoList_FullMethodName,
FullMethod: "/pcmCore.pcmCore/InfoList",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(PcmCoreServer).InfoList(ctx, req.(*InfoListReq))

15
adaptor/PCM-CORE/rpc/pcmcoreclient/pcmcore.go
View File

@ -13,13 +13,14 @@ import (
)
type (
ExternalInfo = pcmCore.ExternalInfo
Info = pcmCore.Info
InfoListReq = pcmCore.InfoListReq
InfoListResp = pcmCore.InfoListResp
SyncInfoReq = pcmCore.SyncInfoReq
SyncInfoResp = pcmCore.SyncInfoResp
TaskInfo = pcmCore.TaskInfo
ExternalInfo = pcmCore.ExternalInfo
Info = pcmCore.Info
InfoListReq = pcmCore.InfoListReq
InfoListResp = pcmCore.InfoListResp
LatestExternalInfo = pcmCore.LatestExternalInfo
SyncInfoReq = pcmCore.SyncInfoReq
SyncInfoResp = pcmCore.SyncInfoResp
TaskInfo = pcmCore.TaskInfo
PcmCore interface {
// SyncInfo Synchronous data information