floraachy
/
pcm-coordinator
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

octopus 添加用户镜像列表接口

This commit is contained in:
tzwang 2023-05-10 15:54:23 +08:00
parent 32c6bb764d
commit 711454c41c
9 changed files with 911 additions and 109 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common/tokenService.go
View File

@ -22,6 +22,7 @@ type TokenTimePair struct {
var (
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
}

7
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/config/config.go
View File

@ -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
}

4
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/config/octopusConfig.go
View File

@ -12,3 +12,7 @@ type OctopusConfig struct {
EnflameT20 int32
OctopusCp string
}
type OctopusApi struct {
GetUserImageList string
}

50
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/getuserimagelistlogic.go Normal file
View File

@ -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
}

7
adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/server/octopusserver.go
View File

@ -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)
}

777
adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus/octopus.pb.go
View File

@ -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{}{
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
}

44
adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus/octopus_grpc.pb.go
View File

@ -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",
}

16
adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopusclient/octopus.go
View File

@ -16,14 +16,21 @@ type (
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...)
}

82
adaptor/PCM-AI/PCM-OCTOPUS/rpc/pb/octopus.proto
View File

@ -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
}