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

fix:在PCM-core中增加api-core

This commit is contained in:
qiwang 2023-03-27 14:38:43 +08:00
parent 0e582951ee
commit c218420cf0
7 changed files with 3242 additions and 55 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
adaptor/PCM-AI/PCM-AI-CORE/api/internal/types/types.go
View File

@ -22,7 +22,7 @@ type DataSetReq struct {
type DataSetResp struct {
TotalNumber uint32 `json:"total_number" copier:"TotalNumber"`
DataSets []DataSets `json:"data_sets" copier:"DataSets"`
Datasets []DataSets `json:"data_sets" copier:"Datasets"`
}
type CreateDataSetReq struct {

14
adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts/pcm-modelarts.pb.go
View File

@ -568,7 +568,7 @@ type DataSetResp struct {
unknownFields protoimpl.UnknownFields
TotalNumber uint32 `protobuf:"varint,1,opt,name=total_number,json=totalNumber,proto3" json:"total_number,omitempty"` // @gotags: copier:"TotalNumber"
DataSets []*DataSets `protobuf:"bytes,2,rep,name=dataSets,proto3" json:"dataSets,omitempty"` // @gotags: copier:"DataSets"
Datasets []*DataSets `protobuf:"bytes,2,rep,name=datasets,proto3" json:"datasets,omitempty"` // @gotags: copier:"Datasets"
}
func (x *DataSetResp) Reset() {
@ -610,9 +610,9 @@ func (x *DataSetResp) GetTotalNumber() uint32 {
return 0
}
func (x *DataSetResp) GetDataSets() []*DataSets {
func (x *DataSetResp) GetDatasets() []*DataSets {
if x != nil {
return x.DataSets
return x.Datasets
}
return nil
}
@ -10149,7 +10149,7 @@ type SearchLabel struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // @gotags: copier:"Name"
Op string `protobuf:"bytes,2,opt,name=op,proto3" json:"op,omitempty"` // @gotags: copier:"Op"
// map<string,weigou> property = 3; // @gotags: copier:"Property"
// map<string,weigou> property = 3; // @gotags: copier:"Property"
Type int64 `protobuf:"varint,4,opt,name=type,proto3" json:"type,omitempty"` // @gotags: copier:"Type"
}
@ -19575,9 +19575,9 @@ var file_pcm_modelarts_proto_rawDesc = []byte{
0x74, 0x52, 0x65, 0x73, 0x70, 0x12, 0x21, 0x0a, 0x0c, 0x74, 0x6f, 0x74, 0x61, 0x6c, 0x5f, 0x6e,
0x75, 0x6d, 0x62, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0b, 0x74, 0x6f, 0x74,
0x61, 0x6c, 0x4e, 0x75, 0x6d, 0x62, 0x65, 0x72, 0x12, 0x2f, 0x0a, 0x08, 0x64, 0x61, 0x74, 0x61,
0x53, 0x65, 0x74, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x13, 0x2e, 0x6d, 0x6f, 0x64,
0x73, 0x65, 0x74, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x13, 0x2e, 0x6d, 0x6f, 0x64,
0x65, 0x6c, 0x61, 0x72, 0x74, 0x73, 0x2e, 0x44, 0x61, 0x74, 0x61, 0x53, 0x65, 0x74, 0x73, 0x52,
0x08, 0x64, 0x61, 0x74, 0x61, 0x53, 0x65, 0x74, 0x73, 0x22, 0x93, 0x02, 0x0a, 0x08, 0x44, 0x61,
0x08, 0x64, 0x61, 0x74, 0x61, 0x73, 0x65, 0x74, 0x73, 0x22, 0x93, 0x02, 0x0a, 0x08, 0x44, 0x61,
0x74, 0x61, 0x53, 0x65, 0x74, 0x73, 0x12, 0x1d, 0x0a, 0x0a, 0x64, 0x61, 0x74, 0x61, 0x73, 0x65,
0x74, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x64, 0x61, 0x74, 0x61,
0x73, 0x65, 0x74, 0x49, 0x64, 0x12, 0x1f, 0x0a, 0x0b, 0x64, 0x61, 0x74, 0x61, 0x5f, 0x66, 0x6f,
@ -23031,7 +23031,7 @@ var file_pcm_modelarts_proto_depIdxs = []int32{
6, // 5: modelarts.password.user:type_name -> modelarts.user
7, // 6: modelarts.user.domain:type_name -> modelarts.domain
0, // 7: modelarts.TokenReq.auth:type_name -> modelarts.auth
12, // 8: modelarts.DataSetResp.dataSets:type_name -> modelarts.DataSets
12, // 8: modelarts.DataSetResp.datasets:type_name -> modelarts.DataSets
13, // 9: modelarts.DataSets.data_sources:type_name -> modelarts.DataSources
15, // 10: modelarts.ImportTaskDataResp.resp200:type_name -> modelarts.ImportTaskDataResp200
16, // 11: modelarts.ImportTaskDataResp.resp400:type_name -> modelarts.ImportTaskDataResp400

84
adaptor/PCM-AI/PCM-MODELARTS/rpc/modelarts/pcm-modelarts_grpc.pb.go
View File

@ -22,64 +22,64 @@ const _ = grpc.SupportPackageIsVersion7
//
// 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 ModelArtsClient interface {
// get modelarts Token
//get modelarts Token
GetToken(ctx context.Context, in *TokenReq, opts ...grpc.CallOption) (*TokenResp, error)
// get modelarts Token
//get modelarts Token
GetDatasetList(ctx context.Context, in *DataSetReq, opts ...grpc.CallOption) (*DataSetResp, error)
// create DateSet
//create DateSet
CreateDataSet(ctx context.Context, in *CreateDataSetReq, opts ...grpc.CallOption) (*CreateDataSetResq, error)
// create DateSet
//create DateSet
DeleteDataSet(ctx context.Context, in *DeleteDataSetReq, opts ...grpc.CallOption) (*DeleteDataSetResq, error)
// creat task 创建导入任务
//creat task 创建导入任务
CreateTask(ctx context.Context, in *ImportTaskDataReq, opts ...grpc.CallOption) (*ImportTaskDataResp, error)
// get taskList 查询数据集导入任务列表
//get taskList 查询数据集导入任务列表
GetImportTaskList(ctx context.Context, in *ListImportTasksReq, opts ...grpc.CallOption) (*ListImportTasksResp, error)
// ListTrainingJobs 查询训练作业列表
// ListTrainingJobs 查询训练作业列表
GetListTrainingJobs(ctx context.Context, in *ListTrainingJobsreq, opts ...grpc.CallOption) (*ListTrainingJobsresp, error)
// CreateTrainingJob 创建训练作业
// CreateTrainingJob 创建训练作业
CreateTrainingJob(ctx context.Context, in *CreateTrainingJobReq, opts ...grpc.CallOption) (*CreateTrainingJobResp, error)
// DeleteTrainingJobConfig 删除训练作业
// DeleteTrainingJobConfig 删除训练作业
DeleteTrainingJob(ctx context.Context, in *DeleteTrainingJobReq, opts ...grpc.CallOption) (*DeleteTrainingJobResp, error)
// CreateTrainingJobConfig 创建训练作业参数
// CreateTrainingJobConfig 创建训练作业参数
CreateTrainingJobConfig(ctx context.Context, in *CreateTrainingJobConfigReq, opts ...grpc.CallOption) (*CreateTrainingJobConfigResp, error)
// DeleteTrainingJobConfig 删除训练作业参数
// DeleteTrainingJobConfig 删除训练作业参数
DeleteTrainingJobConfig(ctx context.Context, in *DeleteTrainingJobConfigReq, opts ...grpc.CallOption) (*DeleteTrainingJobConfigResp, error)
// ListTrainingJobConfig 查询训练作业参数
// ListTrainingJobConfig 查询训练作业参数
ListTrainingJobConfig(ctx context.Context, in *ListTrainingJobConfigReq, opts ...grpc.CallOption) (*ListTrainingJobConfigResp, error)
// CreateAlgorithm 创建算法
// CreateAlgorithm 创建算法
CreateAlgorithm(ctx context.Context, in *CreateAlgorithmReq, opts ...grpc.CallOption) (*CreateAlgorithmResp, error)
// ListAlgorithms 查询算法
// ListAlgorithms 查询算法
ListAlgorithms(ctx context.Context, in *ListAlgorithmsReq, opts ...grpc.CallOption) (*ListAlgorithmsResp, error)
// DeleteAlgorithms 删除算法
// DeleteAlgorithms 删除算法
DeleteAlgorithms(ctx context.Context, in *DeleteAlgorithmsReq, opts ...grpc.CallOption) (*DeleteAlgorithmsResp, error)
// ShowAlgorithmByUuid 展示算法详情
// ShowAlgorithmByUuid 展示算法详情
ShowAlgorithmByUuid(ctx context.Context, in *ShowAlgorithmByUuidReq, opts ...grpc.CallOption) (*ShowAlgorithmByUuidResp, error)
//export task
ExportTask(ctx context.Context, in *ExportTaskReq, opts ...grpc.CallOption) (*ExportTaskResp, error)
GetExportTasksOfDataset(ctx context.Context, in *GetExportTasksOfDatasetReq, opts ...grpc.CallOption) (*GetExportTasksOfDatasetResp, error)
GetExportTaskStatusOfDataset(ctx context.Context, in *GetExportTaskStatusOfDatasetReq, opts ...grpc.CallOption) (*GetExportTaskStatusOfDatasetResp, error)
// processor task
//processor task
CreateProcessorTask(ctx context.Context, in *CreateProcessorTaskReq, opts ...grpc.CallOption) (*CreateProcessorTaskResp, error)
DescribeProcessorTask(ctx context.Context, in *DescribeProcessorTaskReq, opts ...grpc.CallOption) (*DescribeProcessorTaskResp, error)
// model management
//model management
CreateModel(ctx context.Context, in *CreateModelReq, opts ...grpc.CallOption) (*CreateModelResp, error)
DeleteModel(ctx context.Context, in *DeleteModelReq, opts ...grpc.CallOption) (*DeleteModelResp, error)
ListModels(ctx context.Context, in *ListModelReq, opts ...grpc.CallOption) (*ListModelResp, error)
ShowModels(ctx context.Context, in *ShowModelReq, opts ...grpc.CallOption) (*ShowModelResp, error)
// service management
//service management
CreateService(ctx context.Context, in *CreateServiceReq, opts ...grpc.CallOption) (*CreateServiceResp, error)
ListServices(ctx context.Context, in *ListServicesReq, opts ...grpc.CallOption) (*ListServicesResp, error)
ShowService(ctx context.Context, in *ShowServiceReq, opts ...grpc.CallOption) (*ShowServiceResp, error)
DeleteService(ctx context.Context, in *DeleteServiceReq, opts ...grpc.CallOption) (*DeleteServiceResp, error)
ListClusters(ctx context.Context, in *ListClustersReq, opts ...grpc.CallOption) (*ListClustersResp, error)
// notebook task
//notebook task
ListNotebook(ctx context.Context, in *ListNotebookReq, opts ...grpc.CallOption) (*ListNotebookResp, error)
CreateNotebook(ctx context.Context, in *CreateNotebookReq, opts ...grpc.CallOption) (*CreateNotebookResp, error)
StartNotebook(ctx context.Context, in *StartNotebookReq, opts ...grpc.CallOption) (*StartNotebookResp, error)
StopNotebook(ctx context.Context, in *StopNotebookReq, opts ...grpc.CallOption) (*StopNotebookResp, error)
GetNotebookStorage(ctx context.Context, in *GetNotebookStorageReq, opts ...grpc.CallOption) (*GetNotebookStorageResp, error)
MountNotebookStorage(ctx context.Context, in *MountNotebookStorageReq, opts ...grpc.CallOption) (*MountNotebookStorageResp, error)
// visualization-jobs
//visualization-jobs
GetVisualizationJob(ctx context.Context, in *GetVisualizationJobReq, opts ...grpc.CallOption) (*GetVisualizationJobResp, error)
CreateVisualizationJob(ctx context.Context, in *CreateVisualizationJobReq, opts ...grpc.CallOption) (*CreateVisualizationJobResp, error)
}
@ -438,64 +438,64 @@ func (c *modelArtsClient) CreateVisualizationJob(ctx context.Context, in *Create
// All implementations must embed UnimplementedModelArtsServer
// for forward compatibility
type ModelArtsServer interface {
// get modelarts Token
//get modelarts Token
GetToken(context.Context, *TokenReq) (*TokenResp, error)
// get modelarts Token
//get modelarts Token
GetDatasetList(context.Context, *DataSetReq) (*DataSetResp, error)
// create DateSet
//create DateSet
CreateDataSet(context.Context, *CreateDataSetReq) (*CreateDataSetResq, error)
// create DateSet
//create DateSet
DeleteDataSet(context.Context, *DeleteDataSetReq) (*DeleteDataSetResq, error)
// creat task 创建导入任务
//creat task 创建导入任务
CreateTask(context.Context, *ImportTaskDataReq) (*ImportTaskDataResp, error)
// get taskList 查询数据集导入任务列表
//get taskList 查询数据集导入任务列表
GetImportTaskList(context.Context, *ListImportTasksReq) (*ListImportTasksResp, error)
// ListTrainingJobs 查询训练作业列表
// ListTrainingJobs 查询训练作业列表
GetListTrainingJobs(context.Context, *ListTrainingJobsreq) (*ListTrainingJobsresp, error)
// CreateTrainingJob 创建训练作业
// CreateTrainingJob 创建训练作业
CreateTrainingJob(context.Context, *CreateTrainingJobReq) (*CreateTrainingJobResp, error)
// DeleteTrainingJobConfig 删除训练作业
// DeleteTrainingJobConfig 删除训练作业
DeleteTrainingJob(context.Context, *DeleteTrainingJobReq) (*DeleteTrainingJobResp, error)
// CreateTrainingJobConfig 创建训练作业参数
// CreateTrainingJobConfig 创建训练作业参数
CreateTrainingJobConfig(context.Context, *CreateTrainingJobConfigReq) (*CreateTrainingJobConfigResp, error)
// DeleteTrainingJobConfig 删除训练作业参数
// DeleteTrainingJobConfig 删除训练作业参数
DeleteTrainingJobConfig(context.Context, *DeleteTrainingJobConfigReq) (*DeleteTrainingJobConfigResp, error)
// ListTrainingJobConfig 查询训练作业参数
// ListTrainingJobConfig 查询训练作业参数
ListTrainingJobConfig(context.Context, *ListTrainingJobConfigReq) (*ListTrainingJobConfigResp, error)
// CreateAlgorithm 创建算法
// CreateAlgorithm 创建算法
CreateAlgorithm(context.Context, *CreateAlgorithmReq) (*CreateAlgorithmResp, error)
// ListAlgorithms 查询算法
// ListAlgorithms 查询算法
ListAlgorithms(context.Context, *ListAlgorithmsReq) (*ListAlgorithmsResp, error)
// DeleteAlgorithms 删除算法
// DeleteAlgorithms 删除算法
DeleteAlgorithms(context.Context, *DeleteAlgorithmsReq) (*DeleteAlgorithmsResp, error)
// ShowAlgorithmByUuid 展示算法详情
// ShowAlgorithmByUuid 展示算法详情
ShowAlgorithmByUuid(context.Context, *ShowAlgorithmByUuidReq) (*ShowAlgorithmByUuidResp, error)
//export task
ExportTask(context.Context, *ExportTaskReq) (*ExportTaskResp, error)
GetExportTasksOfDataset(context.Context, *GetExportTasksOfDatasetReq) (*GetExportTasksOfDatasetResp, error)
GetExportTaskStatusOfDataset(context.Context, *GetExportTaskStatusOfDatasetReq) (*GetExportTaskStatusOfDatasetResp, error)
// processor task
//processor task
CreateProcessorTask(context.Context, *CreateProcessorTaskReq) (*CreateProcessorTaskResp, error)
DescribeProcessorTask(context.Context, *DescribeProcessorTaskReq) (*DescribeProcessorTaskResp, error)
// model management
//model management
CreateModel(context.Context, *CreateModelReq) (*CreateModelResp, error)
DeleteModel(context.Context, *DeleteModelReq) (*DeleteModelResp, error)
ListModels(context.Context, *ListModelReq) (*ListModelResp, error)
ShowModels(context.Context, *ShowModelReq) (*ShowModelResp, error)
// service management
//service management
CreateService(context.Context, *CreateServiceReq) (*CreateServiceResp, error)
ListServices(context.Context, *ListServicesReq) (*ListServicesResp, error)
ShowService(context.Context, *ShowServiceReq) (*ShowServiceResp, error)
DeleteService(context.Context, *DeleteServiceReq) (*DeleteServiceResp, error)
ListClusters(context.Context, *ListClustersReq) (*ListClustersResp, error)
// notebook task
//notebook task
ListNotebook(context.Context, *ListNotebookReq) (*ListNotebookResp, error)
CreateNotebook(context.Context, *CreateNotebookReq) (*CreateNotebookResp, error)
StartNotebook(context.Context, *StartNotebookReq) (*StartNotebookResp, error)
StopNotebook(context.Context, *StopNotebookReq) (*StopNotebookResp, error)
GetNotebookStorage(context.Context, *GetNotebookStorageReq) (*GetNotebookStorageResp, error)
MountNotebookStorage(context.Context, *MountNotebookStorageReq) (*MountNotebookStorageResp, error)
// visualization-jobs
//visualization-jobs
GetVisualizationJob(context.Context, *GetVisualizationJobReq) (*GetVisualizationJobResp, error)
CreateVisualizationJob(context.Context, *CreateVisualizationJobReq) (*CreateVisualizationJobResp, error)
mustEmbedUnimplementedModelArtsServer()

1510
adaptor/PCM-CORE/api/desc/ai/pcm-ai.api
View File

File diff suppressed because it is too large Load Diff

94
adaptor/PCM-CORE/api/desc/pcm.api
View File

@ -3,6 +3,7 @@ syntax = "v1"
import (
"core/pcm-core.api"
"hpc/pcm-hpc.api"
"ai/pcm-ai.api"
)
info(
@ -49,4 +50,97 @@ service pcm {
@handler listHistoryJobHandler
get /hpc/listHistoryJob (listHistoryJobReq) returns (listHistoryJobResp)
}
//hpc二级接口
@server(
prefix: pcm/v1
group : ai
)
service pcm {
@handler listDataSetHandler
get /ai/listDataSet (DataSetReq) returns (DataSetResp)
@handler CreateDataSetHandler
post /ai/createDataSet (CreateDataSetReq) returns (CreateDataSetResp)
@handler DeleteDataSetHandler
delete /ai/deleteDataSet (DeleteDataSetReq) returns (DeleteDataSetResp)
// creat task 创建导入任务
@handler CreateTaskHandler
post /ai/CreateTask (ImportTaskDataReq) returns (ImportTaskDataResp)
// get taskList 查询数据集导入任务列表
@handler ListImportHandler
get /ai/ListImport (ListImportTasksReq) returns (ListImportTasksResp)
// ListTrainingJobs 查询训练作业列表
@handler GetListTrainingJobsHandler
get /ai/GetListTrainingJobs (ListTrainingJobsreq) returns (ListTrainingJobsresp)
// DeleteTrainingJob 删除训练作业
@handler DeleteTrainingJobHandler
delete /ai/DeleteTrainingJob (DeleteTrainingJobReq) returns (DeleteTrainingJobResp)
// CreateAlgorithm 创建算法
@handler CreateAlgorithmHandler
post /ai/CreateAlgorithm (CreateAlgorithmReq) returns (CreateAlgorithmResp)
// ListAlgorithms 查询创建算法列表
@handler ListAlgorithms
get /ai/ListAlgorithms (ListAlgorithmsReq) returns (ListAlgorithmsResp)
// DeleteAlgorithm 删除算法
@handler DeleteAlgorithm
delete /ai/DeleteAlgorithm (DeleteAlgorithmReq) returns (DeleteAlgorithmResp)
// CreateTrainingJob 创建训练作业
@handler CreateTrainingJobHandler
post /ai/CreateTrainingJob (CreateTrainingJobReq) returns (CreateTrainingJobResp)
// ShowAlgorithmByUuid 展示算法详情
@handler ShowAlgorithmByUuid
get /ai/ShowAlgorithmByUuid (ShowAlgorithmByUuidReq) returns (ShowAlgorithmByUuidResp)
// creat export task 创建导出任务
@handler CreateExportTaskHandler
post /ai/CreateExportTask (CreateExportTaskReq) returns (CreateExportTaskResp)
@handler GetExportTasksOfDatasetHandler
get /ai/GetExportTasksOfDataset (GetExportTasksOfDatasetReq) returns (GetExportTasksOfDatasetResp)
@handler GetExportTaskStatusOfDatasetHandler
get /ai/GetExportTaskStatusOfDataset (GetExportTaskStatusOfDatasetReq) returns (GetExportTaskStatusOfDatasetResp)
// create processor task 创建处理任务
@handler CreateProcessorTaskHandler
post /ai/CreateProcessorTask (CreateProcessorTaskReq) returns (CreateProcessorTaskResp)
// create service 创建服务
@handler CreateServiceHandler
post /ai/CreateService (CreateServiceReq) returns (CreateServiceResp)
// list services 展示服务
@handler ListServicesHandler
get /ai/ListServices (ListServicesReq) returns (ListServicesResp)
// Show service 展示服务详情
@handler ShowServiceHandler
get /ai/ShowService (ShowServiceReq) returns (ShowServiceResp)
// Delete service 删除服务
@handler DeleteServiceHandler
delete /ai/DeleteService (DeleteServiceReq) returns (DeleteServiceResp)
// ListClusters查询专属资源池列表
@handler ListClustersHandler
get /ai/ListClusters (ListClustersReq) returns (ListClustersResp)
/******************Notebook Method start*************************/
@handler listNotebookHandler
get /ai/listNotebook (ListNotebookReq) returns (ListNotebookResp)
@handler createNotebookHandler
post /ai/createNotebook (CreateNotebookReq) returns (CreateNotebookResp)
@handler startNotebookHandler
post /ai/startNotebook (StartNotebookReq) returns (StartNotebookResp)
@handler stopNotebookHandler
post /ai/stopNotebook (StopNotebookReq) returns (StopNotebookResp)
@handler getNotebookStorageHandler
get /ai/getNotebookStorage (GetNotebookStorageReq) returns (GetNotebookStorageResp)
@handler mountNotebookStorageHandler
post /ai/mountNotebookStorage (MountNotebookStorageReq) returns (MountNotebookStorageResp)
/******************Notebook Method end*************************/
/******************Visualization Job Method start*************************/
@handler getVisualizationJobHandler
get /ai/getVisualizationJob (GetVisualizationJobReq) returns (GetVisualizationJobResp)
@handler createVisualizationJobHandler
post /ai/CreateVisualizationJob (CreateVisualizationJobReq) returns (CreateVisualizationJobResp)
/******************Visualization Job Method start*************************/
}

152
adaptor/PCM-CORE/api/internal/handler/routes.go
View File

@ -4,6 +4,7 @@ package handler
import (
"net/http"
ai "PCM/adaptor/PCM-CORE/api/internal/handler/ai"
core "PCM/adaptor/PCM-CORE/api/internal/handler/core"
hpc "PCM/adaptor/PCM-CORE/api/internal/handler/hpc"
"PCM/adaptor/PCM-CORE/api/internal/svc"
@ -63,4 +64,155 @@ func RegisterHandlers(server *rest.Server, serverCtx *svc.ServiceContext) {
},
rest.WithPrefix("/pcm/v1"),
)
server.AddRoutes(
[]rest.Route{
{
Method: http.MethodGet,
Path: "/ai/listDataSet",
Handler: ai.ListDataSetHandler(serverCtx),
},
{
Method: http.MethodPost,
Path: "/ai/createDataSet",
Handler: ai.CreateDataSetHandler(serverCtx),
},
{
Method: http.MethodDelete,
Path: "/ai/deleteDataSet",
Handler: ai.DeleteDataSetHandler(serverCtx),
},
{
Method: http.MethodPost,
Path: "/ai/CreateTask",
Handler: ai.CreateTaskHandler(serverCtx),
},
{
Method: http.MethodGet,
Path: "/ai/ListImport",
Handler: ai.ListImportHandler(serverCtx),
},
{
Method: http.MethodGet,
Path: "/ai/GetListTrainingJobs",
Handler: ai.GetListTrainingJobsHandler(serverCtx),
},
{
Method: http.MethodDelete,
Path: "/ai/DeleteTrainingJob",
Handler: ai.DeleteTrainingJobHandler(serverCtx),
},
{
Method: http.MethodPost,
Path: "/ai/CreateAlgorithm",
Handler: ai.CreateAlgorithmHandler(serverCtx),
},
{
Method: http.MethodGet,
Path: "/ai/ListAlgorithms",
Handler: ai.ListAlgorithmsHandler(serverCtx),
},
{
Method: http.MethodDelete,
Path: "/ai/DeleteAlgorithm",
Handler: ai.DeleteAlgorithmHandler(serverCtx),
},
{
Method: http.MethodPost,
Path: "/ai/CreateTrainingJob",
Handler: ai.CreateTrainingJobHandler(serverCtx),
},
{
Method: http.MethodGet,
Path: "/ai/ShowAlgorithmByUuid",
Handler: ai.ShowAlgorithmByUuidHandler(serverCtx),
},
{
Method: http.MethodPost,
Path: "/ai/CreateExportTask",
Handler: ai.CreateExportTaskHandler(serverCtx),
},
{
Method: http.MethodGet,
Path: "/ai/GetExportTasksOfDataset",
Handler: ai.GetExportTasksOfDatasetHandler(serverCtx),
},
{
Method: http.MethodGet,
Path: "/ai/GetExportTaskStatusOfDataset",
Handler: ai.GetExportTaskStatusOfDatasetHandler(serverCtx),
},
{
Method: http.MethodPost,
Path: "/ai/CreateProcessorTask",
Handler: ai.CreateProcessorTaskHandler(serverCtx),
},
{
Method: http.MethodPost,
Path: "/ai/CreateService",
Handler: ai.CreateServiceHandler(serverCtx),
},
{
Method: http.MethodGet,
Path: "/ai/ListServices",
Handler: ai.ListServicesHandler(serverCtx),
},
{
Method: http.MethodGet,
Path: "/ai/ShowService",
Handler: ai.ShowServiceHandler(serverCtx),
},
{
Method: http.MethodDelete,
Path: "/ai/DeleteService",
Handler: ai.DeleteServiceHandler(serverCtx),
},
{
Method: http.MethodGet,
Path: "/ai/ListClusters",
Handler: ai.ListClustersHandler(serverCtx),
},
{
Method: http.MethodGet,
Path: "/ai/listNotebook",
Handler: ai.ListNotebookHandler(serverCtx),
},
{
Method: http.MethodPost,
Path: "/ai/createNotebook",
Handler: ai.CreateNotebookHandler(serverCtx),
},
{
Method: http.MethodPost,
Path: "/ai/startNotebook",
Handler: ai.StartNotebookHandler(serverCtx),
},
{
Method: http.MethodPost,
Path: "/ai/stopNotebook",
Handler: ai.StopNotebookHandler(serverCtx),
},
{
Method: http.MethodGet,
Path: "/ai/getNotebookStorage",
Handler: ai.GetNotebookStorageHandler(serverCtx),
},
{
Method: http.MethodPost,
Path: "/ai/mountNotebookStorage",
Handler: ai.MountNotebookStorageHandler(serverCtx),
},
{
Method: http.MethodGet,
Path: "/ai/getVisualizationJob",
Handler: ai.GetVisualizationJobHandler(serverCtx),
},
{
Method: http.MethodPost,
Path: "/ai/CreateVisualizationJob",
Handler: ai.CreateVisualizationJobHandler(serverCtx),
},
},
rest.WithPrefix("/pcm/v1"),
)
}

1441
adaptor/PCM-CORE/api/internal/types/types.go
View File

File diff suppressed because it is too large Load Diff