更新启智章鱼接口

Former-commit-id: 11decce9be08d88964e168bfb1a53ae99e0c25f1

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

@@ -20,4 +20,18 @@ type OctopusApi struct {
 	GetMydatasetList   string
 	CreateImage        string
 	DeleteImage        string
+
+	CreateDataSet             string
+	DeleteDataSet             string
+	GetAlgorithmApplyList     string
+	GetAlgorithmFrameworkList string
+	DeleteMyAlgorithm         string
+	CreateMyAlgorithm         string
+	GetAlgorithmList          string
+	GetAlgorithm              string
+	DownloadAlgorithm         string
+	UploadAlgorithm           string
+	UploadAlgorithmConfirm    string
+	UploadImage               string
+	UploadImageConfirm        string
 }

adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/createdatasetlogic.go

@@ -1,8 +1,10 @@
 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"
 	"github.com/zeromicro/go-zero/core/logx"
 )
@@ -21,28 +23,23 @@ func NewCreateDataSetLogic(ctx context.Context, svcCtx *svc.ServiceContext) *Cre
 	}
 }
 
-func (l *CreateDataSetLogic) CreateDataSet(in *octopus.CreateDataSetReq) (*octopus.CreateDataSetResq, error) {
-	// todo: add your logic here and delete this line
-	/*	{
-		// todo: add your logic here and delete this line
-		var resp octopus.CreateDataSetResq
-		url := "http://192.168.242.41:8001/openaiserver/v1/datasetmanage/dataset"
-		reqByte, err := json.Marshal(in)
-		if err != nil {
-			return nil, err
-		}
-		payload := strings.NewReader(string(reqByte))
-		token := common.GetToken()
-		statusCode, body, err := tool.HttpClientWithBodyAndCode(tool.POST, url, payload, token)
-		if err != nil {
-			return nil, err
-		}
-		if statusCode == 200 {
-			json.Unmarshal(body, &resp)
-		} else if statusCode == 400 {
-			json.Unmarshal(body, &resp)
-		}
+func (l *CreateDataSetLogic) CreateDataSet(in *octopus.CreateDataSetReq) (*octopus.CreateDataSetResp, error) {
+	resp := &octopus.CreateDataSetResp{}
 
-	}*/
-	return &octopus.CreateDataSetResq{}, nil
+	var url_prefix = common.OctopusUrls[in.Platform]
+	var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.CreateDataSet
+
+	token := common.GetToken(in.Platform)
+
+	req := tool.GetACHttpRequest()
+	_, err := req.
+		SetHeader("Authorization", "Bearer "+token).
+		SetBody(in.CreateDataSet).
+		SetResult(resp).
+		Post(reqUrl)
+
+	if err != nil {
+		return nil, err
+	}
+	return resp, nil
 }

adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/createmyalgorithmlogic.go

@@ -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 CreateMyAlgorithmLogic struct {
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+	logx.Logger
+}
+
+func NewCreateMyAlgorithmLogic(ctx context.Context, svcCtx *svc.ServiceContext) *CreateMyAlgorithmLogic {
+	return &CreateMyAlgorithmLogic{
+		ctx:    ctx,
+		svcCtx: svcCtx,
+		Logger: logx.WithContext(ctx),
+	}
+}
+
+func (l *CreateMyAlgorithmLogic) CreateMyAlgorithm(in *octopus.CreateMyAlgorithmReq) (*octopus.CreateMyAlgorithmResp, error) {
+	resp := &octopus.CreateMyAlgorithmResp{}
+
+	var url_prefix = common.OctopusUrls[in.Platform]
+	var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.CreateMyAlgorithm
+
+	token := common.GetToken(in.Platform)
+
+	req := tool.GetACHttpRequest()
+	_, err := req.
+		SetHeader("Authorization", "Bearer "+token).
+		SetBody(in.CreateMyAlgorithm).
+		SetResult(resp).
+		Post(reqUrl)
+
+	if err != nil {
+		return nil, err
+	}
+	return resp, nil
+}

adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/deletedatasetlogic.go

@@ -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 DeleteDataSetLogic struct {
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+	logx.Logger
+}
+
+func NewDeleteDataSetLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeleteDataSetLogic {
+	return &DeleteDataSetLogic{
+		ctx:    ctx,
+		svcCtx: svcCtx,
+		Logger: logx.WithContext(ctx),
+	}
+}
+
+func (l *DeleteDataSetLogic) DeleteDataSet(in *octopus.DeleteDataSetReq) (*octopus.DeleteDataSetResp, error) {
+	resp := &octopus.DeleteDataSetResp{}
+
+	var url_prefix = common.OctopusUrls[in.Platform]
+	var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.DeleteDataSet
+
+	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
+}

adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/deletemyalgorithmlogic.go

@@ -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 DeleteMyAlgorithmLogic struct {
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+	logx.Logger
+}
+
+func NewDeleteMyAlgorithmLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeleteMyAlgorithmLogic {
+	return &DeleteMyAlgorithmLogic{
+		ctx:    ctx,
+		svcCtx: svcCtx,
+		Logger: logx.WithContext(ctx),
+	}
+}
+
+func (l *DeleteMyAlgorithmLogic) DeleteMyAlgorithm(in *octopus.DeleteMyAlgorithmReq) (*octopus.DeleteMyAlgorithmResp, error) {
+	resp := &octopus.DeleteMyAlgorithmResp{}
+
+	var url_prefix = common.OctopusUrls[in.Platform]
+	var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.DeleteMyAlgorithm
+
+	token := common.GetToken(in.Platform)
+
+	req := tool.GetACHttpRequest()
+	_, err := req.
+		SetHeader("Authorization", "Bearer "+token).
+		SetPathParam("algorithmId", in.AlgorithmId).
+		SetResult(resp).
+		Delete(reqUrl)
+
+	if err != nil {
+		return nil, err
+	}
+	return resp, nil
+}

adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/downloadalgorithmlogic.go

@@ -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 DownloadAlgorithmLogic struct {
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+	logx.Logger
+}
+
+func NewDownloadAlgorithmLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DownloadAlgorithmLogic {
+	return &DownloadAlgorithmLogic{
+		ctx:    ctx,
+		svcCtx: svcCtx,
+		Logger: logx.WithContext(ctx),
+	}
+}
+
+func (l *DownloadAlgorithmLogic) DownloadAlgorithm(in *octopus.DownloadAlgorithmReq) (*octopus.DownloadAlgorithmResp, error) {
+	resp := &octopus.DownloadAlgorithmResp{}
+
+	var url_prefix = common.OctopusUrls[in.Platform]
+	var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.DownloadAlgorithm
+
+	token := common.GetToken(in.Platform)
+
+	req := tool.GetACHttpRequest()
+	_, err := req.
+		SetHeader("Authorization", "Bearer "+token).
+		SetPathParam("algorithmId", in.AlgorithmId).
+		SetPathParam("version", in.Version).
+		SetResult(resp).
+		Get(reqUrl)
+
+	if err != nil {
+		return nil, err
+	}
+	return resp, nil
+}

adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/getalgorithmapplylistlogic.go

@@ -0,0 +1,50 @@
+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 GetAlgorithmApplyListLogic struct {
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+	logx.Logger
+}
+
+func NewGetAlgorithmApplyListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetAlgorithmApplyListLogic {
+	return &GetAlgorithmApplyListLogic{
+		ctx:    ctx,
+		svcCtx: svcCtx,
+		Logger: logx.WithContext(ctx),
+	}
+}
+
+func (l *GetAlgorithmApplyListLogic) GetAlgorithmApplyList(in *octopus.GetAlgorithmApplyListReq) (*octopus.GetAlgorithmApplyListResp, error) {
+	resp := &octopus.GetAlgorithmApplyListResp{}
+
+	var url_prefix = common.OctopusUrls[in.Platform]
+	var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.GetAlgorithmApplyList
+
+	token := common.GetToken(in.Platform)
+
+	req := tool.GetACHttpRequest()
+	_, err := 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
+}

adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/getalgorithmframeworklistlogic.go

@@ -0,0 +1,50 @@
+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 GetAlgorithmFrameworkListLogic struct {
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+	logx.Logger
+}
+
+func NewGetAlgorithmFrameworkListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetAlgorithmFrameworkListLogic {
+	return &GetAlgorithmFrameworkListLogic{
+		ctx:    ctx,
+		svcCtx: svcCtx,
+		Logger: logx.WithContext(ctx),
+	}
+}
+
+func (l *GetAlgorithmFrameworkListLogic) GetAlgorithmFrameworkList(in *octopus.GetAlgorithmFrameworkListReq) (*octopus.GetAlgorithmFrameworkListResp, error) {
+	resp := &octopus.GetAlgorithmFrameworkListResp{}
+
+	var url_prefix = common.OctopusUrls[in.Platform]
+	var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.GetAlgorithmFrameworkList
+
+	token := common.GetToken(in.Platform)
+
+	req := tool.GetACHttpRequest()
+	_, err := 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
+}

adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/getalgorithmlistlogic.go

@@ -0,0 +1,50 @@
+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 GetAlgorithmListLogic struct {
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+	logx.Logger
+}
+
+func NewGetAlgorithmListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetAlgorithmListLogic {
+	return &GetAlgorithmListLogic{
+		ctx:    ctx,
+		svcCtx: svcCtx,
+		Logger: logx.WithContext(ctx),
+	}
+}
+
+func (l *GetAlgorithmListLogic) GetAlgorithmList(in *octopus.GetAlgorithmListReq) (*octopus.GetAlgorithmListResp, error) {
+	resp := &octopus.GetAlgorithmListResp{}
+
+	var url_prefix = common.OctopusUrls[in.Platform]
+	var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.GetAlgorithmList
+
+	token := common.GetToken(in.Platform)
+
+	req := tool.GetACHttpRequest()
+	_, err := 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
+}

adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/getalgorithmlogic.go

@@ -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 GetAlgorithmLogic struct {
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+	logx.Logger
+}
+
+func NewGetAlgorithmLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetAlgorithmLogic {
+	return &GetAlgorithmLogic{
+		ctx:    ctx,
+		svcCtx: svcCtx,
+		Logger: logx.WithContext(ctx),
+	}
+}
+
+func (l *GetAlgorithmLogic) GetAlgorithm(in *octopus.GetAlgorithmReq) (*octopus.GetAlgorithmResp, error) {
+	resp := &octopus.GetAlgorithmResp{}
+
+	var url_prefix = common.OctopusUrls[in.Platform]
+	var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.GetAlgorithm
+
+	token := common.GetToken(in.Platform)
+
+	req := tool.GetACHttpRequest()
+	_, err := req.
+		SetHeader("Authorization", "Bearer "+token).
+		SetPathParam("algorithmId", in.AlgorithmId).
+		SetPathParam("version", in.Version).
+		SetResult(resp).
+		Get(reqUrl)
+
+	if err != nil {
+		return nil, err
+	}
+	return resp, nil
+}

adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/uploadalgorithmconfirmlogic.go

@@ -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 UploadAlgorithmConfirmLogic struct {
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+	logx.Logger
+}
+
+func NewUploadAlgorithmConfirmLogic(ctx context.Context, svcCtx *svc.ServiceContext) *UploadAlgorithmConfirmLogic {
+	return &UploadAlgorithmConfirmLogic{
+		ctx:    ctx,
+		svcCtx: svcCtx,
+		Logger: logx.WithContext(ctx),
+	}
+}
+
+func (l *UploadAlgorithmConfirmLogic) UploadAlgorithmConfirm(in *octopus.UploadAlgorithmConfirmReq) (*octopus.UploadAlgorithmConfirmResp, error) {
+	resp := &octopus.UploadAlgorithmConfirmResp{}
+
+	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("algorithmId", in.AlgorithmId).
+		SetPathParam("version", in.Version).
+		SetBody(in.FileName).
+		SetResult(resp).
+		Put(reqUrl)
+
+	if err != nil {
+		return nil, err
+	}
+	return resp, nil
+}

adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/uploadalgorithmlogic.go

@@ -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 UploadAlgorithmLogic struct {
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+	logx.Logger
+}
+
+func NewUploadAlgorithmLogic(ctx context.Context, svcCtx *svc.ServiceContext) *UploadAlgorithmLogic {
+	return &UploadAlgorithmLogic{
+		ctx:    ctx,
+		svcCtx: svcCtx,
+		Logger: logx.WithContext(ctx),
+	}
+}
+
+func (l *UploadAlgorithmLogic) UploadAlgorithm(in *octopus.UploadAlgorithmReq) (*octopus.UploadAlgorithmResp, error) {
+	resp := &octopus.UploadAlgorithmResp{}
+
+	var url_prefix = common.OctopusUrls[in.Platform]
+	var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.UploadAlgorithm
+
+	token := common.GetToken(in.Platform)
+
+	req := tool.GetACHttpRequest()
+	_, err := req.
+		SetHeader("Authorization", "Bearer "+token).
+		SetPathParam("algorithmId", in.AlgorithmId).
+		SetPathParam("version", in.Version).
+		SetBody(in.UploadAlgorithmParam).
+		SetResult(resp).
+		Post(reqUrl)
+
+	if err != nil {
+		return nil, err
+	}
+	return resp, nil
+}

adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/uploadimageconfirmlogic.go

@@ -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 UploadImageConfirmLogic struct {
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+	logx.Logger
+}
+
+func NewUploadImageConfirmLogic(ctx context.Context, svcCtx *svc.ServiceContext) *UploadImageConfirmLogic {
+	return &UploadImageConfirmLogic{
+		ctx:    ctx,
+		svcCtx: svcCtx,
+		Logger: logx.WithContext(ctx),
+	}
+}
+
+func (l *UploadImageConfirmLogic) UploadImageConfirm(in *octopus.UploadImageConfirmReq) (*octopus.UploadImageConfirmResp, error) {
+	resp := &octopus.UploadImageConfirmResp{}
+
+	var url_prefix = common.OctopusUrls[in.Platform]
+	var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.UploadImageConfirm
+
+	token := common.GetToken(in.Platform)
+
+	req := tool.GetACHttpRequest()
+	_, err := req.
+		SetHeader("Authorization", "Bearer "+token).
+		SetPathParam("imageId", in.ImageId).
+		SetResult(resp).
+		Put(reqUrl)
+
+	if err != nil {
+		return nil, err
+	}
+	return resp, nil
+}

adaptor/PCM-AI/PCM-OCTOPUS/rpc/internal/logic/uploadimagelogic.go

@@ -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 UploadImageLogic struct {
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+	logx.Logger
+}
+
+func NewUploadImageLogic(ctx context.Context, svcCtx *svc.ServiceContext) *UploadImageLogic {
+	return &UploadImageLogic{
+		ctx:    ctx,
+		svcCtx: svcCtx,
+		Logger: logx.WithContext(ctx),
+	}
+}
+
+func (l *UploadImageLogic) UploadImage(in *octopus.UploadImageReq) (*octopus.UploadImageResp, error) {
+	resp := &octopus.UploadImageResp{}
+
+	var url_prefix = common.OctopusUrls[in.Platform]
+	var reqUrl = url_prefix + l.svcCtx.Config.OctopusApi.UploadImage
+
+	token := common.GetToken(in.Platform)
+
+	req := tool.GetACHttpRequest()
+	_, err := req.
+		SetHeader("Authorization", "Bearer "+token).
+		SetPathParam("imageId", in.ImageId).
+		SetBody(in.UploadImageParam).
+		SetResult(resp).
+		Post(reqUrl)
+
+	if err != nil {
+		return nil, err
+	}
+	return resp, nil
+}

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

@@ -38,17 +38,67 @@ func (s *OctopusServer) GetMyAlgorithmList(ctx context.Context, in *octopus.GetM
 	return l.GetMyAlgorithmList(in)
 }
 
+func (s *OctopusServer) GetAlgorithmList(ctx context.Context, in *octopus.GetAlgorithmListReq) (*octopus.GetAlgorithmListResp, error) {
+	l := logic.NewGetAlgorithmListLogic(ctx, s.svcCtx)
+	return l.GetAlgorithmList(in)
+}
+
+func (s *OctopusServer) GetAlgorithm(ctx context.Context, in *octopus.GetAlgorithmReq) (*octopus.GetAlgorithmResp, error) {
+	l := logic.NewGetAlgorithmLogic(ctx, s.svcCtx)
+	return l.GetAlgorithm(in)
+}
+
+func (s *OctopusServer) GetAlgorithmApplyList(ctx context.Context, in *octopus.GetAlgorithmApplyListReq) (*octopus.GetAlgorithmApplyListResp, error) {
+	l := logic.NewGetAlgorithmApplyListLogic(ctx, s.svcCtx)
+	return l.GetAlgorithmApplyList(in)
+}
+
+func (s *OctopusServer) GetAlgorithmFrameworkList(ctx context.Context, in *octopus.GetAlgorithmFrameworkListReq) (*octopus.GetAlgorithmFrameworkListResp, error) {
+	l := logic.NewGetAlgorithmFrameworkListLogic(ctx, s.svcCtx)
+	return l.GetAlgorithmFrameworkList(in)
+}
+
+func (s *OctopusServer) DeleteMyAlgorithm(ctx context.Context, in *octopus.DeleteMyAlgorithmReq) (*octopus.DeleteMyAlgorithmResp, error) {
+	l := logic.NewDeleteMyAlgorithmLogic(ctx, s.svcCtx)
+	return l.DeleteMyAlgorithm(in)
+}
+
+func (s *OctopusServer) CreateMyAlgorithm(ctx context.Context, in *octopus.CreateMyAlgorithmReq) (*octopus.CreateMyAlgorithmResp, error) {
+	l := logic.NewCreateMyAlgorithmLogic(ctx, s.svcCtx)
+	return l.CreateMyAlgorithm(in)
+}
+
+func (s *OctopusServer) DownloadAlgorithm(ctx context.Context, in *octopus.DownloadAlgorithmReq) (*octopus.DownloadAlgorithmResp, error) {
+	l := logic.NewDownloadAlgorithmLogic(ctx, s.svcCtx)
+	return l.DownloadAlgorithm(in)
+}
+
+func (s *OctopusServer) UploadAlgorithm(ctx context.Context, in *octopus.UploadAlgorithmReq) (*octopus.UploadAlgorithmResp, error) {
+	l := logic.NewUploadAlgorithmLogic(ctx, s.svcCtx)
+	return l.UploadAlgorithm(in)
+}
+
+func (s *OctopusServer) UploadAlgorithmConfirm(ctx context.Context, in *octopus.UploadAlgorithmConfirmReq) (*octopus.UploadAlgorithmConfirmResp, error) {
+	l := logic.NewUploadAlgorithmConfirmLogic(ctx, s.svcCtx)
+	return l.UploadAlgorithmConfirm(in)
+}
+
 // DatasetService
 func (s *OctopusServer) GetMyDatasetList(ctx context.Context, in *octopus.GetMyDatasetListReq) (*octopus.GetMyDatasetListResp, error) {
 	l := logic.NewGetMyDatasetListLogic(ctx, s.svcCtx)
 	return l.GetMyDatasetList(in)
 }
 
-func (s *OctopusServer) CreateDataSet(ctx context.Context, in *octopus.CreateDataSetReq) (*octopus.CreateDataSetResq, error) {
+func (s *OctopusServer) CreateDataSet(ctx context.Context, in *octopus.CreateDataSetReq) (*octopus.CreateDataSetResp, error) {
 	l := logic.NewCreateDataSetLogic(ctx, s.svcCtx)
 	return l.CreateDataSet(in)
 }
 
+func (s *OctopusServer) DeleteDataSet(ctx context.Context, in *octopus.DeleteDataSetReq) (*octopus.DeleteDataSetResp, error) {
+	l := logic.NewDeleteDataSetLogic(ctx, s.svcCtx)
+	return l.DeleteDataSet(in)
+}
+
 // ModelDeployService
 func (s *OctopusServer) GetNotebookList(ctx context.Context, in *octopus.GetNotebookListReq) (*octopus.GetNotebookListResp, error) {
 	l := logic.NewGetNotebookListLogic(ctx, s.svcCtx)
@@ -70,3 +120,13 @@ func (s *OctopusServer) DeleteImage(ctx context.Context, in *octopus.DeleteImage
 	l := logic.NewDeleteImageLogic(ctx, s.svcCtx)
 	return l.DeleteImage(in)
 }
+
+func (s *OctopusServer) UploadImage(ctx context.Context, in *octopus.UploadImageReq) (*octopus.UploadImageResp, error) {
+	l := logic.NewUploadImageLogic(ctx, s.svcCtx)
+	return l.UploadImage(in)
+}
+
+func (s *OctopusServer) UploadImageConfirm(ctx context.Context, in *octopus.UploadImageConfirmReq) (*octopus.UploadImageConfirmResp, error) {
+	l := logic.NewUploadImageConfirmLogic(ctx, s.svcCtx)
+	return l.UploadImageConfirm(in)
+}

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

@@ -1,6 +1,6 @@
 // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
 // versions:
-// - protoc-gen-go-grpc v1.2.0
+// - protoc-gen-go-grpc v1.3.0
 // - protoc             v3.19.4
 // source: octopus.proto
 
@@ -18,24 +18,60 @@ import (
 // Requires gRPC-Go v1.32.0 or later.
 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.
 //
 // 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 {
 	GetComputingPower(ctx context.Context, in *ResourceReq, opts ...grpc.CallOption) (*CpResp, 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)
-	// DatasetService
+	GetAlgorithmList(ctx context.Context, in *GetAlgorithmListReq, opts ...grpc.CallOption) (*GetAlgorithmListResp, error)
+	GetAlgorithm(ctx context.Context, in *GetAlgorithmReq, opts ...grpc.CallOption) (*GetAlgorithmResp, error)
+	GetAlgorithmApplyList(ctx context.Context, in *GetAlgorithmApplyListReq, opts ...grpc.CallOption) (*GetAlgorithmApplyListResp, error)
+	GetAlgorithmFrameworkList(ctx context.Context, in *GetAlgorithmFrameworkListReq, opts ...grpc.CallOption) (*GetAlgorithmFrameworkListResp, error)
+	DeleteMyAlgorithm(ctx context.Context, in *DeleteMyAlgorithmReq, opts ...grpc.CallOption) (*DeleteMyAlgorithmResp, error)
+	CreateMyAlgorithm(ctx context.Context, in *CreateMyAlgorithmReq, opts ...grpc.CallOption) (*CreateMyAlgorithmResp, error)
+	DownloadAlgorithm(ctx context.Context, in *DownloadAlgorithmReq, opts ...grpc.CallOption) (*DownloadAlgorithmResp, error)
+	UploadAlgorithm(ctx context.Context, in *UploadAlgorithmReq, opts ...grpc.CallOption) (*UploadAlgorithmResp, error)
+	UploadAlgorithmConfirm(ctx context.Context, in *UploadAlgorithmConfirmReq, opts ...grpc.CallOption) (*UploadAlgorithmConfirmResp, error)
+	//DatasetService
 	GetMyDatasetList(ctx context.Context, in *GetMyDatasetListReq, opts ...grpc.CallOption) (*GetMyDatasetListResp, error)
-	CreateDataSet(ctx context.Context, in *CreateDataSetReq, opts ...grpc.CallOption) (*CreateDataSetResq, error)
-	// ModelDeployService
-	// Develop
+	CreateDataSet(ctx context.Context, in *CreateDataSetReq, opts ...grpc.CallOption) (*CreateDataSetResp, error)
+	DeleteDataSet(ctx context.Context, in *DeleteDataSetReq, opts ...grpc.CallOption) (*DeleteDataSetResp, error)
+	//ModelDeployService
+	//Develop
 	GetNotebookList(ctx context.Context, in *GetNotebookListReq, opts ...grpc.CallOption) (*GetNotebookListResp, error)
-	// ImageService
+	//ImageService
 	GetUserImageList(ctx context.Context, in *GetUserImageListReq, opts ...grpc.CallOption) (*GetUserImageListResp, error)
 	CreateImage(ctx context.Context, in *CreateImageReq, opts ...grpc.CallOption) (*CreateImageResp, error)
 	DeleteImage(ctx context.Context, in *DeleteImageReq, opts ...grpc.CallOption) (*DeleteImageResp, error)
+	UploadImage(ctx context.Context, in *UploadImageReq, opts ...grpc.CallOption) (*UploadImageResp, error)
+	UploadImageConfirm(ctx context.Context, in *UploadImageConfirmReq, opts ...grpc.CallOption) (*UploadImageConfirmResp, error)
 }
 
 type octopusClient struct {
@@ -48,7 +84,7 @@ func NewOctopusClient(cc grpc.ClientConnInterface) OctopusClient {
 
 func (c *octopusClient) GetComputingPower(ctx context.Context, in *ResourceReq, opts ...grpc.CallOption) (*CpResp, error) {
 	out := new(CpResp)
-	err := c.cc.Invoke(ctx, "/octopus.Octopus/GetComputingPower", in, out, opts...)
+	err := c.cc.Invoke(ctx, Octopus_GetComputingPower_FullMethodName, in, out, opts...)
 	if err != nil {
 		return nil, err
 	}
@@ -57,7 +93,7 @@ func (c *octopusClient) GetComputingPower(ctx context.Context, in *ResourceReq,
 
 func (c *octopusClient) GetGeneralInfo(ctx context.Context, in *ResourceReq, opts ...grpc.CallOption) (*GiResp, error) {
 	out := new(GiResp)
-	err := c.cc.Invoke(ctx, "/octopus.Octopus/GetGeneralInfo", in, out, opts...)
+	err := c.cc.Invoke(ctx, Octopus_GetGeneralInfo_FullMethodName, in, out, opts...)
 	if err != nil {
 		return nil, err
 	}
@@ -66,7 +102,88 @@ func (c *octopusClient) GetGeneralInfo(ctx context.Context, in *ResourceReq, opt
 
 func (c *octopusClient) GetMyAlgorithmList(ctx context.Context, in *GetMyAlgorithmListReq, opts ...grpc.CallOption) (*GetMyAlgorithmListResp, error) {
 	out := new(GetMyAlgorithmListResp)
-	err := c.cc.Invoke(ctx, "/octopus.Octopus/GetMyAlgorithmList", in, out, opts...)
+	err := c.cc.Invoke(ctx, Octopus_GetMyAlgorithmList_FullMethodName, in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *octopusClient) GetAlgorithmList(ctx context.Context, in *GetAlgorithmListReq, opts ...grpc.CallOption) (*GetAlgorithmListResp, error) {
+	out := new(GetAlgorithmListResp)
+	err := c.cc.Invoke(ctx, Octopus_GetAlgorithmList_FullMethodName, in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *octopusClient) GetAlgorithm(ctx context.Context, in *GetAlgorithmReq, opts ...grpc.CallOption) (*GetAlgorithmResp, error) {
+	out := new(GetAlgorithmResp)
+	err := c.cc.Invoke(ctx, Octopus_GetAlgorithm_FullMethodName, in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *octopusClient) GetAlgorithmApplyList(ctx context.Context, in *GetAlgorithmApplyListReq, opts ...grpc.CallOption) (*GetAlgorithmApplyListResp, error) {
+	out := new(GetAlgorithmApplyListResp)
+	err := c.cc.Invoke(ctx, Octopus_GetAlgorithmApplyList_FullMethodName, in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *octopusClient) GetAlgorithmFrameworkList(ctx context.Context, in *GetAlgorithmFrameworkListReq, opts ...grpc.CallOption) (*GetAlgorithmFrameworkListResp, error) {
+	out := new(GetAlgorithmFrameworkListResp)
+	err := c.cc.Invoke(ctx, Octopus_GetAlgorithmFrameworkList_FullMethodName, in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *octopusClient) DeleteMyAlgorithm(ctx context.Context, in *DeleteMyAlgorithmReq, opts ...grpc.CallOption) (*DeleteMyAlgorithmResp, error) {
+	out := new(DeleteMyAlgorithmResp)
+	err := c.cc.Invoke(ctx, Octopus_DeleteMyAlgorithm_FullMethodName, in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *octopusClient) CreateMyAlgorithm(ctx context.Context, in *CreateMyAlgorithmReq, opts ...grpc.CallOption) (*CreateMyAlgorithmResp, error) {
+	out := new(CreateMyAlgorithmResp)
+	err := c.cc.Invoke(ctx, Octopus_CreateMyAlgorithm_FullMethodName, in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *octopusClient) DownloadAlgorithm(ctx context.Context, in *DownloadAlgorithmReq, opts ...grpc.CallOption) (*DownloadAlgorithmResp, error) {
+	out := new(DownloadAlgorithmResp)
+	err := c.cc.Invoke(ctx, Octopus_DownloadAlgorithm_FullMethodName, in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *octopusClient) UploadAlgorithm(ctx context.Context, in *UploadAlgorithmReq, opts ...grpc.CallOption) (*UploadAlgorithmResp, error) {
+	out := new(UploadAlgorithmResp)
+	err := c.cc.Invoke(ctx, Octopus_UploadAlgorithm_FullMethodName, in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *octopusClient) UploadAlgorithmConfirm(ctx context.Context, in *UploadAlgorithmConfirmReq, opts ...grpc.CallOption) (*UploadAlgorithmConfirmResp, error) {
+	out := new(UploadAlgorithmConfirmResp)
+	err := c.cc.Invoke(ctx, Octopus_UploadAlgorithmConfirm_FullMethodName, in, out, opts...)
 	if err != nil {
 		return nil, err
 	}
@@ -75,16 +192,25 @@ func (c *octopusClient) GetMyAlgorithmList(ctx context.Context, in *GetMyAlgorit
 
 func (c *octopusClient) GetMyDatasetList(ctx context.Context, in *GetMyDatasetListReq, opts ...grpc.CallOption) (*GetMyDatasetListResp, error) {
 	out := new(GetMyDatasetListResp)
-	err := c.cc.Invoke(ctx, "/octopus.Octopus/GetMyDatasetList", in, out, opts...)
+	err := c.cc.Invoke(ctx, Octopus_GetMyDatasetList_FullMethodName, in, out, opts...)
 	if err != nil {
 		return nil, err
 	}
 	return out, nil
 }
 
-func (c *octopusClient) CreateDataSet(ctx context.Context, in *CreateDataSetReq, opts ...grpc.CallOption) (*CreateDataSetResq, error) {
-	out := new(CreateDataSetResq)
-	err := c.cc.Invoke(ctx, "/octopus.Octopus/CreateDataSet", in, out, opts...)
+func (c *octopusClient) CreateDataSet(ctx context.Context, in *CreateDataSetReq, opts ...grpc.CallOption) (*CreateDataSetResp, error) {
+	out := new(CreateDataSetResp)
+	err := c.cc.Invoke(ctx, Octopus_CreateDataSet_FullMethodName, in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *octopusClient) DeleteDataSet(ctx context.Context, in *DeleteDataSetReq, opts ...grpc.CallOption) (*DeleteDataSetResp, error) {
+	out := new(DeleteDataSetResp)
+	err := c.cc.Invoke(ctx, Octopus_DeleteDataSet_FullMethodName, in, out, opts...)
 	if err != nil {
 		return nil, err
 	}
@@ -93,7 +219,7 @@ func (c *octopusClient) CreateDataSet(ctx context.Context, in *CreateDataSetReq,
 
 func (c *octopusClient) GetNotebookList(ctx context.Context, in *GetNotebookListReq, opts ...grpc.CallOption) (*GetNotebookListResp, error) {
 	out := new(GetNotebookListResp)
-	err := c.cc.Invoke(ctx, "/octopus.Octopus/GetNotebookList", in, out, opts...)
+	err := c.cc.Invoke(ctx, Octopus_GetNotebookList_FullMethodName, in, out, opts...)
 	if err != nil {
 		return nil, err
 	}
@@ -102,7 +228,7 @@ func (c *octopusClient) GetNotebookList(ctx context.Context, in *GetNotebookList
 
 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...)
+	err := c.cc.Invoke(ctx, Octopus_GetUserImageList_FullMethodName, in, out, opts...)
 	if err != nil {
 		return nil, err
 	}
@@ -111,7 +237,7 @@ func (c *octopusClient) GetUserImageList(ctx context.Context, in *GetUserImageLi
 
 func (c *octopusClient) CreateImage(ctx context.Context, in *CreateImageReq, opts ...grpc.CallOption) (*CreateImageResp, error) {
 	out := new(CreateImageResp)
-	err := c.cc.Invoke(ctx, "/octopus.Octopus/CreateImage", in, out, opts...)
+	err := c.cc.Invoke(ctx, Octopus_CreateImage_FullMethodName, in, out, opts...)
 	if err != nil {
 		return nil, err
 	}
@@ -120,7 +246,25 @@ func (c *octopusClient) CreateImage(ctx context.Context, in *CreateImageReq, opt
 
 func (c *octopusClient) DeleteImage(ctx context.Context, in *DeleteImageReq, opts ...grpc.CallOption) (*DeleteImageResp, error) {
 	out := new(DeleteImageResp)
-	err := c.cc.Invoke(ctx, "/octopus.Octopus/DeleteImage", in, out, opts...)
+	err := c.cc.Invoke(ctx, Octopus_DeleteImage_FullMethodName, in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *octopusClient) UploadImage(ctx context.Context, in *UploadImageReq, opts ...grpc.CallOption) (*UploadImageResp, error) {
+	out := new(UploadImageResp)
+	err := c.cc.Invoke(ctx, Octopus_UploadImage_FullMethodName, in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *octopusClient) UploadImageConfirm(ctx context.Context, in *UploadImageConfirmReq, opts ...grpc.CallOption) (*UploadImageConfirmResp, error) {
+	out := new(UploadImageConfirmResp)
+	err := c.cc.Invoke(ctx, Octopus_UploadImageConfirm_FullMethodName, in, out, opts...)
 	if err != nil {
 		return nil, err
 	}
@@ -133,18 +277,30 @@ func (c *octopusClient) DeleteImage(ctx context.Context, in *DeleteImageReq, opt
 type OctopusServer interface {
 	GetComputingPower(context.Context, *ResourceReq) (*CpResp, error)
 	GetGeneralInfo(context.Context, *ResourceReq) (*GiResp, error)
-	// Algorithm
+	//Algorithm
 	GetMyAlgorithmList(context.Context, *GetMyAlgorithmListReq) (*GetMyAlgorithmListResp, error)
-	// DatasetService
+	GetAlgorithmList(context.Context, *GetAlgorithmListReq) (*GetAlgorithmListResp, error)
+	GetAlgorithm(context.Context, *GetAlgorithmReq) (*GetAlgorithmResp, error)
+	GetAlgorithmApplyList(context.Context, *GetAlgorithmApplyListReq) (*GetAlgorithmApplyListResp, error)
+	GetAlgorithmFrameworkList(context.Context, *GetAlgorithmFrameworkListReq) (*GetAlgorithmFrameworkListResp, error)
+	DeleteMyAlgorithm(context.Context, *DeleteMyAlgorithmReq) (*DeleteMyAlgorithmResp, error)
+	CreateMyAlgorithm(context.Context, *CreateMyAlgorithmReq) (*CreateMyAlgorithmResp, error)
+	DownloadAlgorithm(context.Context, *DownloadAlgorithmReq) (*DownloadAlgorithmResp, error)
+	UploadAlgorithm(context.Context, *UploadAlgorithmReq) (*UploadAlgorithmResp, error)
+	UploadAlgorithmConfirm(context.Context, *UploadAlgorithmConfirmReq) (*UploadAlgorithmConfirmResp, error)
+	//DatasetService
 	GetMyDatasetList(context.Context, *GetMyDatasetListReq) (*GetMyDatasetListResp, error)
-	CreateDataSet(context.Context, *CreateDataSetReq) (*CreateDataSetResq, error)
-	// ModelDeployService
-	// Develop
+	CreateDataSet(context.Context, *CreateDataSetReq) (*CreateDataSetResp, error)
+	DeleteDataSet(context.Context, *DeleteDataSetReq) (*DeleteDataSetResp, error)
+	//ModelDeployService
+	//Develop
 	GetNotebookList(context.Context, *GetNotebookListReq) (*GetNotebookListResp, error)
-	// ImageService
+	//ImageService
 	GetUserImageList(context.Context, *GetUserImageListReq) (*GetUserImageListResp, error)
 	CreateImage(context.Context, *CreateImageReq) (*CreateImageResp, error)
 	DeleteImage(context.Context, *DeleteImageReq) (*DeleteImageResp, error)
+	UploadImage(context.Context, *UploadImageReq) (*UploadImageResp, error)
+	UploadImageConfirm(context.Context, *UploadImageConfirmReq) (*UploadImageConfirmResp, error)
 	mustEmbedUnimplementedOctopusServer()
 }
 
@@ -161,12 +317,42 @@ func (UnimplementedOctopusServer) GetGeneralInfo(context.Context, *ResourceReq)
 func (UnimplementedOctopusServer) GetMyAlgorithmList(context.Context, *GetMyAlgorithmListReq) (*GetMyAlgorithmListResp, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method GetMyAlgorithmList not implemented")
 }
+func (UnimplementedOctopusServer) GetAlgorithmList(context.Context, *GetAlgorithmListReq) (*GetAlgorithmListResp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GetAlgorithmList not implemented")
+}
+func (UnimplementedOctopusServer) GetAlgorithm(context.Context, *GetAlgorithmReq) (*GetAlgorithmResp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GetAlgorithm not implemented")
+}
+func (UnimplementedOctopusServer) GetAlgorithmApplyList(context.Context, *GetAlgorithmApplyListReq) (*GetAlgorithmApplyListResp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GetAlgorithmApplyList not implemented")
+}
+func (UnimplementedOctopusServer) GetAlgorithmFrameworkList(context.Context, *GetAlgorithmFrameworkListReq) (*GetAlgorithmFrameworkListResp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GetAlgorithmFrameworkList not implemented")
+}
+func (UnimplementedOctopusServer) DeleteMyAlgorithm(context.Context, *DeleteMyAlgorithmReq) (*DeleteMyAlgorithmResp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method DeleteMyAlgorithm not implemented")
+}
+func (UnimplementedOctopusServer) CreateMyAlgorithm(context.Context, *CreateMyAlgorithmReq) (*CreateMyAlgorithmResp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method CreateMyAlgorithm not implemented")
+}
+func (UnimplementedOctopusServer) DownloadAlgorithm(context.Context, *DownloadAlgorithmReq) (*DownloadAlgorithmResp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method DownloadAlgorithm not implemented")
+}
+func (UnimplementedOctopusServer) UploadAlgorithm(context.Context, *UploadAlgorithmReq) (*UploadAlgorithmResp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method UploadAlgorithm not implemented")
+}
+func (UnimplementedOctopusServer) UploadAlgorithmConfirm(context.Context, *UploadAlgorithmConfirmReq) (*UploadAlgorithmConfirmResp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method UploadAlgorithmConfirm not implemented")
+}
 func (UnimplementedOctopusServer) GetMyDatasetList(context.Context, *GetMyDatasetListReq) (*GetMyDatasetListResp, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method GetMyDatasetList not implemented")
 }
-func (UnimplementedOctopusServer) CreateDataSet(context.Context, *CreateDataSetReq) (*CreateDataSetResq, error) {
+func (UnimplementedOctopusServer) CreateDataSet(context.Context, *CreateDataSetReq) (*CreateDataSetResp, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method CreateDataSet not implemented")
 }
+func (UnimplementedOctopusServer) DeleteDataSet(context.Context, *DeleteDataSetReq) (*DeleteDataSetResp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method DeleteDataSet not implemented")
+}
 func (UnimplementedOctopusServer) GetNotebookList(context.Context, *GetNotebookListReq) (*GetNotebookListResp, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method GetNotebookList not implemented")
 }
@@ -179,6 +365,12 @@ func (UnimplementedOctopusServer) CreateImage(context.Context, *CreateImageReq)
 func (UnimplementedOctopusServer) DeleteImage(context.Context, *DeleteImageReq) (*DeleteImageResp, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method DeleteImage not implemented")
 }
+func (UnimplementedOctopusServer) UploadImage(context.Context, *UploadImageReq) (*UploadImageResp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method UploadImage not implemented")
+}
+func (UnimplementedOctopusServer) UploadImageConfirm(context.Context, *UploadImageConfirmReq) (*UploadImageConfirmResp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method UploadImageConfirm not implemented")
+}
 func (UnimplementedOctopusServer) mustEmbedUnimplementedOctopusServer() {}
 
 // UnsafeOctopusServer may be embedded to opt out of forward compatibility for this service.
@@ -202,7 +394,7 @@ func _Octopus_GetComputingPower_Handler(srv interface{}, ctx context.Context, de
 	}
 	info := &grpc.UnaryServerInfo{
 		Server:     srv,
-		FullMethod: "/octopus.Octopus/GetComputingPower",
+		FullMethod: Octopus_GetComputingPower_FullMethodName,
 	}
 	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
 		return srv.(OctopusServer).GetComputingPower(ctx, req.(*ResourceReq))
@@ -220,7 +412,7 @@ func _Octopus_GetGeneralInfo_Handler(srv interface{}, ctx context.Context, dec f
 	}
 	info := &grpc.UnaryServerInfo{
 		Server:     srv,
-		FullMethod: "/octopus.Octopus/GetGeneralInfo",
+		FullMethod: Octopus_GetGeneralInfo_FullMethodName,
 	}
 	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
 		return srv.(OctopusServer).GetGeneralInfo(ctx, req.(*ResourceReq))
@@ -238,7 +430,7 @@ func _Octopus_GetMyAlgorithmList_Handler(srv interface{}, ctx context.Context, d
 	}
 	info := &grpc.UnaryServerInfo{
 		Server:     srv,
-		FullMethod: "/octopus.Octopus/GetMyAlgorithmList",
+		FullMethod: Octopus_GetMyAlgorithmList_FullMethodName,
 	}
 	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
 		return srv.(OctopusServer).GetMyAlgorithmList(ctx, req.(*GetMyAlgorithmListReq))
@@ -246,6 +438,168 @@ func _Octopus_GetMyAlgorithmList_Handler(srv interface{}, ctx context.Context, d
 	return interceptor(ctx, in, info, handler)
 }
 
+func _Octopus_GetAlgorithmList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(GetAlgorithmListReq)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(OctopusServer).GetAlgorithmList(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: Octopus_GetAlgorithmList_FullMethodName,
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(OctopusServer).GetAlgorithmList(ctx, req.(*GetAlgorithmListReq))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _Octopus_GetAlgorithm_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(GetAlgorithmReq)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(OctopusServer).GetAlgorithm(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: Octopus_GetAlgorithm_FullMethodName,
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(OctopusServer).GetAlgorithm(ctx, req.(*GetAlgorithmReq))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _Octopus_GetAlgorithmApplyList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(GetAlgorithmApplyListReq)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(OctopusServer).GetAlgorithmApplyList(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: Octopus_GetAlgorithmApplyList_FullMethodName,
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(OctopusServer).GetAlgorithmApplyList(ctx, req.(*GetAlgorithmApplyListReq))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _Octopus_GetAlgorithmFrameworkList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(GetAlgorithmFrameworkListReq)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(OctopusServer).GetAlgorithmFrameworkList(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: Octopus_GetAlgorithmFrameworkList_FullMethodName,
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(OctopusServer).GetAlgorithmFrameworkList(ctx, req.(*GetAlgorithmFrameworkListReq))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _Octopus_DeleteMyAlgorithm_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(DeleteMyAlgorithmReq)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(OctopusServer).DeleteMyAlgorithm(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: Octopus_DeleteMyAlgorithm_FullMethodName,
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(OctopusServer).DeleteMyAlgorithm(ctx, req.(*DeleteMyAlgorithmReq))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _Octopus_CreateMyAlgorithm_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(CreateMyAlgorithmReq)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(OctopusServer).CreateMyAlgorithm(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: Octopus_CreateMyAlgorithm_FullMethodName,
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(OctopusServer).CreateMyAlgorithm(ctx, req.(*CreateMyAlgorithmReq))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _Octopus_DownloadAlgorithm_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(DownloadAlgorithmReq)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(OctopusServer).DownloadAlgorithm(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: Octopus_DownloadAlgorithm_FullMethodName,
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(OctopusServer).DownloadAlgorithm(ctx, req.(*DownloadAlgorithmReq))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _Octopus_UploadAlgorithm_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(UploadAlgorithmReq)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(OctopusServer).UploadAlgorithm(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: Octopus_UploadAlgorithm_FullMethodName,
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(OctopusServer).UploadAlgorithm(ctx, req.(*UploadAlgorithmReq))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _Octopus_UploadAlgorithmConfirm_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(UploadAlgorithmConfirmReq)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(OctopusServer).UploadAlgorithmConfirm(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: Octopus_UploadAlgorithmConfirm_FullMethodName,
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(OctopusServer).UploadAlgorithmConfirm(ctx, req.(*UploadAlgorithmConfirmReq))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
 func _Octopus_GetMyDatasetList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
 	in := new(GetMyDatasetListReq)
 	if err := dec(in); err != nil {
@@ -256,7 +610,7 @@ func _Octopus_GetMyDatasetList_Handler(srv interface{}, ctx context.Context, dec
 	}
 	info := &grpc.UnaryServerInfo{
 		Server:     srv,
-		FullMethod: "/octopus.Octopus/GetMyDatasetList",
+		FullMethod: Octopus_GetMyDatasetList_FullMethodName,
 	}
 	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
 		return srv.(OctopusServer).GetMyDatasetList(ctx, req.(*GetMyDatasetListReq))
@@ -274,7 +628,7 @@ func _Octopus_CreateDataSet_Handler(srv interface{}, ctx context.Context, dec fu
 	}
 	info := &grpc.UnaryServerInfo{
 		Server:     srv,
-		FullMethod: "/octopus.Octopus/CreateDataSet",
+		FullMethod: Octopus_CreateDataSet_FullMethodName,
 	}
 	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
 		return srv.(OctopusServer).CreateDataSet(ctx, req.(*CreateDataSetReq))
@@ -282,6 +636,24 @@ func _Octopus_CreateDataSet_Handler(srv interface{}, ctx context.Context, dec fu
 	return interceptor(ctx, in, info, handler)
 }
 
+func _Octopus_DeleteDataSet_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(DeleteDataSetReq)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(OctopusServer).DeleteDataSet(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: Octopus_DeleteDataSet_FullMethodName,
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(OctopusServer).DeleteDataSet(ctx, req.(*DeleteDataSetReq))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
 func _Octopus_GetNotebookList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
 	in := new(GetNotebookListReq)
 	if err := dec(in); err != nil {
@@ -292,7 +664,7 @@ func _Octopus_GetNotebookList_Handler(srv interface{}, ctx context.Context, dec
 	}
 	info := &grpc.UnaryServerInfo{
 		Server:     srv,
-		FullMethod: "/octopus.Octopus/GetNotebookList",
+		FullMethod: Octopus_GetNotebookList_FullMethodName,
 	}
 	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
 		return srv.(OctopusServer).GetNotebookList(ctx, req.(*GetNotebookListReq))
@@ -310,7 +682,7 @@ func _Octopus_GetUserImageList_Handler(srv interface{}, ctx context.Context, dec
 	}
 	info := &grpc.UnaryServerInfo{
 		Server:     srv,
-		FullMethod: "/octopus.Octopus/GetUserImageList",
+		FullMethod: Octopus_GetUserImageList_FullMethodName,
 	}
 	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
 		return srv.(OctopusServer).GetUserImageList(ctx, req.(*GetUserImageListReq))
@@ -328,7 +700,7 @@ func _Octopus_CreateImage_Handler(srv interface{}, ctx context.Context, dec func
 	}
 	info := &grpc.UnaryServerInfo{
 		Server:     srv,
-		FullMethod: "/octopus.Octopus/CreateImage",
+		FullMethod: Octopus_CreateImage_FullMethodName,
 	}
 	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
 		return srv.(OctopusServer).CreateImage(ctx, req.(*CreateImageReq))
@@ -346,7 +718,7 @@ func _Octopus_DeleteImage_Handler(srv interface{}, ctx context.Context, dec func
 	}
 	info := &grpc.UnaryServerInfo{
 		Server:     srv,
-		FullMethod: "/octopus.Octopus/DeleteImage",
+		FullMethod: Octopus_DeleteImage_FullMethodName,
 	}
 	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
 		return srv.(OctopusServer).DeleteImage(ctx, req.(*DeleteImageReq))
@@ -354,6 +726,42 @@ func _Octopus_DeleteImage_Handler(srv interface{}, ctx context.Context, dec func
 	return interceptor(ctx, in, info, handler)
 }
 
+func _Octopus_UploadImage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(UploadImageReq)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(OctopusServer).UploadImage(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: Octopus_UploadImage_FullMethodName,
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(OctopusServer).UploadImage(ctx, req.(*UploadImageReq))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _Octopus_UploadImageConfirm_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(UploadImageConfirmReq)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(OctopusServer).UploadImageConfirm(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: Octopus_UploadImageConfirm_FullMethodName,
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(OctopusServer).UploadImageConfirm(ctx, req.(*UploadImageConfirmReq))
+	}
+	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)
@@ -373,6 +781,42 @@ var Octopus_ServiceDesc = grpc.ServiceDesc{
 			MethodName: "GetMyAlgorithmList",
 			Handler:    _Octopus_GetMyAlgorithmList_Handler,
 		},
+		{
+			MethodName: "GetAlgorithmList",
+			Handler:    _Octopus_GetAlgorithmList_Handler,
+		},
+		{
+			MethodName: "GetAlgorithm",
+			Handler:    _Octopus_GetAlgorithm_Handler,
+		},
+		{
+			MethodName: "GetAlgorithmApplyList",
+			Handler:    _Octopus_GetAlgorithmApplyList_Handler,
+		},
+		{
+			MethodName: "GetAlgorithmFrameworkList",
+			Handler:    _Octopus_GetAlgorithmFrameworkList_Handler,
+		},
+		{
+			MethodName: "DeleteMyAlgorithm",
+			Handler:    _Octopus_DeleteMyAlgorithm_Handler,
+		},
+		{
+			MethodName: "CreateMyAlgorithm",
+			Handler:    _Octopus_CreateMyAlgorithm_Handler,
+		},
+		{
+			MethodName: "DownloadAlgorithm",
+			Handler:    _Octopus_DownloadAlgorithm_Handler,
+		},
+		{
+			MethodName: "UploadAlgorithm",
+			Handler:    _Octopus_UploadAlgorithm_Handler,
+		},
+		{
+			MethodName: "UploadAlgorithmConfirm",
+			Handler:    _Octopus_UploadAlgorithmConfirm_Handler,
+		},
 		{
 			MethodName: "GetMyDatasetList",
 			Handler:    _Octopus_GetMyDatasetList_Handler,
@@ -381,6 +825,10 @@ var Octopus_ServiceDesc = grpc.ServiceDesc{
 			MethodName: "CreateDataSet",
 			Handler:    _Octopus_CreateDataSet_Handler,
 		},
+		{
+			MethodName: "DeleteDataSet",
+			Handler:    _Octopus_DeleteDataSet_Handler,
+		},
 		{
 			MethodName: "GetNotebookList",
 			Handler:    _Octopus_GetNotebookList_Handler,
@@ -397,6 +845,14 @@ var Octopus_ServiceDesc = grpc.ServiceDesc{
 			MethodName: "DeleteImage",
 			Handler:    _Octopus_DeleteImage_Handler,
 		},
+		{
+			MethodName: "UploadImage",
+			Handler:    _Octopus_UploadImage_Handler,
+		},
+		{
+			MethodName: "UploadImageConfirm",
+			Handler:    _Octopus_UploadImageConfirm_Handler,
+		},
 	},
 	Streams:  []grpc.StreamDesc{},
 	Metadata: "octopus.proto",

adaptor/PCM-AI/PCM-OCTOPUS/rpc/octopusclient/octopus.go

@@ -13,18 +13,37 @@ import (
 )
 
 type (
+	AlgorithmDetail               = octopus.AlgorithmDetail
 	Algorithms                    = octopus.Algorithms
 	Applies                       = octopus.Applies
 	CpResp                        = octopus.CpResp
+	CreateDataSet                 = octopus.CreateDataSet
 	CreateDataSetReq              = octopus.CreateDataSetReq
-	CreateDataSetResq      = octopus.CreateDataSetResq
+	CreateDataSetResp             = octopus.CreateDataSetResp
 	CreateImage                   = octopus.CreateImage
 	CreateImageReq                = octopus.CreateImageReq
 	CreateImageResp               = octopus.CreateImageResp
+	CreateMyAlgorithm             = octopus.CreateMyAlgorithm
+	CreateMyAlgorithmReq          = octopus.CreateMyAlgorithmReq
+	CreateMyAlgorithmResp         = octopus.CreateMyAlgorithmResp
 	Datasets                      = octopus.Datasets
+	DeleteDataSetReq              = octopus.DeleteDataSetReq
+	DeleteDataSetResp             = octopus.DeleteDataSetResp
 	DeleteImageReq                = octopus.DeleteImageReq
 	DeleteImageResp               = octopus.DeleteImageResp
+	DeleteMyAlgorithmReq          = octopus.DeleteMyAlgorithmReq
+	DeleteMyAlgorithmResp         = octopus.DeleteMyAlgorithmResp
+	DownloadAlgorithmReq          = octopus.DownloadAlgorithmReq
+	DownloadAlgorithmResp         = octopus.DownloadAlgorithmResp
 	Error                         = octopus.Error
+	GetAlgorithmApplyListReq      = octopus.GetAlgorithmApplyListReq
+	GetAlgorithmApplyListResp     = octopus.GetAlgorithmApplyListResp
+	GetAlgorithmFrameworkListReq  = octopus.GetAlgorithmFrameworkListReq
+	GetAlgorithmFrameworkListResp = octopus.GetAlgorithmFrameworkListResp
+	GetAlgorithmListReq           = octopus.GetAlgorithmListReq
+	GetAlgorithmListResp          = octopus.GetAlgorithmListResp
+	GetAlgorithmReq               = octopus.GetAlgorithmReq
+	GetAlgorithmResp              = octopus.GetAlgorithmResp
 	GetMyAlgorithmListReq         = octopus.GetMyAlgorithmListReq
 	GetMyAlgorithmListResp        = octopus.GetMyAlgorithmListResp
 	GetMyDatasetListReq           = octopus.GetMyDatasetListReq
@@ -34,32 +53,70 @@ type (
 	GetUserImageListReq           = octopus.GetUserImageListReq
 	GetUserImageListResp          = octopus.GetUserImageListResp
 	GiResp                        = octopus.GiResp
+	Headers                       = octopus.Headers
 	Image                         = octopus.Image
 	Images                        = octopus.Images
+	Lables                        = octopus.Lables
 	Notebooks                     = octopus.Notebooks
+	PayloadAlgorithmFrameworkList = octopus.PayloadAlgorithmFrameworkList
+	PayloadAlgorithmList          = octopus.PayloadAlgorithmList
+	PayloadCreateDataSet          = octopus.PayloadCreateDataSet
 	PayloadCreateImage            = octopus.PayloadCreateImage
+	PayloadCreateMyAlgorithm      = octopus.PayloadCreateMyAlgorithm
+	PayloadDeleteDataSet          = octopus.PayloadDeleteDataSet
 	PayloadDeleteImage            = octopus.PayloadDeleteImage
+	PayloadDeleteMyAlgorithm      = octopus.PayloadDeleteMyAlgorithm
+	PayloadDownloadAlgorithm      = octopus.PayloadDownloadAlgorithm
+	PayloadGetAlgorithm           = octopus.PayloadGetAlgorithm
+	PayloadGetAlgorithmApplyList  = octopus.PayloadGetAlgorithmApplyList
 	PayloadMyAlgorithmList        = octopus.PayloadMyAlgorithmList
 	PayloadMyDatasetList          = octopus.PayloadMyDatasetList
 	PayloadNotebookList           = octopus.PayloadNotebookList
+	PayloadUploadAlgorithm        = octopus.PayloadUploadAlgorithm
+	PayloadUploadAlgorithmConfirm = octopus.PayloadUploadAlgorithmConfirm
+	PayloadUploadImage            = octopus.PayloadUploadImage
+	PayloadUploadImageConfirm     = octopus.PayloadUploadImageConfirm
 	PayloadUserImageList          = octopus.PayloadUserImageList
 	ResourceReq                   = octopus.ResourceReq
 	Tasks                         = octopus.Tasks
+	UploadAlgorithmConfirmReq     = octopus.UploadAlgorithmConfirmReq
+	UploadAlgorithmConfirmResp    = octopus.UploadAlgorithmConfirmResp
+	UploadAlgorithmParam          = octopus.UploadAlgorithmParam
+	UploadAlgorithmReq            = octopus.UploadAlgorithmReq
+	UploadAlgorithmResp           = octopus.UploadAlgorithmResp
+	UploadImageConfirmReq         = octopus.UploadImageConfirmReq
+	UploadImageConfirmResp        = octopus.UploadImageConfirmResp
+	UploadImageParam              = octopus.UploadImageParam
+	UploadImageReq                = octopus.UploadImageReq
+	UploadImageResp               = octopus.UploadImageResp
+	VersionAccesses               = octopus.VersionAccesses
 
 	Octopus interface {
 		GetComputingPower(ctx context.Context, in *ResourceReq, opts ...grpc.CallOption) (*CpResp, error)
 		GetGeneralInfo(ctx context.Context, in *ResourceReq, opts ...grpc.CallOption) (*GiResp, error)
 		// Algorithm
 		GetMyAlgorithmList(ctx context.Context, in *GetMyAlgorithmListReq, opts ...grpc.CallOption) (*GetMyAlgorithmListResp, error)
+		GetAlgorithmList(ctx context.Context, in *GetAlgorithmListReq, opts ...grpc.CallOption) (*GetAlgorithmListResp, error)
+		GetAlgorithm(ctx context.Context, in *GetAlgorithmReq, opts ...grpc.CallOption) (*GetAlgorithmResp, error)
+		GetAlgorithmApplyList(ctx context.Context, in *GetAlgorithmApplyListReq, opts ...grpc.CallOption) (*GetAlgorithmApplyListResp, error)
+		GetAlgorithmFrameworkList(ctx context.Context, in *GetAlgorithmFrameworkListReq, opts ...grpc.CallOption) (*GetAlgorithmFrameworkListResp, error)
+		DeleteMyAlgorithm(ctx context.Context, in *DeleteMyAlgorithmReq, opts ...grpc.CallOption) (*DeleteMyAlgorithmResp, error)
+		CreateMyAlgorithm(ctx context.Context, in *CreateMyAlgorithmReq, opts ...grpc.CallOption) (*CreateMyAlgorithmResp, error)
+		DownloadAlgorithm(ctx context.Context, in *DownloadAlgorithmReq, opts ...grpc.CallOption) (*DownloadAlgorithmResp, error)
+		UploadAlgorithm(ctx context.Context, in *UploadAlgorithmReq, opts ...grpc.CallOption) (*UploadAlgorithmResp, error)
+		UploadAlgorithmConfirm(ctx context.Context, in *UploadAlgorithmConfirmReq, opts ...grpc.CallOption) (*UploadAlgorithmConfirmResp, error)
 		// DatasetService
 		GetMyDatasetList(ctx context.Context, in *GetMyDatasetListReq, opts ...grpc.CallOption) (*GetMyDatasetListResp, error)
-		CreateDataSet(ctx context.Context, in *CreateDataSetReq, opts ...grpc.CallOption) (*CreateDataSetResq, error)
+		CreateDataSet(ctx context.Context, in *CreateDataSetReq, opts ...grpc.CallOption) (*CreateDataSetResp, error)
+		DeleteDataSet(ctx context.Context, in *DeleteDataSetReq, opts ...grpc.CallOption) (*DeleteDataSetResp, error)
 		// ModelDeployService
 		GetNotebookList(ctx context.Context, in *GetNotebookListReq, opts ...grpc.CallOption) (*GetNotebookListResp, error)
 		// ImageService
 		GetUserImageList(ctx context.Context, in *GetUserImageListReq, opts ...grpc.CallOption) (*GetUserImageListResp, error)
 		CreateImage(ctx context.Context, in *CreateImageReq, opts ...grpc.CallOption) (*CreateImageResp, error)
 		DeleteImage(ctx context.Context, in *DeleteImageReq, opts ...grpc.CallOption) (*DeleteImageResp, error)
+		UploadImage(ctx context.Context, in *UploadImageReq, opts ...grpc.CallOption) (*UploadImageResp, error)
+		UploadImageConfirm(ctx context.Context, in *UploadImageConfirmReq, opts ...grpc.CallOption) (*UploadImageConfirmResp, error)
 	}
 
 	defaultOctopus struct {
@@ -89,17 +146,67 @@ func (m *defaultOctopus) GetMyAlgorithmList(ctx context.Context, in *GetMyAlgori
 	return client.GetMyAlgorithmList(ctx, in, opts...)
 }
 
+func (m *defaultOctopus) GetAlgorithmList(ctx context.Context, in *GetAlgorithmListReq, opts ...grpc.CallOption) (*GetAlgorithmListResp, error) {
+	client := octopus.NewOctopusClient(m.cli.Conn())
+	return client.GetAlgorithmList(ctx, in, opts...)
+}
+
+func (m *defaultOctopus) GetAlgorithm(ctx context.Context, in *GetAlgorithmReq, opts ...grpc.CallOption) (*GetAlgorithmResp, error) {
+	client := octopus.NewOctopusClient(m.cli.Conn())
+	return client.GetAlgorithm(ctx, in, opts...)
+}
+
+func (m *defaultOctopus) GetAlgorithmApplyList(ctx context.Context, in *GetAlgorithmApplyListReq, opts ...grpc.CallOption) (*GetAlgorithmApplyListResp, error) {
+	client := octopus.NewOctopusClient(m.cli.Conn())
+	return client.GetAlgorithmApplyList(ctx, in, opts...)
+}
+
+func (m *defaultOctopus) GetAlgorithmFrameworkList(ctx context.Context, in *GetAlgorithmFrameworkListReq, opts ...grpc.CallOption) (*GetAlgorithmFrameworkListResp, error) {
+	client := octopus.NewOctopusClient(m.cli.Conn())
+	return client.GetAlgorithmFrameworkList(ctx, in, opts...)
+}
+
+func (m *defaultOctopus) DeleteMyAlgorithm(ctx context.Context, in *DeleteMyAlgorithmReq, opts ...grpc.CallOption) (*DeleteMyAlgorithmResp, error) {
+	client := octopus.NewOctopusClient(m.cli.Conn())
+	return client.DeleteMyAlgorithm(ctx, in, opts...)
+}
+
+func (m *defaultOctopus) CreateMyAlgorithm(ctx context.Context, in *CreateMyAlgorithmReq, opts ...grpc.CallOption) (*CreateMyAlgorithmResp, error) {
+	client := octopus.NewOctopusClient(m.cli.Conn())
+	return client.CreateMyAlgorithm(ctx, in, opts...)
+}
+
+func (m *defaultOctopus) DownloadAlgorithm(ctx context.Context, in *DownloadAlgorithmReq, opts ...grpc.CallOption) (*DownloadAlgorithmResp, error) {
+	client := octopus.NewOctopusClient(m.cli.Conn())
+	return client.DownloadAlgorithm(ctx, in, opts...)
+}
+
+func (m *defaultOctopus) UploadAlgorithm(ctx context.Context, in *UploadAlgorithmReq, opts ...grpc.CallOption) (*UploadAlgorithmResp, error) {
+	client := octopus.NewOctopusClient(m.cli.Conn())
+	return client.UploadAlgorithm(ctx, in, opts...)
+}
+
+func (m *defaultOctopus) UploadAlgorithmConfirm(ctx context.Context, in *UploadAlgorithmConfirmReq, opts ...grpc.CallOption) (*UploadAlgorithmConfirmResp, error) {
+	client := octopus.NewOctopusClient(m.cli.Conn())
+	return client.UploadAlgorithmConfirm(ctx, in, opts...)
+}
+
 // DatasetService
 func (m *defaultOctopus) GetMyDatasetList(ctx context.Context, in *GetMyDatasetListReq, opts ...grpc.CallOption) (*GetMyDatasetListResp, error) {
 	client := octopus.NewOctopusClient(m.cli.Conn())
 	return client.GetMyDatasetList(ctx, in, opts...)
 }
 
-func (m *defaultOctopus) CreateDataSet(ctx context.Context, in *CreateDataSetReq, opts ...grpc.CallOption) (*CreateDataSetResq, error) {
+func (m *defaultOctopus) CreateDataSet(ctx context.Context, in *CreateDataSetReq, opts ...grpc.CallOption) (*CreateDataSetResp, error) {
 	client := octopus.NewOctopusClient(m.cli.Conn())
 	return client.CreateDataSet(ctx, in, opts...)
 }
 
+func (m *defaultOctopus) DeleteDataSet(ctx context.Context, in *DeleteDataSetReq, opts ...grpc.CallOption) (*DeleteDataSetResp, error) {
+	client := octopus.NewOctopusClient(m.cli.Conn())
+	return client.DeleteDataSet(ctx, in, opts...)
+}
+
 // ModelDeployService
 func (m *defaultOctopus) GetNotebookList(ctx context.Context, in *GetNotebookListReq, opts ...grpc.CallOption) (*GetNotebookListResp, error) {
 	client := octopus.NewOctopusClient(m.cli.Conn())
@@ -121,3 +228,13 @@ func (m *defaultOctopus) DeleteImage(ctx context.Context, in *DeleteImageReq, op
 	client := octopus.NewOctopusClient(m.cli.Conn())
 	return client.DeleteImage(ctx, in, opts...)
 }
+
+func (m *defaultOctopus) UploadImage(ctx context.Context, in *UploadImageReq, opts ...grpc.CallOption) (*UploadImageResp, error) {
+	client := octopus.NewOctopusClient(m.cli.Conn())
+	return client.UploadImage(ctx, in, opts...)
+}
+
+func (m *defaultOctopus) UploadImageConfirm(ctx context.Context, in *UploadImageConfirmReq, opts ...grpc.CallOption) (*UploadImageConfirmResp, error) {
+	client := octopus.NewOctopusClient(m.cli.Conn())
+	return client.UploadImageConfirm(ctx, in, opts...)
+}

adaptor/PCM-AI/PCM-OCTOPUS/rpc/pb/octopus.proto

@@ -16,21 +16,107 @@ message giResp{
   int32 memoryInGib = 2;
 }
 
-
-message CreateDataSetReq {
-  repeated string applyIds = 1; // @gotags: copier:"ApplyIds"
-  string desc = 2;               // @gotags: copier:"Desc"
-  string name = 3;               // @gotags: copier:"Name"
-  string typeId = 4;             // @gotags: copier:"TypeId"
-
-}
-
-message CreateDataSetResq{
-  string id =1;                  // @gotags: copier:"Id"
-  string  version =2;            // @gotags: copier:"Version"
-}
-
 /******************Algorithm Start*************************/
+message GetAlgorithmReq{
+  string platform =1;
+  string algorithmId = 2;
+  string version = 3;
+}
+
+message GetAlgorithmResp{
+  bool success =1;
+  PayloadGetAlgorithm payload =2;
+  Error error = 3;
+}
+
+message PayloadGetAlgorithm{
+  Algorithms algorithm = 1;
+  repeated VersionAccesses versionAccesses = 2;
+}
+
+message VersionAccesses{
+  string algorithmId = 1;
+  string spaceId = 2;
+  string version = 3;
+}
+
+message DownloadAlgorithmReq{
+  string platform =1;
+  string algorithmId = 2;
+  string version = 3;
+}
+
+message DownloadAlgorithmResp{
+  bool success =1;
+  PayloadDownloadAlgorithm payload =2;
+  Error error = 3;
+}
+
+message PayloadDownloadAlgorithm{
+  string downloadUrl = 1;
+}
+
+message UploadAlgorithmReq{
+  string platform =1;
+  string algorithmId = 2;
+  string version = 3;
+  UploadAlgorithmParam uploadAlgorithmParam = 4;
+}
+
+message UploadAlgorithmParam{
+  string domain = 1;
+  string fileName = 2;
+}
+
+message UploadAlgorithmResp{
+  bool success =1;
+  PayloadUploadAlgorithm payload =2;
+  Error error = 3;
+}
+
+message PayloadUploadAlgorithm{
+  string uploadUrl = 1;
+}
+
+message UploadAlgorithmConfirmReq{
+  string platform =1;
+  string algorithmId = 2;
+  string version = 3;
+  string fileName = 4;
+}
+
+message UploadAlgorithmConfirmResp{
+  bool success =1;
+  PayloadUploadAlgorithmConfirm payload =2;
+  Error error = 3;
+}
+
+message PayloadUploadAlgorithmConfirm{
+  int64 updatedAt = 1;
+}
+
+message GetAlgorithmListReq{
+  string platform =1;
+  int32 pageIndex =2;
+  int32 pageSize =3;
+}
+
+message GetAlgorithmListResp{
+  bool success =1;
+  PayloadAlgorithmList payload =2;
+  Error error = 3;
+}
+
+message PayloadAlgorithmList{
+  int32 totalSize =1;
+  repeated AlgorithmDetail algorithms = 2;
+}
+
+message AlgorithmDetail{
+  Algorithms algorithmDetail = 1;
+  bool isShared =2;
+}
+
 message GetMyAlgorithmListReq{
   string platform =1;
   int32 pageIndex =2;
@@ -68,9 +154,114 @@ message Algorithms{
   string frameworkId=17;
   string frameworkName=18;
 }
+
+message GetAlgorithmApplyListReq{
+  string platform =1;
+  int32 pageIndex =2;
+  int32 pageSize =3;
+}
+
+message GetAlgorithmApplyListResp{
+  bool success =1;
+  PayloadGetAlgorithmApplyList payload =2;
+  Error error = 3;
+}
+
+message PayloadGetAlgorithmApplyList{
+  int32 totalSize = 1;
+  repeated Lables lables =2;
+}
+
+message GetAlgorithmFrameworkListReq{
+  string platform =1;
+  int32 pageIndex =2;
+  int32 pageSize =3;
+}
+
+message GetAlgorithmFrameworkListResp{
+  bool success =1;
+  PayloadAlgorithmFrameworkList payload =2;
+  Error error = 3;
+}
+
+message PayloadAlgorithmFrameworkList{
+  int32 totalSize = 1;
+  repeated Lables lables =2;
+}
+
+message Lables{
+  string id = 1;
+  string lableDesc = 2;
+  int32 sourceType = 3;
+}
+
+message DeleteMyAlgorithmReq{
+  string platform =1;
+  string algorithmId=2;
+}
+
+message DeleteMyAlgorithmResp{
+  bool success =1;
+  PayloadDeleteMyAlgorithm payload =2;
+  Error error = 3;
+}
+
+message PayloadDeleteMyAlgorithm{
+  int64 deletedAt=1;
+}
+
+message CreateMyAlgorithmReq{
+  string platform =1;
+  CreateMyAlgorithm createMyAlgorithm=2;
+}
+
+message CreateMyAlgorithmResp{
+  bool success =1;
+  PayloadCreateMyAlgorithm payload =2;
+  Error error = 3;
+}
+
+message CreateMyAlgorithm{
+  string algorithmDescript = 1;
+  string algorithmName =2;
+  string applyId =3;
+  string frameworkId =4;
+  string isEmpty =5;
+  string modelName=6;
+}
+
+message PayloadCreateMyAlgorithm{
+  string algorithmId =1;
+  int64 createdAt =2;
+  string version =3;
+}
+
 /******************Algorithm End*************************/
 
 /******************DatasetService Start*************************/
+message CreateDataSetReq{
+  string platform =1;
+  CreateDataSet  createDataSet=2;
+}
+
+message CreateDataSetResp{
+  bool success =1;
+  PayloadCreateDataSet payload =2;
+  Error error = 3;
+}
+
+message CreateDataSet{
+  repeated string applyIds = 1;
+  string desc = 2;
+  string name = 3;
+  string typeId = 4;
+}
+
+message PayloadCreateDataSet{
+  string id = 1;
+  string version = 2;
+}
+
 message GetMyDatasetListReq{
   string platform =1;
   int32 pageIndex =2;
@@ -105,6 +296,21 @@ message Applies{
   string id=1;
   string desc=2;
 }
+
+message DeleteDataSetReq{
+  string platform =1;
+  string id=2;
+}
+
+message DeleteDataSetResp{
+  bool success =1;
+  PayloadDeleteDataSet payload =2;
+  Error error = 3;
+}
+
+message PayloadDeleteDataSet{
+  int64 deletedAt = 1;
+}
 /******************DatasetService End*************************/
 
 /******************ModelDeployService Start*************************/
@@ -238,6 +444,49 @@ message PayloadCreateImage{
   int64 createdAt=2;
 }
 
+message UploadImageReq{
+  string platform =1;
+  string imageId=2;
+  UploadImageParam uploadImageParam = 3;
+}
+
+message UploadImageParam{
+  string domain = 1;
+  string fileName = 2;
+}
+
+message UploadImageResp{
+  bool success =1;
+  PayloadUploadImage payload =2;
+  Error error = 3;
+}
+
+message PayloadUploadImage{
+  string uploadUrl = 1;
+  Headers headers = 2;
+}
+
+message Headers{
+  string additionalProp1=1;
+  string additionalProp2=2;
+  string additionalProp3=3;
+}
+
+message UploadImageConfirmReq{
+  string platform =1;
+  string imageId=2;
+}
+
+message UploadImageConfirmResp{
+  bool success =1;
+  PayloadUploadImageConfirm payload =2;
+  Error error = 3;
+}
+
+message PayloadUploadImageConfirm{
+  int64 updatedAt = 1;
+}
+
 /******************ImageService End*************************/
 
 /******************Model Start*************************/
@@ -262,11 +511,26 @@ service Octopus {
 
   //Algorithm
   rpc GetMyAlgorithmList(GetMyAlgorithmListReq) returns (GetMyAlgorithmListResp);
+  rpc GetAlgorithmList(GetAlgorithmListReq) returns (GetAlgorithmListResp); //查询算法版本列表
+  rpc GetAlgorithm(GetAlgorithmReq) returns (GetAlgorithmResp); //查询算法版本详情
+  rpc GetAlgorithmApplyList(GetAlgorithmApplyListReq) returns (GetAlgorithmApplyListResp);
+  rpc GetAlgorithmFrameworkList(GetAlgorithmFrameworkListReq) returns (GetAlgorithmFrameworkListResp);
+  rpc DeleteMyAlgorithm(DeleteMyAlgorithmReq) returns (DeleteMyAlgorithmResp);
+  rpc CreateMyAlgorithm(CreateMyAlgorithmReq) returns (CreateMyAlgorithmResp);
+  rpc DownloadAlgorithm(DownloadAlgorithmReq) returns (DownloadAlgorithmResp); //下载算法版本
+  rpc UploadAlgorithm(UploadAlgorithmReq) returns (UploadAlgorithmResp);
+  rpc UploadAlgorithmConfirm(UploadAlgorithmConfirmReq) returns (UploadAlgorithmConfirmResp);
+
+
+
+
+
 
   //DatasetService
   rpc GetMyDatasetList(GetMyDatasetListReq) returns (GetMyDatasetListResp);
+  rpc CreateDataSet(CreateDataSetReq) returns (CreateDataSetResp);
+  rpc DeleteDataSet(DeleteDataSetReq) returns (DeleteDataSetResp);
 
-  rpc CreateDataSet(CreateDataSetReq) returns (CreateDataSetResq);
 
 
   //ModelDeployService
@@ -275,10 +539,10 @@ service Octopus {
 
   //ImageService
   rpc GetUserImageList(GetUserImageListReq) returns (GetUserImageListResp);
-
   rpc CreateImage(CreateImageReq) returns (CreateImageResp);
-
   rpc DeleteImage(DeleteImageReq) returns (DeleteImageResp);
+  rpc UploadImage(UploadImageReq) returns (UploadImageResp);
+  rpc UploadImageConfirm(UploadImageConfirmReq) returns (UploadImageConfirmResp);