From 711454c41c96959b86d19763223a818872f9da35 Mon Sep 17 00:00:00 2001 From: tzwang Date: Wed, 10 May 2023 15:54:23 +0800 Subject: [PATCH] =?UTF-8?q?octopus=20=E6=B7=BB=E5=8A=A0=E7=94=A8=E6=88=B7?= =?UTF-8?q?=E9=95=9C=E5=83=8F=E5=88=97=E8=A1=A8=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../rpc/internal/common/tokenService.go | 13 +- .../PCM-OCTOPUS/rpc/internal/config/config.go | 7 + .../rpc/internal/config/octopusConfig.go | 4 + .../internal/logic/getuserimagelistlogic.go | 50 ++ .../rpc/internal/server/octopusserver.go | 7 +- .../PCM-OCTOPUS/rpc/octopus/octopus.pb.go | 787 +++++++++++++++--- .../rpc/octopus/octopus_grpc.pb.go | 44 +- .../PCM-OCTOPUS/rpc/octopusclient/octopus.go | 26 +- .../PCM-AI/PCM-OCTOPUS/rpc/pb/octopus.proto | 82 +- 9 files changed, 911 insertions(+), 109 deletions(-) create mode 100644 adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/getuserimagelistlogic.go diff --git a/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common/tokenService.go b/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common/tokenService.go index 924ec0d1..f71622f9 100644 --- a/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common/tokenService.go +++ b/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common/tokenService.go @@ -21,7 +21,8 @@ type TokenTimePair struct { } var ( - tokenMap = generateTokenMap() + tokenMap = generateTokenMap() + OctopusUrls = getOctopusUrls() ) func generateTokenMap() map[string]TokenTimePair { @@ -80,3 +81,13 @@ func GetToken(kForToken string) string { } return tokenTimePair.Token } + +func getOctopusUrls() map[string]string { + octopusConfig := config.Cfg + urlMap := map[string]string{ + Hanwuji: octopusConfig.OctopusConfig.HanwujiUrl, + Suiyuan: octopusConfig.OctopusConfig.SuiyuanUrl, + Sailingsi: octopusConfig.OctopusConfig.SailingsiUrl, + } + return urlMap +} diff --git a/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/config/config.go b/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/config/config.go index e3ac2749..42522dfe 100644 --- a/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/config/config.go +++ b/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/config/config.go @@ -12,6 +12,7 @@ import ( type Config struct { zrpc.RpcServerConf OctopusConfig OctopusConfig + OctopusApi OctopusApi PcmCoreRpcConf zrpc.RpcClientConf LogConf logx.LogConf RedisConf redis.RedisConf @@ -44,5 +45,11 @@ func getConfig() Config { // 注册到nacos nacosConfig.Discovery(&c.RpcServerConf) + //OctopusUrls = map[string]string{ + // common.Hanwuji: c.OctopusConfig.HanwujiUrl, + // common.Suiyuan: c.OctopusConfig.SuiyuanUrl, + // common.Sailingsi: c.OctopusConfig.SailingsiUrl, + //} + return c } diff --git a/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/config/octopusConfig.go b/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/config/octopusConfig.go index abb96266..2a743d2f 100644 --- a/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/config/octopusConfig.go +++ b/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/config/octopusConfig.go @@ -12,3 +12,7 @@ type OctopusConfig struct { EnflameT20 int32 OctopusCp string } + +type OctopusApi struct { + GetUserImageList string +} diff --git a/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/getuserimagelistlogic.go b/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/getuserimagelistlogic.go new file mode 100644 index 00000000..bf05c301 --- /dev/null +++ b/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/getuserimagelistlogic.go @@ -0,0 +1,50 @@ +package logic + +import ( + "PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common" + "PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc" + "PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus" + "PCM/common/tool" + "context" + "strconv" + + "github.com/zeromicro/go-zero/core/logx" +) + +type GetUserImageListLogic struct { + ctx context.Context + svcCtx *svc.ServiceContext + logx.Logger +} + +func NewGetUserImageListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetUserImageListLogic { + return &GetUserImageListLogic{ + ctx: ctx, + svcCtx: svcCtx, + Logger: logx.WithContext(ctx), + } +} + +// ImageService +func (l *GetUserImageListLogic) GetUserImageList(in *octopus.GetUserImageListReq) (*octopus.GetUserImageListResp, error) { + resp := &octopus.GetUserImageListResp{} + + var url_prefix = common.OctopusUrls[in.Platform] + var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.GetUserImageList + + token := common.GetToken(in.Platform) + + req := tool.GetACHttpRequest() + _, err := /*req.SetHeader(tool.ContentType, tool.ApplicationJson).*/ req. + SetHeader("Authorization", "Bearer "+token). + SetQueryString("pageIndex=" + strconv.Itoa(int(in.PageIndex))). + SetQueryString("pageSize=" + strconv.Itoa(int(in.PageSize))). + SetResult(&resp). + Get(reqUrl) + + if err != nil { + return nil, err + } + + return resp, nil +} diff --git a/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/server/octopusserver.go b/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/server/octopusserver.go index 4abd4a27..5b5515ed 100644 --- a/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/server/octopusserver.go +++ b/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/server/octopusserver.go @@ -32,8 +32,13 @@ func (s *OctopusServer) GetGeneralInfo(ctx context.Context, in *octopus.Resource return l.GetGeneralInfo(in) } -// get modelarts Token func (s *OctopusServer) CreateDataSet(ctx context.Context, in *octopus.CreateDataSetReq) (*octopus.CreateDataSetResq, error) { l := logic.NewCreateDataSetLogic(ctx, s.svcCtx) return l.CreateDataSet(in) } + +// ImageService +func (s *OctopusServer) GetUserImageList(ctx context.Context, in *octopus.GetUserImageListReq) (*octopus.GetUserImageListResp, error) { + l := logic.NewGetUserImageListLogic(ctx, s.svcCtx) + return l.GetUserImageList(in) +} diff --git a/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus/octopus.pb.go b/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus/octopus.pb.go index 61fffb7c..ae6e517d 100644 --- a/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus/octopus.pb.go +++ b/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus/octopus.pb.go @@ -2,7 +2,7 @@ // versions: // protoc-gen-go v1.28.1 // protoc v3.19.4 -// source: pb/octopus.proto +// source: octopus.proto package octopus @@ -29,7 +29,7 @@ type ResourceReq struct { func (x *ResourceReq) Reset() { *x = ResourceReq{} if protoimpl.UnsafeEnabled { - mi := &file_pb_octopus_proto_msgTypes[0] + mi := &file_octopus_proto_msgTypes[0] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -42,7 +42,7 @@ func (x *ResourceReq) String() string { func (*ResourceReq) ProtoMessage() {} func (x *ResourceReq) ProtoReflect() protoreflect.Message { - mi := &file_pb_octopus_proto_msgTypes[0] + mi := &file_octopus_proto_msgTypes[0] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -55,7 +55,7 @@ func (x *ResourceReq) ProtoReflect() protoreflect.Message { // Deprecated: Use ResourceReq.ProtoReflect.Descriptor instead. func (*ResourceReq) Descriptor() ([]byte, []int) { - return file_pb_octopus_proto_rawDescGZIP(), []int{0} + return file_octopus_proto_rawDescGZIP(), []int{0} } type CpResp struct { @@ -69,7 +69,7 @@ type CpResp struct { func (x *CpResp) Reset() { *x = CpResp{} if protoimpl.UnsafeEnabled { - mi := &file_pb_octopus_proto_msgTypes[1] + mi := &file_octopus_proto_msgTypes[1] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -82,7 +82,7 @@ func (x *CpResp) String() string { func (*CpResp) ProtoMessage() {} func (x *CpResp) ProtoReflect() protoreflect.Message { - mi := &file_pb_octopus_proto_msgTypes[1] + mi := &file_octopus_proto_msgTypes[1] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -95,7 +95,7 @@ func (x *CpResp) ProtoReflect() protoreflect.Message { // Deprecated: Use CpResp.ProtoReflect.Descriptor instead. func (*CpResp) Descriptor() ([]byte, []int) { - return file_pb_octopus_proto_rawDescGZIP(), []int{1} + return file_octopus_proto_rawDescGZIP(), []int{1} } func (x *CpResp) GetPOpsAtFp16() float32 { @@ -117,7 +117,7 @@ type GiResp struct { func (x *GiResp) Reset() { *x = GiResp{} if protoimpl.UnsafeEnabled { - mi := &file_pb_octopus_proto_msgTypes[2] + mi := &file_octopus_proto_msgTypes[2] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -130,7 +130,7 @@ func (x *GiResp) String() string { func (*GiResp) ProtoMessage() {} func (x *GiResp) ProtoReflect() protoreflect.Message { - mi := &file_pb_octopus_proto_msgTypes[2] + mi := &file_octopus_proto_msgTypes[2] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -143,7 +143,7 @@ func (x *GiResp) ProtoReflect() protoreflect.Message { // Deprecated: Use GiResp.ProtoReflect.Descriptor instead. func (*GiResp) Descriptor() ([]byte, []int) { - return file_pb_octopus_proto_rawDescGZIP(), []int{2} + return file_octopus_proto_rawDescGZIP(), []int{2} } func (x *GiResp) GetCpuCoreNum() int32 { @@ -174,7 +174,7 @@ type CreateDataSetReq struct { func (x *CreateDataSetReq) Reset() { *x = CreateDataSetReq{} if protoimpl.UnsafeEnabled { - mi := &file_pb_octopus_proto_msgTypes[3] + mi := &file_octopus_proto_msgTypes[3] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -187,7 +187,7 @@ func (x *CreateDataSetReq) String() string { func (*CreateDataSetReq) ProtoMessage() {} func (x *CreateDataSetReq) ProtoReflect() protoreflect.Message { - mi := &file_pb_octopus_proto_msgTypes[3] + mi := &file_octopus_proto_msgTypes[3] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -200,7 +200,7 @@ func (x *CreateDataSetReq) ProtoReflect() protoreflect.Message { // Deprecated: Use CreateDataSetReq.ProtoReflect.Descriptor instead. func (*CreateDataSetReq) Descriptor() ([]byte, []int) { - return file_pb_octopus_proto_rawDescGZIP(), []int{3} + return file_octopus_proto_rawDescGZIP(), []int{3} } func (x *CreateDataSetReq) GetApplyIds() []string { @@ -243,7 +243,7 @@ type CreateDataSetResq struct { func (x *CreateDataSetResq) Reset() { *x = CreateDataSetResq{} if protoimpl.UnsafeEnabled { - mi := &file_pb_octopus_proto_msgTypes[4] + mi := &file_octopus_proto_msgTypes[4] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -256,7 +256,7 @@ func (x *CreateDataSetResq) String() string { func (*CreateDataSetResq) ProtoMessage() {} func (x *CreateDataSetResq) ProtoReflect() protoreflect.Message { - mi := &file_pb_octopus_proto_msgTypes[4] + mi := &file_octopus_proto_msgTypes[4] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -269,7 +269,7 @@ func (x *CreateDataSetResq) ProtoReflect() protoreflect.Message { // Deprecated: Use CreateDataSetResq.ProtoReflect.Descriptor instead. func (*CreateDataSetResq) Descriptor() ([]byte, []int) { - return file_pb_octopus_proto_rawDescGZIP(), []int{4} + return file_octopus_proto_rawDescGZIP(), []int{4} } func (x *CreateDataSetResq) GetId() string { @@ -286,87 +286,612 @@ func (x *CreateDataSetResq) GetVersion() string { return "" } -var File_pb_octopus_proto protoreflect.FileDescriptor +// *****************ImageService Start************************ +type GetUserImageListReq struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields -var file_pb_octopus_proto_rawDesc = []byte{ - 0x0a, 0x10, 0x70, 0x62, 0x2f, 0x6f, 0x63, 0x74, 0x6f, 0x70, 0x75, 0x73, 0x2e, 0x70, 0x72, 0x6f, - 0x74, 0x6f, 0x12, 0x07, 0x6f, 0x63, 0x74, 0x6f, 0x70, 0x75, 0x73, 0x22, 0x0d, 0x0a, 0x0b, 0x72, - 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x52, 0x65, 0x71, 0x22, 0x28, 0x0a, 0x06, 0x63, 0x70, - 0x52, 0x65, 0x73, 0x70, 0x12, 0x1e, 0x0a, 0x0a, 0x70, 0x4f, 0x70, 0x73, 0x41, 0x74, 0x46, 0x70, - 0x31, 0x36, 0x18, 0x01, 0x20, 0x01, 0x28, 0x02, 0x52, 0x0a, 0x70, 0x4f, 0x70, 0x73, 0x41, 0x74, - 0x46, 0x70, 0x31, 0x36, 0x22, 0x4a, 0x0a, 0x06, 0x67, 0x69, 0x52, 0x65, 0x73, 0x70, 0x12, 0x1e, - 0x0a, 0x0a, 0x63, 0x70, 0x75, 0x43, 0x6f, 0x72, 0x65, 0x4e, 0x75, 0x6d, 0x18, 0x01, 0x20, 0x01, - 0x28, 0x05, 0x52, 0x0a, 0x63, 0x70, 0x75, 0x43, 0x6f, 0x72, 0x65, 0x4e, 0x75, 0x6d, 0x12, 0x20, - 0x0a, 0x0b, 0x6d, 0x65, 0x6d, 0x6f, 0x72, 0x79, 0x49, 0x6e, 0x47, 0x69, 0x62, 0x18, 0x02, 0x20, - 0x01, 0x28, 0x05, 0x52, 0x0b, 0x6d, 0x65, 0x6d, 0x6f, 0x72, 0x79, 0x49, 0x6e, 0x47, 0x69, 0x62, - 0x22, 0x6e, 0x0a, 0x10, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x44, 0x61, 0x74, 0x61, 0x53, 0x65, - 0x74, 0x52, 0x65, 0x71, 0x12, 0x1a, 0x0a, 0x08, 0x61, 0x70, 0x70, 0x6c, 0x79, 0x49, 0x64, 0x73, - 0x18, 0x01, 0x20, 0x03, 0x28, 0x09, 0x52, 0x08, 0x61, 0x70, 0x70, 0x6c, 0x79, 0x49, 0x64, 0x73, - 0x12, 0x12, 0x0a, 0x04, 0x64, 0x65, 0x73, 0x63, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, - 0x64, 0x65, 0x73, 0x63, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, - 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x74, 0x79, 0x70, 0x65, - 0x49, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x74, 0x79, 0x70, 0x65, 0x49, 0x64, - 0x22, 0x3d, 0x0a, 0x11, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x44, 0x61, 0x74, 0x61, 0x53, 0x65, - 0x74, 0x52, 0x65, 0x73, 0x71, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, - 0x09, 0x52, 0x02, 0x69, 0x64, 0x12, 0x18, 0x0a, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, - 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x32, - 0xc6, 0x01, 0x0a, 0x07, 0x4f, 0x63, 0x74, 0x6f, 0x70, 0x75, 0x73, 0x12, 0x3a, 0x0a, 0x11, 0x47, - 0x65, 0x74, 0x43, 0x6f, 0x6d, 0x70, 0x75, 0x74, 0x69, 0x6e, 0x67, 0x50, 0x6f, 0x77, 0x65, 0x72, - 0x12, 0x14, 0x2e, 0x6f, 0x63, 0x74, 0x6f, 0x70, 0x75, 0x73, 0x2e, 0x72, 0x65, 0x73, 0x6f, 0x75, - 0x72, 0x63, 0x65, 0x52, 0x65, 0x71, 0x1a, 0x0f, 0x2e, 0x6f, 0x63, 0x74, 0x6f, 0x70, 0x75, 0x73, - 0x2e, 0x63, 0x70, 0x52, 0x65, 0x73, 0x70, 0x12, 0x37, 0x0a, 0x0e, 0x47, 0x65, 0x74, 0x47, 0x65, - 0x6e, 0x65, 0x72, 0x61, 0x6c, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x14, 0x2e, 0x6f, 0x63, 0x74, 0x6f, - 0x70, 0x75, 0x73, 0x2e, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x52, 0x65, 0x71, 0x1a, - 0x0f, 0x2e, 0x6f, 0x63, 0x74, 0x6f, 0x70, 0x75, 0x73, 0x2e, 0x67, 0x69, 0x52, 0x65, 0x73, 0x70, - 0x12, 0x46, 0x0a, 0x0d, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x44, 0x61, 0x74, 0x61, 0x53, 0x65, - 0x74, 0x12, 0x19, 0x2e, 0x6f, 0x63, 0x74, 0x6f, 0x70, 0x75, 0x73, 0x2e, 0x43, 0x72, 0x65, 0x61, - 0x74, 0x65, 0x44, 0x61, 0x74, 0x61, 0x53, 0x65, 0x74, 0x52, 0x65, 0x71, 0x1a, 0x1a, 0x2e, 0x6f, - 0x63, 0x74, 0x6f, 0x70, 0x75, 0x73, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x44, 0x61, 0x74, - 0x61, 0x53, 0x65, 0x74, 0x52, 0x65, 0x73, 0x71, 0x42, 0x0a, 0x5a, 0x08, 0x2f, 0x6f, 0x63, 0x74, - 0x6f, 0x70, 0x75, 0x73, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, + Platform string `protobuf:"bytes,1,opt,name=platform,proto3" json:"platform,omitempty"` + PageIndex int32 `protobuf:"varint,2,opt,name=pageIndex,proto3" json:"pageIndex,omitempty"` + PageSize int32 `protobuf:"varint,3,opt,name=pageSize,proto3" json:"pageSize,omitempty"` +} + +func (x *GetUserImageListReq) Reset() { + *x = GetUserImageListReq{} + if protoimpl.UnsafeEnabled { + mi := &file_octopus_proto_msgTypes[5] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *GetUserImageListReq) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*GetUserImageListReq) ProtoMessage() {} + +func (x *GetUserImageListReq) ProtoReflect() protoreflect.Message { + mi := &file_octopus_proto_msgTypes[5] + 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 GetUserImageListReq.ProtoReflect.Descriptor instead. +func (*GetUserImageListReq) Descriptor() ([]byte, []int) { + return file_octopus_proto_rawDescGZIP(), []int{5} +} + +func (x *GetUserImageListReq) GetPlatform() string { + if x != nil { + return x.Platform + } + return "" +} + +func (x *GetUserImageListReq) GetPageIndex() int32 { + if x != nil { + return x.PageIndex + } + return 0 +} + +func (x *GetUserImageListReq) GetPageSize() int32 { + if x != nil { + return x.PageSize + } + return 0 +} + +type GetUserImageListResp struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` + Payload *Payload `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"` + Error *Error `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"` +} + +func (x *GetUserImageListResp) Reset() { + *x = GetUserImageListResp{} + if protoimpl.UnsafeEnabled { + mi := &file_octopus_proto_msgTypes[6] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *GetUserImageListResp) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*GetUserImageListResp) ProtoMessage() {} + +func (x *GetUserImageListResp) ProtoReflect() protoreflect.Message { + mi := &file_octopus_proto_msgTypes[6] + 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 GetUserImageListResp.ProtoReflect.Descriptor instead. +func (*GetUserImageListResp) Descriptor() ([]byte, []int) { + return file_octopus_proto_rawDescGZIP(), []int{6} +} + +func (x *GetUserImageListResp) GetSuccess() bool { + if x != nil { + return x.Success + } + return false +} + +func (x *GetUserImageListResp) GetPayload() *Payload { + if x != nil { + return x.Payload + } + return nil +} + +func (x *GetUserImageListResp) GetError() *Error { + if x != nil { + return x.Error + } + return nil +} + +type Error struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` + Subcode int32 `protobuf:"varint,2,opt,name=subcode,proto3" json:"subcode,omitempty"` + Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"` + SubMessage string `protobuf:"bytes,4,opt,name=subMessage,proto3" json:"subMessage,omitempty"` +} + +func (x *Error) Reset() { + *x = Error{} + if protoimpl.UnsafeEnabled { + mi := &file_octopus_proto_msgTypes[7] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *Error) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*Error) ProtoMessage() {} + +func (x *Error) ProtoReflect() protoreflect.Message { + mi := &file_octopus_proto_msgTypes[7] + 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 Error.ProtoReflect.Descriptor instead. +func (*Error) Descriptor() ([]byte, []int) { + return file_octopus_proto_rawDescGZIP(), []int{7} +} + +func (x *Error) GetCode() int32 { + if x != nil { + return x.Code + } + return 0 +} + +func (x *Error) GetSubcode() int32 { + if x != nil { + return x.Subcode + } + return 0 +} + +func (x *Error) GetMessage() string { + if x != nil { + return x.Message + } + return "" +} + +func (x *Error) GetSubMessage() string { + if x != nil { + return x.SubMessage + } + return "" +} + +type Payload struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + TotalSize int32 `protobuf:"varint,1,opt,name=totalSize,proto3" json:"totalSize,omitempty"` + Images []*Images `protobuf:"bytes,2,rep,name=images,proto3" json:"images,omitempty"` +} + +func (x *Payload) Reset() { + *x = Payload{} + if protoimpl.UnsafeEnabled { + mi := &file_octopus_proto_msgTypes[8] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *Payload) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*Payload) ProtoMessage() {} + +func (x *Payload) ProtoReflect() protoreflect.Message { + mi := &file_octopus_proto_msgTypes[8] + 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 Payload.ProtoReflect.Descriptor instead. +func (*Payload) Descriptor() ([]byte, []int) { + return file_octopus_proto_rawDescGZIP(), []int{8} +} + +func (x *Payload) GetTotalSize() int32 { + if x != nil { + return x.TotalSize + } + return 0 +} + +func (x *Payload) GetImages() []*Images { + if x != nil { + return x.Images + } + return nil +} + +type Images struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + IsShared bool `protobuf:"varint,1,opt,name=isShared,proto3" json:"isShared,omitempty"` + Image *Image `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"` +} + +func (x *Images) Reset() { + *x = Images{} + if protoimpl.UnsafeEnabled { + mi := &file_octopus_proto_msgTypes[9] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *Images) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*Images) ProtoMessage() {} + +func (x *Images) ProtoReflect() protoreflect.Message { + mi := &file_octopus_proto_msgTypes[9] + 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 Images.ProtoReflect.Descriptor instead. +func (*Images) Descriptor() ([]byte, []int) { + return file_octopus_proto_rawDescGZIP(), []int{9} +} + +func (x *Images) GetIsShared() bool { + if x != nil { + return x.IsShared + } + return false +} + +func (x *Images) GetImage() *Image { + if x != nil { + return x.Image + } + return nil +} + +type Image struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` + ImageName string `protobuf:"bytes,2,opt,name=imageName,proto3" json:"imageName,omitempty"` + ImageDesc string `protobuf:"bytes,3,opt,name=imageDesc,proto3" json:"imageDesc,omitempty"` + ImageAddr string `protobuf:"bytes,4,opt,name=imageAddr,proto3" json:"imageAddr,omitempty"` + SourceType int32 `protobuf:"varint,5,opt,name=sourceType,proto3" json:"sourceType,omitempty"` + SpaceId string `protobuf:"bytes,6,opt,name=spaceId,proto3" json:"spaceId,omitempty"` + UserId string `protobuf:"bytes,7,opt,name=userId,proto3" json:"userId,omitempty"` + CreatedAt int64 `protobuf:"varint,8,opt,name=createdAt,proto3" json:"createdAt,omitempty"` + UpdatedAt int64 `protobuf:"varint,9,opt,name=updatedAt,proto3" json:"updatedAt,omitempty"` + ImageStatus int32 `protobuf:"varint,10,opt,name=imageStatus,proto3" json:"imageStatus,omitempty"` + Username string `protobuf:"bytes,11,opt,name=username,proto3" json:"username,omitempty"` + ImageVersion string `protobuf:"bytes,12,opt,name=imageVersion,proto3" json:"imageVersion,omitempty"` + ImageFullAddr string `protobuf:"bytes,13,opt,name=imageFullAddr,proto3" json:"imageFullAddr,omitempty"` +} + +func (x *Image) Reset() { + *x = Image{} + if protoimpl.UnsafeEnabled { + mi := &file_octopus_proto_msgTypes[10] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *Image) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*Image) ProtoMessage() {} + +func (x *Image) ProtoReflect() protoreflect.Message { + mi := &file_octopus_proto_msgTypes[10] + 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 Image.ProtoReflect.Descriptor instead. +func (*Image) Descriptor() ([]byte, []int) { + return file_octopus_proto_rawDescGZIP(), []int{10} +} + +func (x *Image) GetId() string { + if x != nil { + return x.Id + } + return "" +} + +func (x *Image) GetImageName() string { + if x != nil { + return x.ImageName + } + return "" +} + +func (x *Image) GetImageDesc() string { + if x != nil { + return x.ImageDesc + } + return "" +} + +func (x *Image) GetImageAddr() string { + if x != nil { + return x.ImageAddr + } + return "" +} + +func (x *Image) GetSourceType() int32 { + if x != nil { + return x.SourceType + } + return 0 +} + +func (x *Image) GetSpaceId() string { + if x != nil { + return x.SpaceId + } + return "" +} + +func (x *Image) GetUserId() string { + if x != nil { + return x.UserId + } + return "" +} + +func (x *Image) GetCreatedAt() int64 { + if x != nil { + return x.CreatedAt + } + return 0 +} + +func (x *Image) GetUpdatedAt() int64 { + if x != nil { + return x.UpdatedAt + } + return 0 +} + +func (x *Image) GetImageStatus() int32 { + if x != nil { + return x.ImageStatus + } + return 0 +} + +func (x *Image) GetUsername() string { + if x != nil { + return x.Username + } + return "" +} + +func (x *Image) GetImageVersion() string { + if x != nil { + return x.ImageVersion + } + return "" +} + +func (x *Image) GetImageFullAddr() string { + if x != nil { + return x.ImageFullAddr + } + return "" +} + +var File_octopus_proto protoreflect.FileDescriptor + +var file_octopus_proto_rawDesc = []byte{ + 0x0a, 0x0d, 0x6f, 0x63, 0x74, 0x6f, 0x70, 0x75, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, + 0x07, 0x6f, 0x63, 0x74, 0x6f, 0x70, 0x75, 0x73, 0x22, 0x0d, 0x0a, 0x0b, 0x72, 0x65, 0x73, 0x6f, + 0x75, 0x72, 0x63, 0x65, 0x52, 0x65, 0x71, 0x22, 0x28, 0x0a, 0x06, 0x63, 0x70, 0x52, 0x65, 0x73, + 0x70, 0x12, 0x1e, 0x0a, 0x0a, 0x70, 0x4f, 0x70, 0x73, 0x41, 0x74, 0x46, 0x70, 0x31, 0x36, 0x18, + 0x01, 0x20, 0x01, 0x28, 0x02, 0x52, 0x0a, 0x70, 0x4f, 0x70, 0x73, 0x41, 0x74, 0x46, 0x70, 0x31, + 0x36, 0x22, 0x4a, 0x0a, 0x06, 0x67, 0x69, 0x52, 0x65, 0x73, 0x70, 0x12, 0x1e, 0x0a, 0x0a, 0x63, + 0x70, 0x75, 0x43, 0x6f, 0x72, 0x65, 0x4e, 0x75, 0x6d, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, + 0x0a, 0x63, 0x70, 0x75, 0x43, 0x6f, 0x72, 0x65, 0x4e, 0x75, 0x6d, 0x12, 0x20, 0x0a, 0x0b, 0x6d, + 0x65, 0x6d, 0x6f, 0x72, 0x79, 0x49, 0x6e, 0x47, 0x69, 0x62, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, + 0x52, 0x0b, 0x6d, 0x65, 0x6d, 0x6f, 0x72, 0x79, 0x49, 0x6e, 0x47, 0x69, 0x62, 0x22, 0x6e, 0x0a, + 0x10, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x44, 0x61, 0x74, 0x61, 0x53, 0x65, 0x74, 0x52, 0x65, + 0x71, 0x12, 0x1a, 0x0a, 0x08, 0x61, 0x70, 0x70, 0x6c, 0x79, 0x49, 0x64, 0x73, 0x18, 0x01, 0x20, + 0x03, 0x28, 0x09, 0x52, 0x08, 0x61, 0x70, 0x70, 0x6c, 0x79, 0x49, 0x64, 0x73, 0x12, 0x12, 0x0a, + 0x04, 0x64, 0x65, 0x73, 0x63, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x64, 0x65, 0x73, + 0x63, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, + 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x74, 0x79, 0x70, 0x65, 0x49, 0x64, 0x18, + 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x74, 0x79, 0x70, 0x65, 0x49, 0x64, 0x22, 0x3d, 0x0a, + 0x11, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x44, 0x61, 0x74, 0x61, 0x53, 0x65, 0x74, 0x52, 0x65, + 0x73, 0x71, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x02, + 0x69, 0x64, 0x12, 0x18, 0x0a, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, + 0x01, 0x28, 0x09, 0x52, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x22, 0x6b, 0x0a, 0x13, + 0x47, 0x65, 0x74, 0x55, 0x73, 0x65, 0x72, 0x49, 0x6d, 0x61, 0x67, 0x65, 0x4c, 0x69, 0x73, 0x74, + 0x52, 0x65, 0x71, 0x12, 0x1a, 0x0a, 0x08, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x18, + 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x12, + 0x1c, 0x0a, 0x09, 0x70, 0x61, 0x67, 0x65, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x18, 0x02, 0x20, 0x01, + 0x28, 0x05, 0x52, 0x09, 0x70, 0x61, 0x67, 0x65, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x12, 0x1a, 0x0a, + 0x08, 0x70, 0x61, 0x67, 0x65, 0x53, 0x69, 0x7a, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, + 0x08, 0x70, 0x61, 0x67, 0x65, 0x53, 0x69, 0x7a, 0x65, 0x22, 0x82, 0x01, 0x0a, 0x14, 0x47, 0x65, + 0x74, 0x55, 0x73, 0x65, 0x72, 0x49, 0x6d, 0x61, 0x67, 0x65, 0x4c, 0x69, 0x73, 0x74, 0x52, 0x65, + 0x73, 0x70, 0x12, 0x18, 0x0a, 0x07, 0x73, 0x75, 0x63, 0x63, 0x65, 0x73, 0x73, 0x18, 0x01, 0x20, + 0x01, 0x28, 0x08, 0x52, 0x07, 0x73, 0x75, 0x63, 0x63, 0x65, 0x73, 0x73, 0x12, 0x2a, 0x0a, 0x07, + 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x10, 0x2e, + 0x6f, 0x63, 0x74, 0x6f, 0x70, 0x75, 0x73, 0x2e, 0x50, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x52, + 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x12, 0x24, 0x0a, 0x05, 0x65, 0x72, 0x72, 0x6f, + 0x72, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0e, 0x2e, 0x6f, 0x63, 0x74, 0x6f, 0x70, 0x75, + 0x73, 0x2e, 0x45, 0x72, 0x72, 0x6f, 0x72, 0x52, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x22, 0x6f, + 0x0a, 0x05, 0x45, 0x72, 0x72, 0x6f, 0x72, 0x12, 0x12, 0x0a, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x18, + 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x73, + 0x75, 0x62, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x52, 0x07, 0x73, 0x75, + 0x62, 0x63, 0x6f, 0x64, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, + 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, + 0x1e, 0x0a, 0x0a, 0x73, 0x75, 0x62, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x18, 0x04, 0x20, + 0x01, 0x28, 0x09, 0x52, 0x0a, 0x73, 0x75, 0x62, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x22, + 0x50, 0x0a, 0x07, 0x50, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x12, 0x1c, 0x0a, 0x09, 0x74, 0x6f, + 0x74, 0x61, 0x6c, 0x53, 0x69, 0x7a, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x09, 0x74, + 0x6f, 0x74, 0x61, 0x6c, 0x53, 0x69, 0x7a, 0x65, 0x12, 0x27, 0x0a, 0x06, 0x69, 0x6d, 0x61, 0x67, + 0x65, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x0f, 0x2e, 0x6f, 0x63, 0x74, 0x6f, 0x70, + 0x75, 0x73, 0x2e, 0x49, 0x6d, 0x61, 0x67, 0x65, 0x73, 0x52, 0x06, 0x69, 0x6d, 0x61, 0x67, 0x65, + 0x73, 0x22, 0x4a, 0x0a, 0x06, 0x49, 0x6d, 0x61, 0x67, 0x65, 0x73, 0x12, 0x1a, 0x0a, 0x08, 0x69, + 0x73, 0x53, 0x68, 0x61, 0x72, 0x65, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x08, 0x52, 0x08, 0x69, + 0x73, 0x53, 0x68, 0x61, 0x72, 0x65, 0x64, 0x12, 0x24, 0x0a, 0x05, 0x69, 0x6d, 0x61, 0x67, 0x65, + 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0e, 0x2e, 0x6f, 0x63, 0x74, 0x6f, 0x70, 0x75, 0x73, + 0x2e, 0x49, 0x6d, 0x61, 0x67, 0x65, 0x52, 0x05, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x22, 0x87, 0x03, + 0x0a, 0x05, 0x49, 0x6d, 0x61, 0x67, 0x65, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, + 0x01, 0x28, 0x09, 0x52, 0x02, 0x69, 0x64, 0x12, 0x1c, 0x0a, 0x09, 0x69, 0x6d, 0x61, 0x67, 0x65, + 0x4e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x69, 0x6d, 0x61, 0x67, + 0x65, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x44, 0x65, + 0x73, 0x63, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x44, + 0x65, 0x73, 0x63, 0x12, 0x1c, 0x0a, 0x09, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x41, 0x64, 0x64, 0x72, + 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x41, 0x64, 0x64, + 0x72, 0x12, 0x1e, 0x0a, 0x0a, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x54, 0x79, 0x70, 0x65, 0x18, + 0x05, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0a, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x54, 0x79, 0x70, + 0x65, 0x12, 0x18, 0x0a, 0x07, 0x73, 0x70, 0x61, 0x63, 0x65, 0x49, 0x64, 0x18, 0x06, 0x20, 0x01, + 0x28, 0x09, 0x52, 0x07, 0x73, 0x70, 0x61, 0x63, 0x65, 0x49, 0x64, 0x12, 0x16, 0x0a, 0x06, 0x75, + 0x73, 0x65, 0x72, 0x49, 0x64, 0x18, 0x07, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x75, 0x73, 0x65, + 0x72, 0x49, 0x64, 0x12, 0x1c, 0x0a, 0x09, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x64, 0x41, 0x74, + 0x18, 0x08, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x64, 0x41, + 0x74, 0x12, 0x1c, 0x0a, 0x09, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x64, 0x41, 0x74, 0x18, 0x09, + 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x64, 0x41, 0x74, 0x12, + 0x20, 0x0a, 0x0b, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x18, 0x0a, + 0x20, 0x01, 0x28, 0x05, 0x52, 0x0b, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x53, 0x74, 0x61, 0x74, 0x75, + 0x73, 0x12, 0x1a, 0x0a, 0x08, 0x75, 0x73, 0x65, 0x72, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x0b, 0x20, + 0x01, 0x28, 0x09, 0x52, 0x08, 0x75, 0x73, 0x65, 0x72, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x22, 0x0a, + 0x0c, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x0c, 0x20, + 0x01, 0x28, 0x09, 0x52, 0x0c, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, + 0x6e, 0x12, 0x24, 0x0a, 0x0d, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x46, 0x75, 0x6c, 0x6c, 0x41, 0x64, + 0x64, 0x72, 0x18, 0x0d, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x69, 0x6d, 0x61, 0x67, 0x65, 0x46, + 0x75, 0x6c, 0x6c, 0x41, 0x64, 0x64, 0x72, 0x32, 0x97, 0x02, 0x0a, 0x07, 0x4f, 0x63, 0x74, 0x6f, + 0x70, 0x75, 0x73, 0x12, 0x3a, 0x0a, 0x11, 0x47, 0x65, 0x74, 0x43, 0x6f, 0x6d, 0x70, 0x75, 0x74, + 0x69, 0x6e, 0x67, 0x50, 0x6f, 0x77, 0x65, 0x72, 0x12, 0x14, 0x2e, 0x6f, 0x63, 0x74, 0x6f, 0x70, + 0x75, 0x73, 0x2e, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x52, 0x65, 0x71, 0x1a, 0x0f, + 0x2e, 0x6f, 0x63, 0x74, 0x6f, 0x70, 0x75, 0x73, 0x2e, 0x63, 0x70, 0x52, 0x65, 0x73, 0x70, 0x12, + 0x37, 0x0a, 0x0e, 0x47, 0x65, 0x74, 0x47, 0x65, 0x6e, 0x65, 0x72, 0x61, 0x6c, 0x49, 0x6e, 0x66, + 0x6f, 0x12, 0x14, 0x2e, 0x6f, 0x63, 0x74, 0x6f, 0x70, 0x75, 0x73, 0x2e, 0x72, 0x65, 0x73, 0x6f, + 0x75, 0x72, 0x63, 0x65, 0x52, 0x65, 0x71, 0x1a, 0x0f, 0x2e, 0x6f, 0x63, 0x74, 0x6f, 0x70, 0x75, + 0x73, 0x2e, 0x67, 0x69, 0x52, 0x65, 0x73, 0x70, 0x12, 0x46, 0x0a, 0x0d, 0x43, 0x72, 0x65, 0x61, + 0x74, 0x65, 0x44, 0x61, 0x74, 0x61, 0x53, 0x65, 0x74, 0x12, 0x19, 0x2e, 0x6f, 0x63, 0x74, 0x6f, + 0x70, 0x75, 0x73, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x44, 0x61, 0x74, 0x61, 0x53, 0x65, + 0x74, 0x52, 0x65, 0x71, 0x1a, 0x1a, 0x2e, 0x6f, 0x63, 0x74, 0x6f, 0x70, 0x75, 0x73, 0x2e, 0x43, + 0x72, 0x65, 0x61, 0x74, 0x65, 0x44, 0x61, 0x74, 0x61, 0x53, 0x65, 0x74, 0x52, 0x65, 0x73, 0x71, + 0x12, 0x4f, 0x0a, 0x10, 0x47, 0x65, 0x74, 0x55, 0x73, 0x65, 0x72, 0x49, 0x6d, 0x61, 0x67, 0x65, + 0x4c, 0x69, 0x73, 0x74, 0x12, 0x1c, 0x2e, 0x6f, 0x63, 0x74, 0x6f, 0x70, 0x75, 0x73, 0x2e, 0x47, + 0x65, 0x74, 0x55, 0x73, 0x65, 0x72, 0x49, 0x6d, 0x61, 0x67, 0x65, 0x4c, 0x69, 0x73, 0x74, 0x52, + 0x65, 0x71, 0x1a, 0x1d, 0x2e, 0x6f, 0x63, 0x74, 0x6f, 0x70, 0x75, 0x73, 0x2e, 0x47, 0x65, 0x74, + 0x55, 0x73, 0x65, 0x72, 0x49, 0x6d, 0x61, 0x67, 0x65, 0x4c, 0x69, 0x73, 0x74, 0x52, 0x65, 0x73, + 0x70, 0x42, 0x0a, 0x5a, 0x08, 0x2f, 0x6f, 0x63, 0x74, 0x6f, 0x70, 0x75, 0x73, 0x62, 0x06, 0x70, + 0x72, 0x6f, 0x74, 0x6f, 0x33, } var ( - file_pb_octopus_proto_rawDescOnce sync.Once - file_pb_octopus_proto_rawDescData = file_pb_octopus_proto_rawDesc + file_octopus_proto_rawDescOnce sync.Once + file_octopus_proto_rawDescData = file_octopus_proto_rawDesc ) -func file_pb_octopus_proto_rawDescGZIP() []byte { - file_pb_octopus_proto_rawDescOnce.Do(func() { - file_pb_octopus_proto_rawDescData = protoimpl.X.CompressGZIP(file_pb_octopus_proto_rawDescData) +func file_octopus_proto_rawDescGZIP() []byte { + file_octopus_proto_rawDescOnce.Do(func() { + file_octopus_proto_rawDescData = protoimpl.X.CompressGZIP(file_octopus_proto_rawDescData) }) - return file_pb_octopus_proto_rawDescData + return file_octopus_proto_rawDescData } -var file_pb_octopus_proto_msgTypes = make([]protoimpl.MessageInfo, 5) -var file_pb_octopus_proto_goTypes = []interface{}{ - (*ResourceReq)(nil), // 0: octopus.resourceReq - (*CpResp)(nil), // 1: octopus.cpResp - (*GiResp)(nil), // 2: octopus.giResp - (*CreateDataSetReq)(nil), // 3: octopus.CreateDataSetReq - (*CreateDataSetResq)(nil), // 4: octopus.CreateDataSetResq +var file_octopus_proto_msgTypes = make([]protoimpl.MessageInfo, 11) +var file_octopus_proto_goTypes = []interface{}{ + (*ResourceReq)(nil), // 0: octopus.resourceReq + (*CpResp)(nil), // 1: octopus.cpResp + (*GiResp)(nil), // 2: octopus.giResp + (*CreateDataSetReq)(nil), // 3: octopus.CreateDataSetReq + (*CreateDataSetResq)(nil), // 4: octopus.CreateDataSetResq + (*GetUserImageListReq)(nil), // 5: octopus.GetUserImageListReq + (*GetUserImageListResp)(nil), // 6: octopus.GetUserImageListResp + (*Error)(nil), // 7: octopus.Error + (*Payload)(nil), // 8: octopus.Payload + (*Images)(nil), // 9: octopus.Images + (*Image)(nil), // 10: octopus.Image } -var file_pb_octopus_proto_depIdxs = []int32{ - 0, // 0: octopus.Octopus.GetComputingPower:input_type -> octopus.resourceReq - 0, // 1: octopus.Octopus.GetGeneralInfo:input_type -> octopus.resourceReq - 3, // 2: octopus.Octopus.CreateDataSet:input_type -> octopus.CreateDataSetReq - 1, // 3: octopus.Octopus.GetComputingPower:output_type -> octopus.cpResp - 2, // 4: octopus.Octopus.GetGeneralInfo:output_type -> octopus.giResp - 4, // 5: octopus.Octopus.CreateDataSet:output_type -> octopus.CreateDataSetResq - 3, // [3:6] is the sub-list for method output_type - 0, // [0:3] is the sub-list for method input_type - 0, // [0:0] is the sub-list for extension type_name - 0, // [0:0] is the sub-list for extension extendee - 0, // [0:0] is the sub-list for field type_name +var file_octopus_proto_depIdxs = []int32{ + 8, // 0: octopus.GetUserImageListResp.payload:type_name -> octopus.Payload + 7, // 1: octopus.GetUserImageListResp.error:type_name -> octopus.Error + 9, // 2: octopus.Payload.images:type_name -> octopus.Images + 10, // 3: octopus.Images.image:type_name -> octopus.Image + 0, // 4: octopus.Octopus.GetComputingPower:input_type -> octopus.resourceReq + 0, // 5: octopus.Octopus.GetGeneralInfo:input_type -> octopus.resourceReq + 3, // 6: octopus.Octopus.CreateDataSet:input_type -> octopus.CreateDataSetReq + 5, // 7: octopus.Octopus.GetUserImageList:input_type -> octopus.GetUserImageListReq + 1, // 8: octopus.Octopus.GetComputingPower:output_type -> octopus.cpResp + 2, // 9: octopus.Octopus.GetGeneralInfo:output_type -> octopus.giResp + 4, // 10: octopus.Octopus.CreateDataSet:output_type -> octopus.CreateDataSetResq + 6, // 11: octopus.Octopus.GetUserImageList:output_type -> octopus.GetUserImageListResp + 8, // [8:12] is the sub-list for method output_type + 4, // [4:8] 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_pb_octopus_proto_init() } -func file_pb_octopus_proto_init() { - if File_pb_octopus_proto != nil { +func init() { file_octopus_proto_init() } +func file_octopus_proto_init() { + if File_octopus_proto != nil { return } if !protoimpl.UnsafeEnabled { - file_pb_octopus_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { + file_octopus_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*ResourceReq); i { case 0: return &v.state @@ -378,7 +903,7 @@ func file_pb_octopus_proto_init() { return nil } } - file_pb_octopus_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { + file_octopus_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*CpResp); i { case 0: return &v.state @@ -390,7 +915,7 @@ func file_pb_octopus_proto_init() { return nil } } - file_pb_octopus_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { + file_octopus_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*GiResp); i { case 0: return &v.state @@ -402,7 +927,7 @@ func file_pb_octopus_proto_init() { return nil } } - file_pb_octopus_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { + file_octopus_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*CreateDataSetReq); i { case 0: return &v.state @@ -414,7 +939,7 @@ func file_pb_octopus_proto_init() { return nil } } - file_pb_octopus_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { + file_octopus_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*CreateDataSetResq); i { case 0: return &v.state @@ -426,23 +951,95 @@ func file_pb_octopus_proto_init() { return nil } } + file_octopus_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*GetUserImageListReq); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_octopus_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*GetUserImageListResp); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_octopus_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*Error); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_octopus_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*Payload); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_octopus_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*Images); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_octopus_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*Image); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } } type x struct{} out := protoimpl.TypeBuilder{ File: protoimpl.DescBuilder{ GoPackagePath: reflect.TypeOf(x{}).PkgPath(), - RawDescriptor: file_pb_octopus_proto_rawDesc, + RawDescriptor: file_octopus_proto_rawDesc, NumEnums: 0, - NumMessages: 5, + NumMessages: 11, NumExtensions: 0, NumServices: 1, }, - GoTypes: file_pb_octopus_proto_goTypes, - DependencyIndexes: file_pb_octopus_proto_depIdxs, - MessageInfos: file_pb_octopus_proto_msgTypes, + GoTypes: file_octopus_proto_goTypes, + DependencyIndexes: file_octopus_proto_depIdxs, + MessageInfos: file_octopus_proto_msgTypes, }.Build() - File_pb_octopus_proto = out.File - file_pb_octopus_proto_rawDesc = nil - file_pb_octopus_proto_goTypes = nil - file_pb_octopus_proto_depIdxs = nil + File_octopus_proto = out.File + file_octopus_proto_rawDesc = nil + file_octopus_proto_goTypes = nil + file_octopus_proto_depIdxs = nil } diff --git a/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus/octopus_grpc.pb.go b/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus/octopus_grpc.pb.go index 691aa4f0..9c2a1334 100644 --- a/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus/octopus_grpc.pb.go +++ b/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus/octopus_grpc.pb.go @@ -2,7 +2,7 @@ // versions: // - protoc-gen-go-grpc v1.2.0 // - protoc v3.19.4 -// source: pb/octopus.proto +// source: octopus.proto package octopus @@ -24,8 +24,9 @@ const _ = grpc.SupportPackageIsVersion7 type OctopusClient interface { GetComputingPower(ctx context.Context, in *ResourceReq, opts ...grpc.CallOption) (*CpResp, error) GetGeneralInfo(ctx context.Context, in *ResourceReq, opts ...grpc.CallOption) (*GiResp, error) - // get modelarts Token CreateDataSet(ctx context.Context, in *CreateDataSetReq, opts ...grpc.CallOption) (*CreateDataSetResq, error) + // ImageService + GetUserImageList(ctx context.Context, in *GetUserImageListReq, opts ...grpc.CallOption) (*GetUserImageListResp, error) } type octopusClient struct { @@ -63,14 +64,24 @@ func (c *octopusClient) CreateDataSet(ctx context.Context, in *CreateDataSetReq, return out, nil } +func (c *octopusClient) GetUserImageList(ctx context.Context, in *GetUserImageListReq, opts ...grpc.CallOption) (*GetUserImageListResp, error) { + out := new(GetUserImageListResp) + err := c.cc.Invoke(ctx, "/octopus.Octopus/GetUserImageList", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + // OctopusServer is the server API for Octopus service. // All implementations must embed UnimplementedOctopusServer // for forward compatibility type OctopusServer interface { GetComputingPower(context.Context, *ResourceReq) (*CpResp, error) GetGeneralInfo(context.Context, *ResourceReq) (*GiResp, error) - // get modelarts Token CreateDataSet(context.Context, *CreateDataSetReq) (*CreateDataSetResq, error) + // ImageService + GetUserImageList(context.Context, *GetUserImageListReq) (*GetUserImageListResp, error) mustEmbedUnimplementedOctopusServer() } @@ -87,6 +98,9 @@ func (UnimplementedOctopusServer) GetGeneralInfo(context.Context, *ResourceReq) func (UnimplementedOctopusServer) CreateDataSet(context.Context, *CreateDataSetReq) (*CreateDataSetResq, error) { return nil, status.Errorf(codes.Unimplemented, "method CreateDataSet not implemented") } +func (UnimplementedOctopusServer) GetUserImageList(context.Context, *GetUserImageListReq) (*GetUserImageListResp, error) { + return nil, status.Errorf(codes.Unimplemented, "method GetUserImageList not implemented") +} func (UnimplementedOctopusServer) mustEmbedUnimplementedOctopusServer() {} // UnsafeOctopusServer may be embedded to opt out of forward compatibility for this service. @@ -154,6 +168,24 @@ func _Octopus_CreateDataSet_Handler(srv interface{}, ctx context.Context, dec fu return interceptor(ctx, in, info, handler) } +func _Octopus_GetUserImageList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(GetUserImageListReq) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(OctopusServer).GetUserImageList(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/octopus.Octopus/GetUserImageList", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(OctopusServer).GetUserImageList(ctx, req.(*GetUserImageListReq)) + } + return interceptor(ctx, in, info, handler) +} + // Octopus_ServiceDesc is the grpc.ServiceDesc for Octopus service. // It's only intended for direct use with grpc.RegisterService, // and not to be introspected or modified (even as a copy) @@ -173,7 +205,11 @@ var Octopus_ServiceDesc = grpc.ServiceDesc{ MethodName: "CreateDataSet", Handler: _Octopus_CreateDataSet_Handler, }, + { + MethodName: "GetUserImageList", + Handler: _Octopus_GetUserImageList_Handler, + }, }, Streams: []grpc.StreamDesc{}, - Metadata: "pb/octopus.proto", + Metadata: "octopus.proto", } diff --git a/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopusclient/octopus.go b/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopusclient/octopus.go index 0950107e..586969a6 100644 --- a/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopusclient/octopus.go +++ b/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopusclient/octopus.go @@ -13,17 +13,24 @@ import ( ) type ( - CpResp = octopus.CpResp - CreateDataSetReq = octopus.CreateDataSetReq - CreateDataSetResq = octopus.CreateDataSetResq - GiResp = octopus.GiResp - ResourceReq = octopus.ResourceReq + CpResp = octopus.CpResp + CreateDataSetReq = octopus.CreateDataSetReq + CreateDataSetResq = octopus.CreateDataSetResq + Error = octopus.Error + GetUserImageListReq = octopus.GetUserImageListReq + GetUserImageListResp = octopus.GetUserImageListResp + GiResp = octopus.GiResp + Image = octopus.Image + Images = octopus.Images + Payload = octopus.Payload + ResourceReq = octopus.ResourceReq Octopus interface { GetComputingPower(ctx context.Context, in *ResourceReq, opts ...grpc.CallOption) (*CpResp, error) GetGeneralInfo(ctx context.Context, in *ResourceReq, opts ...grpc.CallOption) (*GiResp, error) - // get modelarts Token CreateDataSet(ctx context.Context, in *CreateDataSetReq, opts ...grpc.CallOption) (*CreateDataSetResq, error) + // ImageService + GetUserImageList(ctx context.Context, in *GetUserImageListReq, opts ...grpc.CallOption) (*GetUserImageListResp, error) } defaultOctopus struct { @@ -47,8 +54,13 @@ func (m *defaultOctopus) GetGeneralInfo(ctx context.Context, in *ResourceReq, op return client.GetGeneralInfo(ctx, in, opts...) } -// get modelarts Token func (m *defaultOctopus) CreateDataSet(ctx context.Context, in *CreateDataSetReq, opts ...grpc.CallOption) (*CreateDataSetResq, error) { client := octopus.NewOctopusClient(m.cli.Conn()) return client.CreateDataSet(ctx, in, opts...) } + +// ImageService +func (m *defaultOctopus) GetUserImageList(ctx context.Context, in *GetUserImageListReq, opts ...grpc.CallOption) (*GetUserImageListResp, error) { + client := octopus.NewOctopusClient(m.cli.Conn()) + return client.GetUserImageList(ctx, in, opts...) +} diff --git a/adaptor/PCM-AI/PCM-OCTOPUS/rpc/pb/octopus.proto b/adaptor/PCM-AI/PCM-OCTOPUS/rpc/pb/octopus.proto index 30fca4c5..73707235 100644 --- a/adaptor/PCM-AI/PCM-OCTOPUS/rpc/pb/octopus.proto +++ b/adaptor/PCM-AI/PCM-OCTOPUS/rpc/pb/octopus.proto @@ -30,12 +30,92 @@ message CreateDataSetResq{ string version =2; // @gotags: copier:"Version" } +/******************Algorithm Start*************************/ +/******************Algorithm End*************************/ + +/******************DatasetService Start*************************/ +/******************DatasetService End*************************/ + +/******************ModelDeployService Start*************************/ +/******************ModelDeployService End*************************/ + +/******************Develop Start*************************/ +/******************Develop End*************************/ + +/******************ImageService Start*************************/ +message GetUserImageListReq{ + string platform =1; + int32 pageIndex =2; + int32 pageSize =3; +} + +message GetUserImageListResp{ + bool success =1; + Payload payload =2; + Error error = 3; +} + +message Error{ + int32 code =1; + int32 subcode =2; + string message =3; + string subMessage =4; +} + +message Payload{ + int32 totalSize =1; + repeated Images images =2; +} + +message Images{ + bool isShared =1; + Image image =2; +} + +message Image{ + string id =1; + string imageName =2; + string imageDesc = 3; + string imageAddr = 4; + int32 sourceType = 5; + string spaceId = 6; + string userId = 7; + int64 createdAt = 8; + int64 updatedAt = 9; + int32 imageStatus = 10; + string username = 11; + string imageVersion = 12; + string imageFullAddr = 13; +} + +/******************ImageService End*************************/ + +/******************Model Start*************************/ +/******************Model End*************************/ + +/******************TrainJobService Start*************************/ +/******************TrainJobService End*************************/ + + service Octopus { rpc GetComputingPower(resourceReq) returns (cpResp); rpc GetGeneralInfo(resourceReq) returns (giResp); - //get modelarts Token rpc CreateDataSet(CreateDataSetReq) returns (CreateDataSetResq); + + //Algorithm + + //DatasetService + + //ModelDeployService + //Develop + + //ImageService + rpc GetUserImageList(GetUserImageListReq) returns (GetUserImageListResp); + + //Model + //TrainJobService + } \ No newline at end of file