启智章鱼接口更新

Former-commit-id: 0fa8da48b772b64f91aecc40c207a54f006589fc
This commit is contained in:
tzwang 2023-05-22 11:23:47 +08:00
parent 21619f7bf5
commit 3ce935fc4d
12 changed files with 3159 additions and 774 deletions

View File

@ -34,4 +34,10 @@ type OctopusApi struct {
UploadAlgorithmConfirm string UploadAlgorithmConfirm string
UploadImage string UploadImage string
UploadImageConfirm string UploadImageConfirm string
UploadDataSet string
UploadDataSetConfirm string
CreateDataSetVersion string
DeleteDataSetVersion string
GetDatasetVersionList string
DeleteNotebook string
} }

View File

@ -0,0 +1,48 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
type CreateDataSetVersionLogic struct {
ctx context.Context
svcCtx *svc.ServiceContext
logx.Logger
}
func NewCreateDataSetVersionLogic(ctx context.Context, svcCtx *svc.ServiceContext) *CreateDataSetVersionLogic {
return &CreateDataSetVersionLogic{
ctx: ctx,
svcCtx: svcCtx,
Logger: logx.WithContext(ctx),
}
}
func (l *CreateDataSetVersionLogic) CreateDataSetVersion(in *octopus.CreateDataSetVersionReq) (*octopus.CreateDataSetVersionResp, error) {
resp := &octopus.CreateDataSetVersionResp{}
var url_prefix = common.OctopusUrls[in.Platform]
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.CreateDataSetVersion
token := common.GetToken(in.Platform)
req := tool.GetACHttpRequest()
_, err := req.
SetHeader("Authorization", "Bearer "+token).
SetPathParam("datasetId", in.DatasetId).
SetBody(in.Desc).
SetResult(resp).
Post(reqUrl)
if err != nil {
return nil, err
}
return resp, nil
}

View File

@ -0,0 +1,48 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
type DeleteDataSetVersionLogic struct {
ctx context.Context
svcCtx *svc.ServiceContext
logx.Logger
}
func NewDeleteDataSetVersionLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeleteDataSetVersionLogic {
return &DeleteDataSetVersionLogic{
ctx: ctx,
svcCtx: svcCtx,
Logger: logx.WithContext(ctx),
}
}
func (l *DeleteDataSetVersionLogic) DeleteDataSetVersion(in *octopus.DeleteDataSetVersionReq) (*octopus.DeleteDataSetVersionResp, error) {
resp := &octopus.DeleteDataSetVersionResp{}
var url_prefix = common.OctopusUrls[in.Platform]
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.DeleteDataSetVersion
token := common.GetToken(in.Platform)
req := tool.GetACHttpRequest()
_, err := req.
SetHeader("Authorization", "Bearer "+token).
SetPathParam("datasetId", in.DatasetId).
SetPathParam("version", in.Version).
SetResult(resp).
Delete(reqUrl)
if err != nil {
return nil, err
}
return resp, nil
}

View File

@ -0,0 +1,47 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
type DeleteNotebookLogic struct {
ctx context.Context
svcCtx *svc.ServiceContext
logx.Logger
}
func NewDeleteNotebookLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeleteNotebookLogic {
return &DeleteNotebookLogic{
ctx: ctx,
svcCtx: svcCtx,
Logger: logx.WithContext(ctx),
}
}
func (l *DeleteNotebookLogic) DeleteNotebook(in *octopus.DeleteNotebookReq) (*octopus.DeleteNotebookResp, error) {
resp := &octopus.DeleteNotebookResp{}
var url_prefix = common.OctopusUrls[in.Platform]
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.DeleteNotebook
token := common.GetToken(in.Platform)
req := tool.GetACHttpRequest()
_, err := req.
SetHeader("Authorization", "Bearer "+token).
SetPathParam("id", in.Id).
SetResult(resp).
Delete(reqUrl)
if err != nil {
return nil, err
}
return resp, nil
}

View File

@ -0,0 +1,51 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"strconv"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
type GetDatasetVersionListLogic struct {
ctx context.Context
svcCtx *svc.ServiceContext
logx.Logger
}
func NewGetDatasetVersionListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetDatasetVersionListLogic {
return &GetDatasetVersionListLogic{
ctx: ctx,
svcCtx: svcCtx,
Logger: logx.WithContext(ctx),
}
}
func (l *GetDatasetVersionListLogic) GetDatasetVersionList(in *octopus.GetDatasetVersionListReq) (*octopus.GetDatasetVersionListResp, error) {
resp := &octopus.GetDatasetVersionListResp{}
var url_prefix = common.OctopusUrls[in.Platform]
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.GetDatasetVersionList
token := common.GetToken(in.Platform)
req := tool.GetACHttpRequest()
_, err := req.
SetHeader("Authorization", "Bearer "+token).
SetPathParam("datasetId", in.DatasetId).
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
}

View File

@ -0,0 +1,49 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
type UploadDataSetConfirmLogic struct {
ctx context.Context
svcCtx *svc.ServiceContext
logx.Logger
}
func NewUploadDataSetConfirmLogic(ctx context.Context, svcCtx *svc.ServiceContext) *UploadDataSetConfirmLogic {
return &UploadDataSetConfirmLogic{
ctx: ctx,
svcCtx: svcCtx,
Logger: logx.WithContext(ctx),
}
}
func (l *UploadDataSetConfirmLogic) UploadDataSetConfirm(in *octopus.UploadDataSetConfirmReq) (*octopus.UploadDataSetConfirmResp, error) {
resp := &octopus.UploadDataSetConfirmResp{}
var url_prefix = common.OctopusUrls[in.Platform]
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.UploadAlgorithmConfirm
token := common.GetToken(in.Platform)
req := tool.GetACHttpRequest()
_, err := req.
SetHeader("Authorization", "Bearer "+token).
SetPathParam("datasetId", in.DatasetId).
SetPathParam("version", in.Version).
SetBody(in.FileName).
SetResult(resp).
Put(reqUrl)
if err != nil {
return nil, err
}
return resp, nil
}

View File

@ -0,0 +1,49 @@
package logic
import (
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/common"
"PCM/common/tool"
"context"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/svc"
"PCM/adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopus"
"github.com/zeromicro/go-zero/core/logx"
)
type UploadDataSetLogic struct {
ctx context.Context
svcCtx *svc.ServiceContext
logx.Logger
}
func NewUploadDataSetLogic(ctx context.Context, svcCtx *svc.ServiceContext) *UploadDataSetLogic {
return &UploadDataSetLogic{
ctx: ctx,
svcCtx: svcCtx,
Logger: logx.WithContext(ctx),
}
}
func (l *UploadDataSetLogic) UploadDataSet(in *octopus.UploadDataSetReq) (*octopus.UploadDataSetResp, error) {
resp := &octopus.UploadDataSetResp{}
var url_prefix = common.OctopusUrls[in.Platform]
var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.UploadDataSet
token := common.GetToken(in.Platform)
req := tool.GetACHttpRequest()
_, err := req.
SetHeader("Authorization", "Bearer "+token).
SetPathParam("datasetId", in.DatasetId).
SetPathParam("version", in.Version).
SetBody(in.UploadDataSetParam).
SetResult(resp).
Post(reqUrl)
if err != nil {
return nil, err
}
return resp, nil
}

View File

@ -89,6 +89,11 @@ func (s *OctopusServer) GetMyDatasetList(ctx context.Context, in *octopus.GetMyD
return l.GetMyDatasetList(in) return l.GetMyDatasetList(in)
} }
func (s *OctopusServer) GetDatasetVersionList(ctx context.Context, in *octopus.GetDatasetVersionListReq) (*octopus.GetDatasetVersionListResp, error) {
l := logic.NewGetDatasetVersionListLogic(ctx, s.svcCtx)
return l.GetDatasetVersionList(in)
}
func (s *OctopusServer) CreateDataSet(ctx context.Context, in *octopus.CreateDataSetReq) (*octopus.CreateDataSetResp, error) { func (s *OctopusServer) CreateDataSet(ctx context.Context, in *octopus.CreateDataSetReq) (*octopus.CreateDataSetResp, error) {
l := logic.NewCreateDataSetLogic(ctx, s.svcCtx) l := logic.NewCreateDataSetLogic(ctx, s.svcCtx)
return l.CreateDataSet(in) return l.CreateDataSet(in)
@ -99,12 +104,37 @@ func (s *OctopusServer) DeleteDataSet(ctx context.Context, in *octopus.DeleteDat
return l.DeleteDataSet(in) return l.DeleteDataSet(in)
} }
func (s *OctopusServer) UploadDataSet(ctx context.Context, in *octopus.UploadDataSetReq) (*octopus.UploadDataSetResp, error) {
l := logic.NewUploadDataSetLogic(ctx, s.svcCtx)
return l.UploadDataSet(in)
}
func (s *OctopusServer) UploadDataSetConfirm(ctx context.Context, in *octopus.UploadDataSetConfirmReq) (*octopus.UploadDataSetConfirmResp, error) {
l := logic.NewUploadDataSetConfirmLogic(ctx, s.svcCtx)
return l.UploadDataSetConfirm(in)
}
func (s *OctopusServer) CreateDataSetVersion(ctx context.Context, in *octopus.CreateDataSetVersionReq) (*octopus.CreateDataSetVersionResp, error) {
l := logic.NewCreateDataSetVersionLogic(ctx, s.svcCtx)
return l.CreateDataSetVersion(in)
}
func (s *OctopusServer) DeleteDataSetVersion(ctx context.Context, in *octopus.DeleteDataSetVersionReq) (*octopus.DeleteDataSetVersionResp, error) {
l := logic.NewDeleteDataSetVersionLogic(ctx, s.svcCtx)
return l.DeleteDataSetVersion(in)
}
// ModelDeployService // ModelDeployService
func (s *OctopusServer) GetNotebookList(ctx context.Context, in *octopus.GetNotebookListReq) (*octopus.GetNotebookListResp, error) { func (s *OctopusServer) GetNotebookList(ctx context.Context, in *octopus.GetNotebookListReq) (*octopus.GetNotebookListResp, error) {
l := logic.NewGetNotebookListLogic(ctx, s.svcCtx) l := logic.NewGetNotebookListLogic(ctx, s.svcCtx)
return l.GetNotebookList(in) return l.GetNotebookList(in)
} }
func (s *OctopusServer) DeleteNotebook(ctx context.Context, in *octopus.DeleteNotebookReq) (*octopus.DeleteNotebookResp, error) {
l := logic.NewDeleteNotebookLogic(ctx, s.svcCtx)
return l.DeleteNotebook(in)
}
// ImageService // ImageService
func (s *OctopusServer) GetUserImageList(ctx context.Context, in *octopus.GetUserImageListReq) (*octopus.GetUserImageListResp, error) { func (s *OctopusServer) GetUserImageList(ctx context.Context, in *octopus.GetUserImageListReq) (*octopus.GetUserImageListResp, error) {
l := logic.NewGetUserImageListLogic(ctx, s.svcCtx) l := logic.NewGetUserImageListLogic(ctx, s.svcCtx)

File diff suppressed because it is too large Load Diff

View File

@ -1,6 +1,6 @@
// Code generated by protoc-gen-go-grpc. DO NOT EDIT. // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions: // versions:
// - protoc-gen-go-grpc v1.3.0 // - protoc-gen-go-grpc v1.2.0
// - protoc v3.19.4 // - protoc v3.19.4
// source: octopus.proto // source: octopus.proto
@ -18,37 +18,13 @@ import (
// Requires gRPC-Go v1.32.0 or later. // Requires gRPC-Go v1.32.0 or later.
const _ = grpc.SupportPackageIsVersion7 const _ = grpc.SupportPackageIsVersion7
const (
Octopus_GetComputingPower_FullMethodName = "/octopus.Octopus/GetComputingPower"
Octopus_GetGeneralInfo_FullMethodName = "/octopus.Octopus/GetGeneralInfo"
Octopus_GetMyAlgorithmList_FullMethodName = "/octopus.Octopus/GetMyAlgorithmList"
Octopus_GetAlgorithmList_FullMethodName = "/octopus.Octopus/GetAlgorithmList"
Octopus_GetAlgorithm_FullMethodName = "/octopus.Octopus/GetAlgorithm"
Octopus_GetAlgorithmApplyList_FullMethodName = "/octopus.Octopus/GetAlgorithmApplyList"
Octopus_GetAlgorithmFrameworkList_FullMethodName = "/octopus.Octopus/GetAlgorithmFrameworkList"
Octopus_DeleteMyAlgorithm_FullMethodName = "/octopus.Octopus/DeleteMyAlgorithm"
Octopus_CreateMyAlgorithm_FullMethodName = "/octopus.Octopus/CreateMyAlgorithm"
Octopus_DownloadAlgorithm_FullMethodName = "/octopus.Octopus/DownloadAlgorithm"
Octopus_UploadAlgorithm_FullMethodName = "/octopus.Octopus/UploadAlgorithm"
Octopus_UploadAlgorithmConfirm_FullMethodName = "/octopus.Octopus/UploadAlgorithmConfirm"
Octopus_GetMyDatasetList_FullMethodName = "/octopus.Octopus/GetMyDatasetList"
Octopus_CreateDataSet_FullMethodName = "/octopus.Octopus/CreateDataSet"
Octopus_DeleteDataSet_FullMethodName = "/octopus.Octopus/DeleteDataSet"
Octopus_GetNotebookList_FullMethodName = "/octopus.Octopus/GetNotebookList"
Octopus_GetUserImageList_FullMethodName = "/octopus.Octopus/GetUserImageList"
Octopus_CreateImage_FullMethodName = "/octopus.Octopus/CreateImage"
Octopus_DeleteImage_FullMethodName = "/octopus.Octopus/DeleteImage"
Octopus_UploadImage_FullMethodName = "/octopus.Octopus/UploadImage"
Octopus_UploadImageConfirm_FullMethodName = "/octopus.Octopus/UploadImageConfirm"
)
// OctopusClient is the client API for Octopus service. // OctopusClient is the client API for Octopus service.
// //
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
type OctopusClient interface { type OctopusClient interface {
GetComputingPower(ctx context.Context, in *ResourceReq, opts ...grpc.CallOption) (*CpResp, error) GetComputingPower(ctx context.Context, in *ResourceReq, opts ...grpc.CallOption) (*CpResp, error)
GetGeneralInfo(ctx context.Context, in *ResourceReq, opts ...grpc.CallOption) (*GiResp, error) GetGeneralInfo(ctx context.Context, in *ResourceReq, opts ...grpc.CallOption) (*GiResp, error)
//Algorithm // Algorithm
GetMyAlgorithmList(ctx context.Context, in *GetMyAlgorithmListReq, opts ...grpc.CallOption) (*GetMyAlgorithmListResp, error) GetMyAlgorithmList(ctx context.Context, in *GetMyAlgorithmListReq, opts ...grpc.CallOption) (*GetMyAlgorithmListResp, error)
GetAlgorithmList(ctx context.Context, in *GetAlgorithmListReq, opts ...grpc.CallOption) (*GetAlgorithmListResp, error) GetAlgorithmList(ctx context.Context, in *GetAlgorithmListReq, opts ...grpc.CallOption) (*GetAlgorithmListResp, error)
GetAlgorithm(ctx context.Context, in *GetAlgorithmReq, opts ...grpc.CallOption) (*GetAlgorithmResp, error) GetAlgorithm(ctx context.Context, in *GetAlgorithmReq, opts ...grpc.CallOption) (*GetAlgorithmResp, error)
@ -59,14 +35,20 @@ type OctopusClient interface {
DownloadAlgorithm(ctx context.Context, in *DownloadAlgorithmReq, opts ...grpc.CallOption) (*DownloadAlgorithmResp, error) DownloadAlgorithm(ctx context.Context, in *DownloadAlgorithmReq, opts ...grpc.CallOption) (*DownloadAlgorithmResp, error)
UploadAlgorithm(ctx context.Context, in *UploadAlgorithmReq, opts ...grpc.CallOption) (*UploadAlgorithmResp, error) UploadAlgorithm(ctx context.Context, in *UploadAlgorithmReq, opts ...grpc.CallOption) (*UploadAlgorithmResp, error)
UploadAlgorithmConfirm(ctx context.Context, in *UploadAlgorithmConfirmReq, opts ...grpc.CallOption) (*UploadAlgorithmConfirmResp, error) UploadAlgorithmConfirm(ctx context.Context, in *UploadAlgorithmConfirmReq, opts ...grpc.CallOption) (*UploadAlgorithmConfirmResp, error)
//DatasetService // DatasetService
GetMyDatasetList(ctx context.Context, in *GetMyDatasetListReq, opts ...grpc.CallOption) (*GetMyDatasetListResp, error) GetMyDatasetList(ctx context.Context, in *GetMyDatasetListReq, opts ...grpc.CallOption) (*GetMyDatasetListResp, error)
GetDatasetVersionList(ctx context.Context, in *GetDatasetVersionListReq, opts ...grpc.CallOption) (*GetDatasetVersionListResp, error)
CreateDataSet(ctx context.Context, in *CreateDataSetReq, opts ...grpc.CallOption) (*CreateDataSetResp, error) CreateDataSet(ctx context.Context, in *CreateDataSetReq, opts ...grpc.CallOption) (*CreateDataSetResp, error)
DeleteDataSet(ctx context.Context, in *DeleteDataSetReq, opts ...grpc.CallOption) (*DeleteDataSetResp, error) DeleteDataSet(ctx context.Context, in *DeleteDataSetReq, opts ...grpc.CallOption) (*DeleteDataSetResp, error)
//ModelDeployService UploadDataSet(ctx context.Context, in *UploadDataSetReq, opts ...grpc.CallOption) (*UploadDataSetResp, error)
//Develop UploadDataSetConfirm(ctx context.Context, in *UploadDataSetConfirmReq, opts ...grpc.CallOption) (*UploadDataSetConfirmResp, error)
CreateDataSetVersion(ctx context.Context, in *CreateDataSetVersionReq, opts ...grpc.CallOption) (*CreateDataSetVersionResp, error)
DeleteDataSetVersion(ctx context.Context, in *DeleteDataSetVersionReq, opts ...grpc.CallOption) (*DeleteDataSetVersionResp, error)
// ModelDeployService
// Develop
GetNotebookList(ctx context.Context, in *GetNotebookListReq, opts ...grpc.CallOption) (*GetNotebookListResp, error) GetNotebookList(ctx context.Context, in *GetNotebookListReq, opts ...grpc.CallOption) (*GetNotebookListResp, error)
//ImageService DeleteNotebook(ctx context.Context, in *DeleteNotebookReq, opts ...grpc.CallOption) (*DeleteNotebookResp, error)
// ImageService
GetUserImageList(ctx context.Context, in *GetUserImageListReq, opts ...grpc.CallOption) (*GetUserImageListResp, error) GetUserImageList(ctx context.Context, in *GetUserImageListReq, opts ...grpc.CallOption) (*GetUserImageListResp, error)
CreateImage(ctx context.Context, in *CreateImageReq, opts ...grpc.CallOption) (*CreateImageResp, error) CreateImage(ctx context.Context, in *CreateImageReq, opts ...grpc.CallOption) (*CreateImageResp, error)
DeleteImage(ctx context.Context, in *DeleteImageReq, opts ...grpc.CallOption) (*DeleteImageResp, error) DeleteImage(ctx context.Context, in *DeleteImageReq, opts ...grpc.CallOption) (*DeleteImageResp, error)
@ -84,7 +66,7 @@ func NewOctopusClient(cc grpc.ClientConnInterface) OctopusClient {
func (c *octopusClient) GetComputingPower(ctx context.Context, in *ResourceReq, opts ...grpc.CallOption) (*CpResp, error) { func (c *octopusClient) GetComputingPower(ctx context.Context, in *ResourceReq, opts ...grpc.CallOption) (*CpResp, error) {
out := new(CpResp) out := new(CpResp)
err := c.cc.Invoke(ctx, Octopus_GetComputingPower_FullMethodName, in, out, opts...) err := c.cc.Invoke(ctx, "/octopus.Octopus/GetComputingPower", in, out, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -93,7 +75,7 @@ func (c *octopusClient) GetComputingPower(ctx context.Context, in *ResourceReq,
func (c *octopusClient) GetGeneralInfo(ctx context.Context, in *ResourceReq, opts ...grpc.CallOption) (*GiResp, error) { func (c *octopusClient) GetGeneralInfo(ctx context.Context, in *ResourceReq, opts ...grpc.CallOption) (*GiResp, error) {
out := new(GiResp) out := new(GiResp)
err := c.cc.Invoke(ctx, Octopus_GetGeneralInfo_FullMethodName, in, out, opts...) err := c.cc.Invoke(ctx, "/octopus.Octopus/GetGeneralInfo", in, out, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -102,7 +84,7 @@ func (c *octopusClient) GetGeneralInfo(ctx context.Context, in *ResourceReq, opt
func (c *octopusClient) GetMyAlgorithmList(ctx context.Context, in *GetMyAlgorithmListReq, opts ...grpc.CallOption) (*GetMyAlgorithmListResp, error) { func (c *octopusClient) GetMyAlgorithmList(ctx context.Context, in *GetMyAlgorithmListReq, opts ...grpc.CallOption) (*GetMyAlgorithmListResp, error) {
out := new(GetMyAlgorithmListResp) out := new(GetMyAlgorithmListResp)
err := c.cc.Invoke(ctx, Octopus_GetMyAlgorithmList_FullMethodName, in, out, opts...) err := c.cc.Invoke(ctx, "/octopus.Octopus/GetMyAlgorithmList", in, out, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -111,7 +93,7 @@ func (c *octopusClient) GetMyAlgorithmList(ctx context.Context, in *GetMyAlgorit
func (c *octopusClient) GetAlgorithmList(ctx context.Context, in *GetAlgorithmListReq, opts ...grpc.CallOption) (*GetAlgorithmListResp, error) { func (c *octopusClient) GetAlgorithmList(ctx context.Context, in *GetAlgorithmListReq, opts ...grpc.CallOption) (*GetAlgorithmListResp, error) {
out := new(GetAlgorithmListResp) out := new(GetAlgorithmListResp)
err := c.cc.Invoke(ctx, Octopus_GetAlgorithmList_FullMethodName, in, out, opts...) err := c.cc.Invoke(ctx, "/octopus.Octopus/GetAlgorithmList", in, out, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -120,7 +102,7 @@ func (c *octopusClient) GetAlgorithmList(ctx context.Context, in *GetAlgorithmLi
func (c *octopusClient) GetAlgorithm(ctx context.Context, in *GetAlgorithmReq, opts ...grpc.CallOption) (*GetAlgorithmResp, error) { func (c *octopusClient) GetAlgorithm(ctx context.Context, in *GetAlgorithmReq, opts ...grpc.CallOption) (*GetAlgorithmResp, error) {
out := new(GetAlgorithmResp) out := new(GetAlgorithmResp)
err := c.cc.Invoke(ctx, Octopus_GetAlgorithm_FullMethodName, in, out, opts...) err := c.cc.Invoke(ctx, "/octopus.Octopus/GetAlgorithm", in, out, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -129,7 +111,7 @@ func (c *octopusClient) GetAlgorithm(ctx context.Context, in *GetAlgorithmReq, o
func (c *octopusClient) GetAlgorithmApplyList(ctx context.Context, in *GetAlgorithmApplyListReq, opts ...grpc.CallOption) (*GetAlgorithmApplyListResp, error) { func (c *octopusClient) GetAlgorithmApplyList(ctx context.Context, in *GetAlgorithmApplyListReq, opts ...grpc.CallOption) (*GetAlgorithmApplyListResp, error) {
out := new(GetAlgorithmApplyListResp) out := new(GetAlgorithmApplyListResp)
err := c.cc.Invoke(ctx, Octopus_GetAlgorithmApplyList_FullMethodName, in, out, opts...) err := c.cc.Invoke(ctx, "/octopus.Octopus/GetAlgorithmApplyList", in, out, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -138,7 +120,7 @@ func (c *octopusClient) GetAlgorithmApplyList(ctx context.Context, in *GetAlgori
func (c *octopusClient) GetAlgorithmFrameworkList(ctx context.Context, in *GetAlgorithmFrameworkListReq, opts ...grpc.CallOption) (*GetAlgorithmFrameworkListResp, error) { func (c *octopusClient) GetAlgorithmFrameworkList(ctx context.Context, in *GetAlgorithmFrameworkListReq, opts ...grpc.CallOption) (*GetAlgorithmFrameworkListResp, error) {
out := new(GetAlgorithmFrameworkListResp) out := new(GetAlgorithmFrameworkListResp)
err := c.cc.Invoke(ctx, Octopus_GetAlgorithmFrameworkList_FullMethodName, in, out, opts...) err := c.cc.Invoke(ctx, "/octopus.Octopus/GetAlgorithmFrameworkList", in, out, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -147,7 +129,7 @@ func (c *octopusClient) GetAlgorithmFrameworkList(ctx context.Context, in *GetAl
func (c *octopusClient) DeleteMyAlgorithm(ctx context.Context, in *DeleteMyAlgorithmReq, opts ...grpc.CallOption) (*DeleteMyAlgorithmResp, error) { func (c *octopusClient) DeleteMyAlgorithm(ctx context.Context, in *DeleteMyAlgorithmReq, opts ...grpc.CallOption) (*DeleteMyAlgorithmResp, error) {
out := new(DeleteMyAlgorithmResp) out := new(DeleteMyAlgorithmResp)
err := c.cc.Invoke(ctx, Octopus_DeleteMyAlgorithm_FullMethodName, in, out, opts...) err := c.cc.Invoke(ctx, "/octopus.Octopus/DeleteMyAlgorithm", in, out, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -156,7 +138,7 @@ func (c *octopusClient) DeleteMyAlgorithm(ctx context.Context, in *DeleteMyAlgor
func (c *octopusClient) CreateMyAlgorithm(ctx context.Context, in *CreateMyAlgorithmReq, opts ...grpc.CallOption) (*CreateMyAlgorithmResp, error) { func (c *octopusClient) CreateMyAlgorithm(ctx context.Context, in *CreateMyAlgorithmReq, opts ...grpc.CallOption) (*CreateMyAlgorithmResp, error) {
out := new(CreateMyAlgorithmResp) out := new(CreateMyAlgorithmResp)
err := c.cc.Invoke(ctx, Octopus_CreateMyAlgorithm_FullMethodName, in, out, opts...) err := c.cc.Invoke(ctx, "/octopus.Octopus/CreateMyAlgorithm", in, out, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -165,7 +147,7 @@ func (c *octopusClient) CreateMyAlgorithm(ctx context.Context, in *CreateMyAlgor
func (c *octopusClient) DownloadAlgorithm(ctx context.Context, in *DownloadAlgorithmReq, opts ...grpc.CallOption) (*DownloadAlgorithmResp, error) { func (c *octopusClient) DownloadAlgorithm(ctx context.Context, in *DownloadAlgorithmReq, opts ...grpc.CallOption) (*DownloadAlgorithmResp, error) {
out := new(DownloadAlgorithmResp) out := new(DownloadAlgorithmResp)
err := c.cc.Invoke(ctx, Octopus_DownloadAlgorithm_FullMethodName, in, out, opts...) err := c.cc.Invoke(ctx, "/octopus.Octopus/DownloadAlgorithm", in, out, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -174,7 +156,7 @@ func (c *octopusClient) DownloadAlgorithm(ctx context.Context, in *DownloadAlgor
func (c *octopusClient) UploadAlgorithm(ctx context.Context, in *UploadAlgorithmReq, opts ...grpc.CallOption) (*UploadAlgorithmResp, error) { func (c *octopusClient) UploadAlgorithm(ctx context.Context, in *UploadAlgorithmReq, opts ...grpc.CallOption) (*UploadAlgorithmResp, error) {
out := new(UploadAlgorithmResp) out := new(UploadAlgorithmResp)
err := c.cc.Invoke(ctx, Octopus_UploadAlgorithm_FullMethodName, in, out, opts...) err := c.cc.Invoke(ctx, "/octopus.Octopus/UploadAlgorithm", in, out, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -183,7 +165,7 @@ func (c *octopusClient) UploadAlgorithm(ctx context.Context, in *UploadAlgorithm
func (c *octopusClient) UploadAlgorithmConfirm(ctx context.Context, in *UploadAlgorithmConfirmReq, opts ...grpc.CallOption) (*UploadAlgorithmConfirmResp, error) { func (c *octopusClient) UploadAlgorithmConfirm(ctx context.Context, in *UploadAlgorithmConfirmReq, opts ...grpc.CallOption) (*UploadAlgorithmConfirmResp, error) {
out := new(UploadAlgorithmConfirmResp) out := new(UploadAlgorithmConfirmResp)
err := c.cc.Invoke(ctx, Octopus_UploadAlgorithmConfirm_FullMethodName, in, out, opts...) err := c.cc.Invoke(ctx, "/octopus.Octopus/UploadAlgorithmConfirm", in, out, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -192,7 +174,16 @@ func (c *octopusClient) UploadAlgorithmConfirm(ctx context.Context, in *UploadAl
func (c *octopusClient) GetMyDatasetList(ctx context.Context, in *GetMyDatasetListReq, opts ...grpc.CallOption) (*GetMyDatasetListResp, error) { func (c *octopusClient) GetMyDatasetList(ctx context.Context, in *GetMyDatasetListReq, opts ...grpc.CallOption) (*GetMyDatasetListResp, error) {
out := new(GetMyDatasetListResp) out := new(GetMyDatasetListResp)
err := c.cc.Invoke(ctx, Octopus_GetMyDatasetList_FullMethodName, in, out, opts...) err := c.cc.Invoke(ctx, "/octopus.Octopus/GetMyDatasetList", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *octopusClient) GetDatasetVersionList(ctx context.Context, in *GetDatasetVersionListReq, opts ...grpc.CallOption) (*GetDatasetVersionListResp, error) {
out := new(GetDatasetVersionListResp)
err := c.cc.Invoke(ctx, "/octopus.Octopus/GetDatasetVersionList", in, out, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -201,7 +192,7 @@ func (c *octopusClient) GetMyDatasetList(ctx context.Context, in *GetMyDatasetLi
func (c *octopusClient) CreateDataSet(ctx context.Context, in *CreateDataSetReq, opts ...grpc.CallOption) (*CreateDataSetResp, error) { func (c *octopusClient) CreateDataSet(ctx context.Context, in *CreateDataSetReq, opts ...grpc.CallOption) (*CreateDataSetResp, error) {
out := new(CreateDataSetResp) out := new(CreateDataSetResp)
err := c.cc.Invoke(ctx, Octopus_CreateDataSet_FullMethodName, in, out, opts...) err := c.cc.Invoke(ctx, "/octopus.Octopus/CreateDataSet", in, out, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -210,7 +201,43 @@ func (c *octopusClient) CreateDataSet(ctx context.Context, in *CreateDataSetReq,
func (c *octopusClient) DeleteDataSet(ctx context.Context, in *DeleteDataSetReq, opts ...grpc.CallOption) (*DeleteDataSetResp, error) { func (c *octopusClient) DeleteDataSet(ctx context.Context, in *DeleteDataSetReq, opts ...grpc.CallOption) (*DeleteDataSetResp, error) {
out := new(DeleteDataSetResp) out := new(DeleteDataSetResp)
err := c.cc.Invoke(ctx, Octopus_DeleteDataSet_FullMethodName, in, out, opts...) err := c.cc.Invoke(ctx, "/octopus.Octopus/DeleteDataSet", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *octopusClient) UploadDataSet(ctx context.Context, in *UploadDataSetReq, opts ...grpc.CallOption) (*UploadDataSetResp, error) {
out := new(UploadDataSetResp)
err := c.cc.Invoke(ctx, "/octopus.Octopus/UploadDataSet", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *octopusClient) UploadDataSetConfirm(ctx context.Context, in *UploadDataSetConfirmReq, opts ...grpc.CallOption) (*UploadDataSetConfirmResp, error) {
out := new(UploadDataSetConfirmResp)
err := c.cc.Invoke(ctx, "/octopus.Octopus/UploadDataSetConfirm", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *octopusClient) CreateDataSetVersion(ctx context.Context, in *CreateDataSetVersionReq, opts ...grpc.CallOption) (*CreateDataSetVersionResp, error) {
out := new(CreateDataSetVersionResp)
err := c.cc.Invoke(ctx, "/octopus.Octopus/CreateDataSetVersion", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *octopusClient) DeleteDataSetVersion(ctx context.Context, in *DeleteDataSetVersionReq, opts ...grpc.CallOption) (*DeleteDataSetVersionResp, error) {
out := new(DeleteDataSetVersionResp)
err := c.cc.Invoke(ctx, "/octopus.Octopus/DeleteDataSetVersion", in, out, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -219,7 +246,16 @@ func (c *octopusClient) DeleteDataSet(ctx context.Context, in *DeleteDataSetReq,
func (c *octopusClient) GetNotebookList(ctx context.Context, in *GetNotebookListReq, opts ...grpc.CallOption) (*GetNotebookListResp, error) { func (c *octopusClient) GetNotebookList(ctx context.Context, in *GetNotebookListReq, opts ...grpc.CallOption) (*GetNotebookListResp, error) {
out := new(GetNotebookListResp) out := new(GetNotebookListResp)
err := c.cc.Invoke(ctx, Octopus_GetNotebookList_FullMethodName, in, out, opts...) err := c.cc.Invoke(ctx, "/octopus.Octopus/GetNotebookList", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *octopusClient) DeleteNotebook(ctx context.Context, in *DeleteNotebookReq, opts ...grpc.CallOption) (*DeleteNotebookResp, error) {
out := new(DeleteNotebookResp)
err := c.cc.Invoke(ctx, "/octopus.Octopus/DeleteNotebook", in, out, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -228,7 +264,7 @@ func (c *octopusClient) GetNotebookList(ctx context.Context, in *GetNotebookList
func (c *octopusClient) GetUserImageList(ctx context.Context, in *GetUserImageListReq, opts ...grpc.CallOption) (*GetUserImageListResp, error) { func (c *octopusClient) GetUserImageList(ctx context.Context, in *GetUserImageListReq, opts ...grpc.CallOption) (*GetUserImageListResp, error) {
out := new(GetUserImageListResp) out := new(GetUserImageListResp)
err := c.cc.Invoke(ctx, Octopus_GetUserImageList_FullMethodName, in, out, opts...) err := c.cc.Invoke(ctx, "/octopus.Octopus/GetUserImageList", in, out, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -237,7 +273,7 @@ func (c *octopusClient) GetUserImageList(ctx context.Context, in *GetUserImageLi
func (c *octopusClient) CreateImage(ctx context.Context, in *CreateImageReq, opts ...grpc.CallOption) (*CreateImageResp, error) { func (c *octopusClient) CreateImage(ctx context.Context, in *CreateImageReq, opts ...grpc.CallOption) (*CreateImageResp, error) {
out := new(CreateImageResp) out := new(CreateImageResp)
err := c.cc.Invoke(ctx, Octopus_CreateImage_FullMethodName, in, out, opts...) err := c.cc.Invoke(ctx, "/octopus.Octopus/CreateImage", in, out, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -246,7 +282,7 @@ func (c *octopusClient) CreateImage(ctx context.Context, in *CreateImageReq, opt
func (c *octopusClient) DeleteImage(ctx context.Context, in *DeleteImageReq, opts ...grpc.CallOption) (*DeleteImageResp, error) { func (c *octopusClient) DeleteImage(ctx context.Context, in *DeleteImageReq, opts ...grpc.CallOption) (*DeleteImageResp, error) {
out := new(DeleteImageResp) out := new(DeleteImageResp)
err := c.cc.Invoke(ctx, Octopus_DeleteImage_FullMethodName, in, out, opts...) err := c.cc.Invoke(ctx, "/octopus.Octopus/DeleteImage", in, out, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -255,7 +291,7 @@ func (c *octopusClient) DeleteImage(ctx context.Context, in *DeleteImageReq, opt
func (c *octopusClient) UploadImage(ctx context.Context, in *UploadImageReq, opts ...grpc.CallOption) (*UploadImageResp, error) { func (c *octopusClient) UploadImage(ctx context.Context, in *UploadImageReq, opts ...grpc.CallOption) (*UploadImageResp, error) {
out := new(UploadImageResp) out := new(UploadImageResp)
err := c.cc.Invoke(ctx, Octopus_UploadImage_FullMethodName, in, out, opts...) err := c.cc.Invoke(ctx, "/octopus.Octopus/UploadImage", in, out, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -264,7 +300,7 @@ func (c *octopusClient) UploadImage(ctx context.Context, in *UploadImageReq, opt
func (c *octopusClient) UploadImageConfirm(ctx context.Context, in *UploadImageConfirmReq, opts ...grpc.CallOption) (*UploadImageConfirmResp, error) { func (c *octopusClient) UploadImageConfirm(ctx context.Context, in *UploadImageConfirmReq, opts ...grpc.CallOption) (*UploadImageConfirmResp, error) {
out := new(UploadImageConfirmResp) out := new(UploadImageConfirmResp)
err := c.cc.Invoke(ctx, Octopus_UploadImageConfirm_FullMethodName, in, out, opts...) err := c.cc.Invoke(ctx, "/octopus.Octopus/UploadImageConfirm", in, out, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -277,7 +313,7 @@ func (c *octopusClient) UploadImageConfirm(ctx context.Context, in *UploadImageC
type OctopusServer interface { type OctopusServer interface {
GetComputingPower(context.Context, *ResourceReq) (*CpResp, error) GetComputingPower(context.Context, *ResourceReq) (*CpResp, error)
GetGeneralInfo(context.Context, *ResourceReq) (*GiResp, error) GetGeneralInfo(context.Context, *ResourceReq) (*GiResp, error)
//Algorithm // Algorithm
GetMyAlgorithmList(context.Context, *GetMyAlgorithmListReq) (*GetMyAlgorithmListResp, error) GetMyAlgorithmList(context.Context, *GetMyAlgorithmListReq) (*GetMyAlgorithmListResp, error)
GetAlgorithmList(context.Context, *GetAlgorithmListReq) (*GetAlgorithmListResp, error) GetAlgorithmList(context.Context, *GetAlgorithmListReq) (*GetAlgorithmListResp, error)
GetAlgorithm(context.Context, *GetAlgorithmReq) (*GetAlgorithmResp, error) GetAlgorithm(context.Context, *GetAlgorithmReq) (*GetAlgorithmResp, error)
@ -288,14 +324,20 @@ type OctopusServer interface {
DownloadAlgorithm(context.Context, *DownloadAlgorithmReq) (*DownloadAlgorithmResp, error) DownloadAlgorithm(context.Context, *DownloadAlgorithmReq) (*DownloadAlgorithmResp, error)
UploadAlgorithm(context.Context, *UploadAlgorithmReq) (*UploadAlgorithmResp, error) UploadAlgorithm(context.Context, *UploadAlgorithmReq) (*UploadAlgorithmResp, error)
UploadAlgorithmConfirm(context.Context, *UploadAlgorithmConfirmReq) (*UploadAlgorithmConfirmResp, error) UploadAlgorithmConfirm(context.Context, *UploadAlgorithmConfirmReq) (*UploadAlgorithmConfirmResp, error)
//DatasetService // DatasetService
GetMyDatasetList(context.Context, *GetMyDatasetListReq) (*GetMyDatasetListResp, error) GetMyDatasetList(context.Context, *GetMyDatasetListReq) (*GetMyDatasetListResp, error)
GetDatasetVersionList(context.Context, *GetDatasetVersionListReq) (*GetDatasetVersionListResp, error)
CreateDataSet(context.Context, *CreateDataSetReq) (*CreateDataSetResp, error) CreateDataSet(context.Context, *CreateDataSetReq) (*CreateDataSetResp, error)
DeleteDataSet(context.Context, *DeleteDataSetReq) (*DeleteDataSetResp, error) DeleteDataSet(context.Context, *DeleteDataSetReq) (*DeleteDataSetResp, error)
//ModelDeployService UploadDataSet(context.Context, *UploadDataSetReq) (*UploadDataSetResp, error)
//Develop UploadDataSetConfirm(context.Context, *UploadDataSetConfirmReq) (*UploadDataSetConfirmResp, error)
CreateDataSetVersion(context.Context, *CreateDataSetVersionReq) (*CreateDataSetVersionResp, error)
DeleteDataSetVersion(context.Context, *DeleteDataSetVersionReq) (*DeleteDataSetVersionResp, error)
// ModelDeployService
// Develop
GetNotebookList(context.Context, *GetNotebookListReq) (*GetNotebookListResp, error) GetNotebookList(context.Context, *GetNotebookListReq) (*GetNotebookListResp, error)
//ImageService DeleteNotebook(context.Context, *DeleteNotebookReq) (*DeleteNotebookResp, error)
// ImageService
GetUserImageList(context.Context, *GetUserImageListReq) (*GetUserImageListResp, error) GetUserImageList(context.Context, *GetUserImageListReq) (*GetUserImageListResp, error)
CreateImage(context.Context, *CreateImageReq) (*CreateImageResp, error) CreateImage(context.Context, *CreateImageReq) (*CreateImageResp, error)
DeleteImage(context.Context, *DeleteImageReq) (*DeleteImageResp, error) DeleteImage(context.Context, *DeleteImageReq) (*DeleteImageResp, error)
@ -347,15 +389,33 @@ func (UnimplementedOctopusServer) UploadAlgorithmConfirm(context.Context, *Uploa
func (UnimplementedOctopusServer) GetMyDatasetList(context.Context, *GetMyDatasetListReq) (*GetMyDatasetListResp, error) { func (UnimplementedOctopusServer) GetMyDatasetList(context.Context, *GetMyDatasetListReq) (*GetMyDatasetListResp, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetMyDatasetList not implemented") return nil, status.Errorf(codes.Unimplemented, "method GetMyDatasetList not implemented")
} }
func (UnimplementedOctopusServer) GetDatasetVersionList(context.Context, *GetDatasetVersionListReq) (*GetDatasetVersionListResp, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetDatasetVersionList not implemented")
}
func (UnimplementedOctopusServer) CreateDataSet(context.Context, *CreateDataSetReq) (*CreateDataSetResp, error) { func (UnimplementedOctopusServer) CreateDataSet(context.Context, *CreateDataSetReq) (*CreateDataSetResp, error) {
return nil, status.Errorf(codes.Unimplemented, "method CreateDataSet not implemented") return nil, status.Errorf(codes.Unimplemented, "method CreateDataSet not implemented")
} }
func (UnimplementedOctopusServer) DeleteDataSet(context.Context, *DeleteDataSetReq) (*DeleteDataSetResp, error) { func (UnimplementedOctopusServer) DeleteDataSet(context.Context, *DeleteDataSetReq) (*DeleteDataSetResp, error) {
return nil, status.Errorf(codes.Unimplemented, "method DeleteDataSet not implemented") return nil, status.Errorf(codes.Unimplemented, "method DeleteDataSet not implemented")
} }
func (UnimplementedOctopusServer) UploadDataSet(context.Context, *UploadDataSetReq) (*UploadDataSetResp, error) {
return nil, status.Errorf(codes.Unimplemented, "method UploadDataSet not implemented")
}
func (UnimplementedOctopusServer) UploadDataSetConfirm(context.Context, *UploadDataSetConfirmReq) (*UploadDataSetConfirmResp, error) {
return nil, status.Errorf(codes.Unimplemented, "method UploadDataSetConfirm not implemented")
}
func (UnimplementedOctopusServer) CreateDataSetVersion(context.Context, *CreateDataSetVersionReq) (*CreateDataSetVersionResp, error) {
return nil, status.Errorf(codes.Unimplemented, "method CreateDataSetVersion not implemented")
}
func (UnimplementedOctopusServer) DeleteDataSetVersion(context.Context, *DeleteDataSetVersionReq) (*DeleteDataSetVersionResp, error) {
return nil, status.Errorf(codes.Unimplemented, "method DeleteDataSetVersion not implemented")
}
func (UnimplementedOctopusServer) GetNotebookList(context.Context, *GetNotebookListReq) (*GetNotebookListResp, error) { func (UnimplementedOctopusServer) GetNotebookList(context.Context, *GetNotebookListReq) (*GetNotebookListResp, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetNotebookList not implemented") return nil, status.Errorf(codes.Unimplemented, "method GetNotebookList not implemented")
} }
func (UnimplementedOctopusServer) DeleteNotebook(context.Context, *DeleteNotebookReq) (*DeleteNotebookResp, error) {
return nil, status.Errorf(codes.Unimplemented, "method DeleteNotebook not implemented")
}
func (UnimplementedOctopusServer) GetUserImageList(context.Context, *GetUserImageListReq) (*GetUserImageListResp, error) { func (UnimplementedOctopusServer) GetUserImageList(context.Context, *GetUserImageListReq) (*GetUserImageListResp, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetUserImageList not implemented") return nil, status.Errorf(codes.Unimplemented, "method GetUserImageList not implemented")
} }
@ -394,7 +454,7 @@ func _Octopus_GetComputingPower_Handler(srv interface{}, ctx context.Context, de
} }
info := &grpc.UnaryServerInfo{ info := &grpc.UnaryServerInfo{
Server: srv, Server: srv,
FullMethod: Octopus_GetComputingPower_FullMethodName, FullMethod: "/octopus.Octopus/GetComputingPower",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OctopusServer).GetComputingPower(ctx, req.(*ResourceReq)) return srv.(OctopusServer).GetComputingPower(ctx, req.(*ResourceReq))
@ -412,7 +472,7 @@ func _Octopus_GetGeneralInfo_Handler(srv interface{}, ctx context.Context, dec f
} }
info := &grpc.UnaryServerInfo{ info := &grpc.UnaryServerInfo{
Server: srv, Server: srv,
FullMethod: Octopus_GetGeneralInfo_FullMethodName, FullMethod: "/octopus.Octopus/GetGeneralInfo",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OctopusServer).GetGeneralInfo(ctx, req.(*ResourceReq)) return srv.(OctopusServer).GetGeneralInfo(ctx, req.(*ResourceReq))
@ -430,7 +490,7 @@ func _Octopus_GetMyAlgorithmList_Handler(srv interface{}, ctx context.Context, d
} }
info := &grpc.UnaryServerInfo{ info := &grpc.UnaryServerInfo{
Server: srv, Server: srv,
FullMethod: Octopus_GetMyAlgorithmList_FullMethodName, FullMethod: "/octopus.Octopus/GetMyAlgorithmList",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OctopusServer).GetMyAlgorithmList(ctx, req.(*GetMyAlgorithmListReq)) return srv.(OctopusServer).GetMyAlgorithmList(ctx, req.(*GetMyAlgorithmListReq))
@ -448,7 +508,7 @@ func _Octopus_GetAlgorithmList_Handler(srv interface{}, ctx context.Context, dec
} }
info := &grpc.UnaryServerInfo{ info := &grpc.UnaryServerInfo{
Server: srv, Server: srv,
FullMethod: Octopus_GetAlgorithmList_FullMethodName, FullMethod: "/octopus.Octopus/GetAlgorithmList",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OctopusServer).GetAlgorithmList(ctx, req.(*GetAlgorithmListReq)) return srv.(OctopusServer).GetAlgorithmList(ctx, req.(*GetAlgorithmListReq))
@ -466,7 +526,7 @@ func _Octopus_GetAlgorithm_Handler(srv interface{}, ctx context.Context, dec fun
} }
info := &grpc.UnaryServerInfo{ info := &grpc.UnaryServerInfo{
Server: srv, Server: srv,
FullMethod: Octopus_GetAlgorithm_FullMethodName, FullMethod: "/octopus.Octopus/GetAlgorithm",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OctopusServer).GetAlgorithm(ctx, req.(*GetAlgorithmReq)) return srv.(OctopusServer).GetAlgorithm(ctx, req.(*GetAlgorithmReq))
@ -484,7 +544,7 @@ func _Octopus_GetAlgorithmApplyList_Handler(srv interface{}, ctx context.Context
} }
info := &grpc.UnaryServerInfo{ info := &grpc.UnaryServerInfo{
Server: srv, Server: srv,
FullMethod: Octopus_GetAlgorithmApplyList_FullMethodName, FullMethod: "/octopus.Octopus/GetAlgorithmApplyList",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OctopusServer).GetAlgorithmApplyList(ctx, req.(*GetAlgorithmApplyListReq)) return srv.(OctopusServer).GetAlgorithmApplyList(ctx, req.(*GetAlgorithmApplyListReq))
@ -502,7 +562,7 @@ func _Octopus_GetAlgorithmFrameworkList_Handler(srv interface{}, ctx context.Con
} }
info := &grpc.UnaryServerInfo{ info := &grpc.UnaryServerInfo{
Server: srv, Server: srv,
FullMethod: Octopus_GetAlgorithmFrameworkList_FullMethodName, FullMethod: "/octopus.Octopus/GetAlgorithmFrameworkList",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OctopusServer).GetAlgorithmFrameworkList(ctx, req.(*GetAlgorithmFrameworkListReq)) return srv.(OctopusServer).GetAlgorithmFrameworkList(ctx, req.(*GetAlgorithmFrameworkListReq))
@ -520,7 +580,7 @@ func _Octopus_DeleteMyAlgorithm_Handler(srv interface{}, ctx context.Context, de
} }
info := &grpc.UnaryServerInfo{ info := &grpc.UnaryServerInfo{
Server: srv, Server: srv,
FullMethod: Octopus_DeleteMyAlgorithm_FullMethodName, FullMethod: "/octopus.Octopus/DeleteMyAlgorithm",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OctopusServer).DeleteMyAlgorithm(ctx, req.(*DeleteMyAlgorithmReq)) return srv.(OctopusServer).DeleteMyAlgorithm(ctx, req.(*DeleteMyAlgorithmReq))
@ -538,7 +598,7 @@ func _Octopus_CreateMyAlgorithm_Handler(srv interface{}, ctx context.Context, de
} }
info := &grpc.UnaryServerInfo{ info := &grpc.UnaryServerInfo{
Server: srv, Server: srv,
FullMethod: Octopus_CreateMyAlgorithm_FullMethodName, FullMethod: "/octopus.Octopus/CreateMyAlgorithm",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OctopusServer).CreateMyAlgorithm(ctx, req.(*CreateMyAlgorithmReq)) return srv.(OctopusServer).CreateMyAlgorithm(ctx, req.(*CreateMyAlgorithmReq))
@ -556,7 +616,7 @@ func _Octopus_DownloadAlgorithm_Handler(srv interface{}, ctx context.Context, de
} }
info := &grpc.UnaryServerInfo{ info := &grpc.UnaryServerInfo{
Server: srv, Server: srv,
FullMethod: Octopus_DownloadAlgorithm_FullMethodName, FullMethod: "/octopus.Octopus/DownloadAlgorithm",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OctopusServer).DownloadAlgorithm(ctx, req.(*DownloadAlgorithmReq)) return srv.(OctopusServer).DownloadAlgorithm(ctx, req.(*DownloadAlgorithmReq))
@ -574,7 +634,7 @@ func _Octopus_UploadAlgorithm_Handler(srv interface{}, ctx context.Context, dec
} }
info := &grpc.UnaryServerInfo{ info := &grpc.UnaryServerInfo{
Server: srv, Server: srv,
FullMethod: Octopus_UploadAlgorithm_FullMethodName, FullMethod: "/octopus.Octopus/UploadAlgorithm",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OctopusServer).UploadAlgorithm(ctx, req.(*UploadAlgorithmReq)) return srv.(OctopusServer).UploadAlgorithm(ctx, req.(*UploadAlgorithmReq))
@ -592,7 +652,7 @@ func _Octopus_UploadAlgorithmConfirm_Handler(srv interface{}, ctx context.Contex
} }
info := &grpc.UnaryServerInfo{ info := &grpc.UnaryServerInfo{
Server: srv, Server: srv,
FullMethod: Octopus_UploadAlgorithmConfirm_FullMethodName, FullMethod: "/octopus.Octopus/UploadAlgorithmConfirm",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OctopusServer).UploadAlgorithmConfirm(ctx, req.(*UploadAlgorithmConfirmReq)) return srv.(OctopusServer).UploadAlgorithmConfirm(ctx, req.(*UploadAlgorithmConfirmReq))
@ -610,7 +670,7 @@ func _Octopus_GetMyDatasetList_Handler(srv interface{}, ctx context.Context, dec
} }
info := &grpc.UnaryServerInfo{ info := &grpc.UnaryServerInfo{
Server: srv, Server: srv,
FullMethod: Octopus_GetMyDatasetList_FullMethodName, FullMethod: "/octopus.Octopus/GetMyDatasetList",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OctopusServer).GetMyDatasetList(ctx, req.(*GetMyDatasetListReq)) return srv.(OctopusServer).GetMyDatasetList(ctx, req.(*GetMyDatasetListReq))
@ -618,6 +678,24 @@ func _Octopus_GetMyDatasetList_Handler(srv interface{}, ctx context.Context, dec
return interceptor(ctx, in, info, handler) return interceptor(ctx, in, info, handler)
} }
func _Octopus_GetDatasetVersionList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetDatasetVersionListReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(OctopusServer).GetDatasetVersionList(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/octopus.Octopus/GetDatasetVersionList",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OctopusServer).GetDatasetVersionList(ctx, req.(*GetDatasetVersionListReq))
}
return interceptor(ctx, in, info, handler)
}
func _Octopus_CreateDataSet_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { func _Octopus_CreateDataSet_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(CreateDataSetReq) in := new(CreateDataSetReq)
if err := dec(in); err != nil { if err := dec(in); err != nil {
@ -628,7 +706,7 @@ func _Octopus_CreateDataSet_Handler(srv interface{}, ctx context.Context, dec fu
} }
info := &grpc.UnaryServerInfo{ info := &grpc.UnaryServerInfo{
Server: srv, Server: srv,
FullMethod: Octopus_CreateDataSet_FullMethodName, FullMethod: "/octopus.Octopus/CreateDataSet",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OctopusServer).CreateDataSet(ctx, req.(*CreateDataSetReq)) return srv.(OctopusServer).CreateDataSet(ctx, req.(*CreateDataSetReq))
@ -646,7 +724,7 @@ func _Octopus_DeleteDataSet_Handler(srv interface{}, ctx context.Context, dec fu
} }
info := &grpc.UnaryServerInfo{ info := &grpc.UnaryServerInfo{
Server: srv, Server: srv,
FullMethod: Octopus_DeleteDataSet_FullMethodName, FullMethod: "/octopus.Octopus/DeleteDataSet",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OctopusServer).DeleteDataSet(ctx, req.(*DeleteDataSetReq)) return srv.(OctopusServer).DeleteDataSet(ctx, req.(*DeleteDataSetReq))
@ -654,6 +732,78 @@ func _Octopus_DeleteDataSet_Handler(srv interface{}, ctx context.Context, dec fu
return interceptor(ctx, in, info, handler) return interceptor(ctx, in, info, handler)
} }
func _Octopus_UploadDataSet_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(UploadDataSetReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(OctopusServer).UploadDataSet(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/octopus.Octopus/UploadDataSet",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OctopusServer).UploadDataSet(ctx, req.(*UploadDataSetReq))
}
return interceptor(ctx, in, info, handler)
}
func _Octopus_UploadDataSetConfirm_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(UploadDataSetConfirmReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(OctopusServer).UploadDataSetConfirm(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/octopus.Octopus/UploadDataSetConfirm",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OctopusServer).UploadDataSetConfirm(ctx, req.(*UploadDataSetConfirmReq))
}
return interceptor(ctx, in, info, handler)
}
func _Octopus_CreateDataSetVersion_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(CreateDataSetVersionReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(OctopusServer).CreateDataSetVersion(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/octopus.Octopus/CreateDataSetVersion",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OctopusServer).CreateDataSetVersion(ctx, req.(*CreateDataSetVersionReq))
}
return interceptor(ctx, in, info, handler)
}
func _Octopus_DeleteDataSetVersion_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(DeleteDataSetVersionReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(OctopusServer).DeleteDataSetVersion(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/octopus.Octopus/DeleteDataSetVersion",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OctopusServer).DeleteDataSetVersion(ctx, req.(*DeleteDataSetVersionReq))
}
return interceptor(ctx, in, info, handler)
}
func _Octopus_GetNotebookList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { func _Octopus_GetNotebookList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetNotebookListReq) in := new(GetNotebookListReq)
if err := dec(in); err != nil { if err := dec(in); err != nil {
@ -664,7 +814,7 @@ func _Octopus_GetNotebookList_Handler(srv interface{}, ctx context.Context, dec
} }
info := &grpc.UnaryServerInfo{ info := &grpc.UnaryServerInfo{
Server: srv, Server: srv,
FullMethod: Octopus_GetNotebookList_FullMethodName, FullMethod: "/octopus.Octopus/GetNotebookList",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OctopusServer).GetNotebookList(ctx, req.(*GetNotebookListReq)) return srv.(OctopusServer).GetNotebookList(ctx, req.(*GetNotebookListReq))
@ -672,6 +822,24 @@ func _Octopus_GetNotebookList_Handler(srv interface{}, ctx context.Context, dec
return interceptor(ctx, in, info, handler) return interceptor(ctx, in, info, handler)
} }
func _Octopus_DeleteNotebook_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(DeleteNotebookReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(OctopusServer).DeleteNotebook(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/octopus.Octopus/DeleteNotebook",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OctopusServer).DeleteNotebook(ctx, req.(*DeleteNotebookReq))
}
return interceptor(ctx, in, info, handler)
}
func _Octopus_GetUserImageList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { func _Octopus_GetUserImageList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetUserImageListReq) in := new(GetUserImageListReq)
if err := dec(in); err != nil { if err := dec(in); err != nil {
@ -682,7 +850,7 @@ func _Octopus_GetUserImageList_Handler(srv interface{}, ctx context.Context, dec
} }
info := &grpc.UnaryServerInfo{ info := &grpc.UnaryServerInfo{
Server: srv, Server: srv,
FullMethod: Octopus_GetUserImageList_FullMethodName, FullMethod: "/octopus.Octopus/GetUserImageList",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OctopusServer).GetUserImageList(ctx, req.(*GetUserImageListReq)) return srv.(OctopusServer).GetUserImageList(ctx, req.(*GetUserImageListReq))
@ -700,7 +868,7 @@ func _Octopus_CreateImage_Handler(srv interface{}, ctx context.Context, dec func
} }
info := &grpc.UnaryServerInfo{ info := &grpc.UnaryServerInfo{
Server: srv, Server: srv,
FullMethod: Octopus_CreateImage_FullMethodName, FullMethod: "/octopus.Octopus/CreateImage",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OctopusServer).CreateImage(ctx, req.(*CreateImageReq)) return srv.(OctopusServer).CreateImage(ctx, req.(*CreateImageReq))
@ -718,7 +886,7 @@ func _Octopus_DeleteImage_Handler(srv interface{}, ctx context.Context, dec func
} }
info := &grpc.UnaryServerInfo{ info := &grpc.UnaryServerInfo{
Server: srv, Server: srv,
FullMethod: Octopus_DeleteImage_FullMethodName, FullMethod: "/octopus.Octopus/DeleteImage",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OctopusServer).DeleteImage(ctx, req.(*DeleteImageReq)) return srv.(OctopusServer).DeleteImage(ctx, req.(*DeleteImageReq))
@ -736,7 +904,7 @@ func _Octopus_UploadImage_Handler(srv interface{}, ctx context.Context, dec func
} }
info := &grpc.UnaryServerInfo{ info := &grpc.UnaryServerInfo{
Server: srv, Server: srv,
FullMethod: Octopus_UploadImage_FullMethodName, FullMethod: "/octopus.Octopus/UploadImage",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OctopusServer).UploadImage(ctx, req.(*UploadImageReq)) return srv.(OctopusServer).UploadImage(ctx, req.(*UploadImageReq))
@ -754,7 +922,7 @@ func _Octopus_UploadImageConfirm_Handler(srv interface{}, ctx context.Context, d
} }
info := &grpc.UnaryServerInfo{ info := &grpc.UnaryServerInfo{
Server: srv, Server: srv,
FullMethod: Octopus_UploadImageConfirm_FullMethodName, FullMethod: "/octopus.Octopus/UploadImageConfirm",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(OctopusServer).UploadImageConfirm(ctx, req.(*UploadImageConfirmReq)) return srv.(OctopusServer).UploadImageConfirm(ctx, req.(*UploadImageConfirmReq))
@ -821,6 +989,10 @@ var Octopus_ServiceDesc = grpc.ServiceDesc{
MethodName: "GetMyDatasetList", MethodName: "GetMyDatasetList",
Handler: _Octopus_GetMyDatasetList_Handler, Handler: _Octopus_GetMyDatasetList_Handler,
}, },
{
MethodName: "GetDatasetVersionList",
Handler: _Octopus_GetDatasetVersionList_Handler,
},
{ {
MethodName: "CreateDataSet", MethodName: "CreateDataSet",
Handler: _Octopus_CreateDataSet_Handler, Handler: _Octopus_CreateDataSet_Handler,
@ -829,10 +1001,30 @@ var Octopus_ServiceDesc = grpc.ServiceDesc{
MethodName: "DeleteDataSet", MethodName: "DeleteDataSet",
Handler: _Octopus_DeleteDataSet_Handler, Handler: _Octopus_DeleteDataSet_Handler,
}, },
{
MethodName: "UploadDataSet",
Handler: _Octopus_UploadDataSet_Handler,
},
{
MethodName: "UploadDataSetConfirm",
Handler: _Octopus_UploadDataSetConfirm_Handler,
},
{
MethodName: "CreateDataSetVersion",
Handler: _Octopus_CreateDataSetVersion_Handler,
},
{
MethodName: "DeleteDataSetVersion",
Handler: _Octopus_DeleteDataSetVersion_Handler,
},
{ {
MethodName: "GetNotebookList", MethodName: "GetNotebookList",
Handler: _Octopus_GetNotebookList_Handler, Handler: _Octopus_GetNotebookList_Handler,
}, },
{
MethodName: "DeleteNotebook",
Handler: _Octopus_DeleteNotebook_Handler,
},
{ {
MethodName: "GetUserImageList", MethodName: "GetUserImageList",
Handler: _Octopus_GetUserImageList_Handler, Handler: _Octopus_GetUserImageList_Handler,

View File

@ -20,19 +20,26 @@ type (
CreateDataSet = octopus.CreateDataSet CreateDataSet = octopus.CreateDataSet
CreateDataSetReq = octopus.CreateDataSetReq CreateDataSetReq = octopus.CreateDataSetReq
CreateDataSetResp = octopus.CreateDataSetResp CreateDataSetResp = octopus.CreateDataSetResp
CreateDataSetVersionReq = octopus.CreateDataSetVersionReq
CreateDataSetVersionResp = octopus.CreateDataSetVersionResp
CreateImage = octopus.CreateImage CreateImage = octopus.CreateImage
CreateImageReq = octopus.CreateImageReq CreateImageReq = octopus.CreateImageReq
CreateImageResp = octopus.CreateImageResp CreateImageResp = octopus.CreateImageResp
CreateMyAlgorithm = octopus.CreateMyAlgorithm CreateMyAlgorithm = octopus.CreateMyAlgorithm
CreateMyAlgorithmReq = octopus.CreateMyAlgorithmReq CreateMyAlgorithmReq = octopus.CreateMyAlgorithmReq
CreateMyAlgorithmResp = octopus.CreateMyAlgorithmResp CreateMyAlgorithmResp = octopus.CreateMyAlgorithmResp
DatasetVersion = octopus.DatasetVersion
Datasets = octopus.Datasets Datasets = octopus.Datasets
DeleteDataSetReq = octopus.DeleteDataSetReq DeleteDataSetReq = octopus.DeleteDataSetReq
DeleteDataSetResp = octopus.DeleteDataSetResp DeleteDataSetResp = octopus.DeleteDataSetResp
DeleteDataSetVersionReq = octopus.DeleteDataSetVersionReq
DeleteDataSetVersionResp = octopus.DeleteDataSetVersionResp
DeleteImageReq = octopus.DeleteImageReq DeleteImageReq = octopus.DeleteImageReq
DeleteImageResp = octopus.DeleteImageResp DeleteImageResp = octopus.DeleteImageResp
DeleteMyAlgorithmReq = octopus.DeleteMyAlgorithmReq DeleteMyAlgorithmReq = octopus.DeleteMyAlgorithmReq
DeleteMyAlgorithmResp = octopus.DeleteMyAlgorithmResp DeleteMyAlgorithmResp = octopus.DeleteMyAlgorithmResp
DeleteNotebookReq = octopus.DeleteNotebookReq
DeleteNotebookResp = octopus.DeleteNotebookResp
DownloadAlgorithmReq = octopus.DownloadAlgorithmReq DownloadAlgorithmReq = octopus.DownloadAlgorithmReq
DownloadAlgorithmResp = octopus.DownloadAlgorithmResp DownloadAlgorithmResp = octopus.DownloadAlgorithmResp
Error = octopus.Error Error = octopus.Error
@ -44,6 +51,8 @@ type (
GetAlgorithmListResp = octopus.GetAlgorithmListResp GetAlgorithmListResp = octopus.GetAlgorithmListResp
GetAlgorithmReq = octopus.GetAlgorithmReq GetAlgorithmReq = octopus.GetAlgorithmReq
GetAlgorithmResp = octopus.GetAlgorithmResp GetAlgorithmResp = octopus.GetAlgorithmResp
GetDatasetVersionListReq = octopus.GetDatasetVersionListReq
GetDatasetVersionListResp = octopus.GetDatasetVersionListResp
GetMyAlgorithmListReq = octopus.GetMyAlgorithmListReq GetMyAlgorithmListReq = octopus.GetMyAlgorithmListReq
GetMyAlgorithmListResp = octopus.GetMyAlgorithmListResp GetMyAlgorithmListResp = octopus.GetMyAlgorithmListResp
GetMyDatasetListReq = octopus.GetMyDatasetListReq GetMyDatasetListReq = octopus.GetMyDatasetListReq
@ -61,19 +70,25 @@ type (
PayloadAlgorithmFrameworkList = octopus.PayloadAlgorithmFrameworkList PayloadAlgorithmFrameworkList = octopus.PayloadAlgorithmFrameworkList
PayloadAlgorithmList = octopus.PayloadAlgorithmList PayloadAlgorithmList = octopus.PayloadAlgorithmList
PayloadCreateDataSet = octopus.PayloadCreateDataSet PayloadCreateDataSet = octopus.PayloadCreateDataSet
PayloadCreateDataSetVersion = octopus.PayloadCreateDataSetVersion
PayloadCreateImage = octopus.PayloadCreateImage PayloadCreateImage = octopus.PayloadCreateImage
PayloadCreateMyAlgorithm = octopus.PayloadCreateMyAlgorithm PayloadCreateMyAlgorithm = octopus.PayloadCreateMyAlgorithm
PayloadDeleteDataSet = octopus.PayloadDeleteDataSet PayloadDeleteDataSet = octopus.PayloadDeleteDataSet
PayloadDeleteDataSetVersion = octopus.PayloadDeleteDataSetVersion
PayloadDeleteImage = octopus.PayloadDeleteImage PayloadDeleteImage = octopus.PayloadDeleteImage
PayloadDeleteMyAlgorithm = octopus.PayloadDeleteMyAlgorithm PayloadDeleteMyAlgorithm = octopus.PayloadDeleteMyAlgorithm
PayloadDeleteNotebook = octopus.PayloadDeleteNotebook
PayloadDownloadAlgorithm = octopus.PayloadDownloadAlgorithm PayloadDownloadAlgorithm = octopus.PayloadDownloadAlgorithm
PayloadGetAlgorithm = octopus.PayloadGetAlgorithm PayloadGetAlgorithm = octopus.PayloadGetAlgorithm
PayloadGetAlgorithmApplyList = octopus.PayloadGetAlgorithmApplyList PayloadGetAlgorithmApplyList = octopus.PayloadGetAlgorithmApplyList
PayloadGetDatasetVersion = octopus.PayloadGetDatasetVersion
PayloadMyAlgorithmList = octopus.PayloadMyAlgorithmList PayloadMyAlgorithmList = octopus.PayloadMyAlgorithmList
PayloadMyDatasetList = octopus.PayloadMyDatasetList PayloadMyDatasetList = octopus.PayloadMyDatasetList
PayloadNotebookList = octopus.PayloadNotebookList PayloadNotebookList = octopus.PayloadNotebookList
PayloadUploadAlgorithm = octopus.PayloadUploadAlgorithm PayloadUploadAlgorithm = octopus.PayloadUploadAlgorithm
PayloadUploadAlgorithmConfirm = octopus.PayloadUploadAlgorithmConfirm PayloadUploadAlgorithmConfirm = octopus.PayloadUploadAlgorithmConfirm
PayloadUploadDataSet = octopus.PayloadUploadDataSet
PayloadUploadDataSetConfirm = octopus.PayloadUploadDataSetConfirm
PayloadUploadImage = octopus.PayloadUploadImage PayloadUploadImage = octopus.PayloadUploadImage
PayloadUploadImageConfirm = octopus.PayloadUploadImageConfirm PayloadUploadImageConfirm = octopus.PayloadUploadImageConfirm
PayloadUserImageList = octopus.PayloadUserImageList PayloadUserImageList = octopus.PayloadUserImageList
@ -84,6 +99,11 @@ type (
UploadAlgorithmParam = octopus.UploadAlgorithmParam UploadAlgorithmParam = octopus.UploadAlgorithmParam
UploadAlgorithmReq = octopus.UploadAlgorithmReq UploadAlgorithmReq = octopus.UploadAlgorithmReq
UploadAlgorithmResp = octopus.UploadAlgorithmResp UploadAlgorithmResp = octopus.UploadAlgorithmResp
UploadDataSetConfirmReq = octopus.UploadDataSetConfirmReq
UploadDataSetConfirmResp = octopus.UploadDataSetConfirmResp
UploadDataSetParam = octopus.UploadDataSetParam
UploadDataSetReq = octopus.UploadDataSetReq
UploadDataSetResp = octopus.UploadDataSetResp
UploadImageConfirmReq = octopus.UploadImageConfirmReq UploadImageConfirmReq = octopus.UploadImageConfirmReq
UploadImageConfirmResp = octopus.UploadImageConfirmResp UploadImageConfirmResp = octopus.UploadImageConfirmResp
UploadImageParam = octopus.UploadImageParam UploadImageParam = octopus.UploadImageParam
@ -107,10 +127,16 @@ type (
UploadAlgorithmConfirm(ctx context.Context, in *UploadAlgorithmConfirmReq, opts ...grpc.CallOption) (*UploadAlgorithmConfirmResp, error) UploadAlgorithmConfirm(ctx context.Context, in *UploadAlgorithmConfirmReq, opts ...grpc.CallOption) (*UploadAlgorithmConfirmResp, error)
// DatasetService // DatasetService
GetMyDatasetList(ctx context.Context, in *GetMyDatasetListReq, opts ...grpc.CallOption) (*GetMyDatasetListResp, error) GetMyDatasetList(ctx context.Context, in *GetMyDatasetListReq, opts ...grpc.CallOption) (*GetMyDatasetListResp, error)
GetDatasetVersionList(ctx context.Context, in *GetDatasetVersionListReq, opts ...grpc.CallOption) (*GetDatasetVersionListResp, error)
CreateDataSet(ctx context.Context, in *CreateDataSetReq, opts ...grpc.CallOption) (*CreateDataSetResp, error) CreateDataSet(ctx context.Context, in *CreateDataSetReq, opts ...grpc.CallOption) (*CreateDataSetResp, error)
DeleteDataSet(ctx context.Context, in *DeleteDataSetReq, opts ...grpc.CallOption) (*DeleteDataSetResp, error) DeleteDataSet(ctx context.Context, in *DeleteDataSetReq, opts ...grpc.CallOption) (*DeleteDataSetResp, error)
UploadDataSet(ctx context.Context, in *UploadDataSetReq, opts ...grpc.CallOption) (*UploadDataSetResp, error)
UploadDataSetConfirm(ctx context.Context, in *UploadDataSetConfirmReq, opts ...grpc.CallOption) (*UploadDataSetConfirmResp, error)
CreateDataSetVersion(ctx context.Context, in *CreateDataSetVersionReq, opts ...grpc.CallOption) (*CreateDataSetVersionResp, error)
DeleteDataSetVersion(ctx context.Context, in *DeleteDataSetVersionReq, opts ...grpc.CallOption) (*DeleteDataSetVersionResp, error)
// ModelDeployService // ModelDeployService
GetNotebookList(ctx context.Context, in *GetNotebookListReq, opts ...grpc.CallOption) (*GetNotebookListResp, error) GetNotebookList(ctx context.Context, in *GetNotebookListReq, opts ...grpc.CallOption) (*GetNotebookListResp, error)
DeleteNotebook(ctx context.Context, in *DeleteNotebookReq, opts ...grpc.CallOption) (*DeleteNotebookResp, error)
// ImageService // ImageService
GetUserImageList(ctx context.Context, in *GetUserImageListReq, opts ...grpc.CallOption) (*GetUserImageListResp, error) GetUserImageList(ctx context.Context, in *GetUserImageListReq, opts ...grpc.CallOption) (*GetUserImageListResp, error)
CreateImage(ctx context.Context, in *CreateImageReq, opts ...grpc.CallOption) (*CreateImageResp, error) CreateImage(ctx context.Context, in *CreateImageReq, opts ...grpc.CallOption) (*CreateImageResp, error)
@ -197,6 +223,11 @@ func (m *defaultOctopus) GetMyDatasetList(ctx context.Context, in *GetMyDatasetL
return client.GetMyDatasetList(ctx, in, opts...) return client.GetMyDatasetList(ctx, in, opts...)
} }
func (m *defaultOctopus) GetDatasetVersionList(ctx context.Context, in *GetDatasetVersionListReq, opts ...grpc.CallOption) (*GetDatasetVersionListResp, error) {
client := octopus.NewOctopusClient(m.cli.Conn())
return client.GetDatasetVersionList(ctx, in, opts...)
}
func (m *defaultOctopus) CreateDataSet(ctx context.Context, in *CreateDataSetReq, opts ...grpc.CallOption) (*CreateDataSetResp, error) { func (m *defaultOctopus) CreateDataSet(ctx context.Context, in *CreateDataSetReq, opts ...grpc.CallOption) (*CreateDataSetResp, error) {
client := octopus.NewOctopusClient(m.cli.Conn()) client := octopus.NewOctopusClient(m.cli.Conn())
return client.CreateDataSet(ctx, in, opts...) return client.CreateDataSet(ctx, in, opts...)
@ -207,12 +238,37 @@ func (m *defaultOctopus) DeleteDataSet(ctx context.Context, in *DeleteDataSetReq
return client.DeleteDataSet(ctx, in, opts...) return client.DeleteDataSet(ctx, in, opts...)
} }
func (m *defaultOctopus) UploadDataSet(ctx context.Context, in *UploadDataSetReq, opts ...grpc.CallOption) (*UploadDataSetResp, error) {
client := octopus.NewOctopusClient(m.cli.Conn())
return client.UploadDataSet(ctx, in, opts...)
}
func (m *defaultOctopus) UploadDataSetConfirm(ctx context.Context, in *UploadDataSetConfirmReq, opts ...grpc.CallOption) (*UploadDataSetConfirmResp, error) {
client := octopus.NewOctopusClient(m.cli.Conn())
return client.UploadDataSetConfirm(ctx, in, opts...)
}
func (m *defaultOctopus) CreateDataSetVersion(ctx context.Context, in *CreateDataSetVersionReq, opts ...grpc.CallOption) (*CreateDataSetVersionResp, error) {
client := octopus.NewOctopusClient(m.cli.Conn())
return client.CreateDataSetVersion(ctx, in, opts...)
}
func (m *defaultOctopus) DeleteDataSetVersion(ctx context.Context, in *DeleteDataSetVersionReq, opts ...grpc.CallOption) (*DeleteDataSetVersionResp, error) {
client := octopus.NewOctopusClient(m.cli.Conn())
return client.DeleteDataSetVersion(ctx, in, opts...)
}
// ModelDeployService // ModelDeployService
func (m *defaultOctopus) GetNotebookList(ctx context.Context, in *GetNotebookListReq, opts ...grpc.CallOption) (*GetNotebookListResp, error) { func (m *defaultOctopus) GetNotebookList(ctx context.Context, in *GetNotebookListReq, opts ...grpc.CallOption) (*GetNotebookListResp, error) {
client := octopus.NewOctopusClient(m.cli.Conn()) client := octopus.NewOctopusClient(m.cli.Conn())
return client.GetNotebookList(ctx, in, opts...) return client.GetNotebookList(ctx, in, opts...)
} }
func (m *defaultOctopus) DeleteNotebook(ctx context.Context, in *DeleteNotebookReq, opts ...grpc.CallOption) (*DeleteNotebookResp, error) {
client := octopus.NewOctopusClient(m.cli.Conn())
return client.DeleteNotebook(ctx, in, opts...)
}
// ImageService // ImageService
func (m *defaultOctopus) GetUserImageList(ctx context.Context, in *GetUserImageListReq, opts ...grpc.CallOption) (*GetUserImageListResp, error) { func (m *defaultOctopus) GetUserImageList(ctx context.Context, in *GetUserImageListReq, opts ...grpc.CallOption) (*GetUserImageListResp, error) {
client := octopus.NewOctopusClient(m.cli.Conn()) client := octopus.NewOctopusClient(m.cli.Conn())

View File

@ -239,6 +239,34 @@ message PayloadCreateMyAlgorithm{
/******************Algorithm End*************************/ /******************Algorithm End*************************/
/******************DatasetService Start*************************/ /******************DatasetService Start*************************/
message GetDatasetVersionListReq{
string platform =1;
int32 pageIndex =2;
int32 pageSize =3;
string datasetId = 4;
}
message GetDatasetVersionListResp{
bool success =1;
PayloadGetDatasetVersion payload =2;
Error error = 3;
}
message PayloadGetDatasetVersion{
int32 totalSize =1;
repeated DatasetVersion versions = 2;
}
message DatasetVersion{
int64 createdAt = 1;
string datasetId = 2;
string desc = 3;
bool shared = 4;
int32 status = 5;
int32 updatedAt = 6;
string version = 7;
}
message CreateDataSetReq{ message CreateDataSetReq{
string platform =1; string platform =1;
CreateDataSet createDataSet=2; CreateDataSet createDataSet=2;
@ -311,12 +339,99 @@ message DeleteDataSetResp{
message PayloadDeleteDataSet{ message PayloadDeleteDataSet{
int64 deletedAt = 1; int64 deletedAt = 1;
} }
message UploadDataSetReq{
string platform =1;
string datasetId=2;
string version=3;
UploadDataSetParam UploadDataSetParam = 4;
}
message UploadDataSetParam{
string domain = 1;
string fileName = 2;
}
message UploadDataSetResp{
bool success =1;
PayloadUploadDataSet payload =2;
Error error = 3;
}
message PayloadUploadDataSet{
string uploadUrl = 1;
}
message UploadDataSetConfirmReq{
string platform =1;
string datasetId=2;
string version=3;
string fileName = 4;
}
message UploadDataSetConfirmResp{
bool success =1;
PayloadUploadDataSetConfirm payload =2;
Error error = 3;
}
message PayloadUploadDataSetConfirm{
int64 updatedAt = 1;
}
message CreateDataSetVersionReq{
string platform =1;
string datasetId=2;
string desc =3;
}
message CreateDataSetVersionResp{
bool success =1;
PayloadCreateDataSetVersion payload =2;
Error error = 3;
}
message PayloadCreateDataSetVersion {
string datasetId = 1;
string version = 2;
}
message DeleteDataSetVersionReq{
string platform =1;
string datasetId=2;
string version = 3;
}
message DeleteDataSetVersionResp{
bool success =1;
PayloadDeleteDataSetVersion payload =2;
Error error = 3;
}
message PayloadDeleteDataSetVersion{
int64 deletedAt = 1;
}
/******************DatasetService End*************************/ /******************DatasetService End*************************/
/******************ModelDeployService Start*************************/ /******************ModelDeployService Start*************************/
/******************ModelDeployService End*************************/ /******************ModelDeployService End*************************/
/******************Develop Start*************************/ /******************Develop Start*************************/
message DeleteNotebookReq{
string platform =1;
string id =2;
}
message DeleteNotebookResp{
bool success =1;
PayloadDeleteNotebook payload =2;
Error error = 3;
}
message PayloadDeleteNotebook{
string id = 1;
}
message GetNotebookListReq{ message GetNotebookListReq{
string platform =1; string platform =1;
int32 pageIndex =2; int32 pageIndex =2;
@ -528,14 +643,23 @@ service Octopus {
//DatasetService //DatasetService
rpc GetMyDatasetList(GetMyDatasetListReq) returns (GetMyDatasetListResp); rpc GetMyDatasetList(GetMyDatasetListReq) returns (GetMyDatasetListResp);
rpc GetDatasetVersionList(GetDatasetVersionListReq) returns (GetDatasetVersionListResp);
rpc CreateDataSet(CreateDataSetReq) returns (CreateDataSetResp); rpc CreateDataSet(CreateDataSetReq) returns (CreateDataSetResp);
rpc DeleteDataSet(DeleteDataSetReq) returns (DeleteDataSetResp); rpc DeleteDataSet(DeleteDataSetReq) returns (DeleteDataSetResp);
rpc UploadDataSet(UploadDataSetReq) returns (UploadDataSetResp);
rpc UploadDataSetConfirm(UploadDataSetConfirmReq) returns (UploadDataSetConfirmResp);
rpc CreateDataSetVersion(CreateDataSetVersionReq) returns (CreateDataSetVersionResp); //
rpc DeleteDataSetVersion(DeleteDataSetVersionReq) returns (DeleteDataSetVersionResp); //
//ModelDeployService //ModelDeployService
//Develop //Develop
rpc GetNotebookList(GetNotebookListReq) returns (GetNotebookListResp); rpc GetNotebookList(GetNotebookListReq) returns (GetNotebookListResp);
rpc DeleteNotebook(DeleteNotebookReq) returns (DeleteNotebookResp);
//ImageService //ImageService
rpc GetUserImageList(GetUserImageListReq) returns (GetUserImageListResp); rpc GetUserImageList(GetUserImageListReq) returns (GetUserImageListResp);