added getdeployinstance api

This commit is contained in:
tzwang 2025-03-26 15:54:06 +08:00
parent 1969076fb6
commit 087f426b30
6 changed files with 89 additions and 0 deletions

View File

@ -127,6 +127,18 @@ type (
}
/******************Deploy instance*************************/
GetDeployInstanceReq{
AdapterId string `form:"adapterId"`
ClusterId string `form:"clusterId"`
Id string `form:"id"`
InstanceId string `form:"instanceId"`
}
GetDeployInstanceResp {
Instance interface{} `json:"instance"`
}
DeployInstanceListReq{
PageInfo
}

View File

@ -960,6 +960,9 @@ service pcm {
group: inference
)
service pcm {
@handler GetDeployInstanceHandler
get /inference/getDeployInstance (GetDeployInstanceReq) returns (GetDeployInstanceResp)
@handler CreateInferenceTaskHandler
post /inference/createTask (CreateInferenceTaskReq) returns (CreateInferenceTaskResp)

View File

@ -0,0 +1,28 @@
package inference
import (
"net/http"
"github.com/zeromicro/go-zero/rest/httpx"
"gitlink.org.cn/JointCloud/pcm-coordinator/internal/logic/inference"
"gitlink.org.cn/JointCloud/pcm-coordinator/internal/svc"
"gitlink.org.cn/JointCloud/pcm-coordinator/internal/types"
)
func GetDeployInstanceHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
return func(w http.ResponseWriter, r *http.Request) {
var req types.GetDeployInstanceReq
if err := httpx.Parse(r, &req); err != nil {
httpx.ErrorCtx(r.Context(), w, err)
return
}
l := inference.NewGetDeployInstanceLogic(r.Context(), svcCtx)
resp, err := l.GetDeployInstance(&req)
if err != nil {
httpx.ErrorCtx(r.Context(), w, err)
} else {
httpx.OkJsonCtx(r.Context(), w, resp)
}
}
}

View File

@ -1208,6 +1208,11 @@ func RegisterHandlers(server *rest.Server, serverCtx *svc.ServiceContext) {
server.AddRoutes(
[]rest.Route{
{
Method: http.MethodGet,
Path: "/inference/getDeployInstance",
Handler: inference.GetDeployInstanceHandler(serverCtx),
},
{
Method: http.MethodPost,
Path: "/inference/createTask",

View File

@ -0,0 +1,30 @@
package inference
import (
"context"
"gitlink.org.cn/JointCloud/pcm-coordinator/internal/svc"
"gitlink.org.cn/JointCloud/pcm-coordinator/internal/types"
"github.com/zeromicro/go-zero/core/logx"
)
type GetDeployInstanceLogic struct {
logx.Logger
ctx context.Context
svcCtx *svc.ServiceContext
}
func NewGetDeployInstanceLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetDeployInstanceLogic {
return &GetDeployInstanceLogic{
Logger: logx.WithContext(ctx),
ctx: ctx,
svcCtx: svcCtx,
}
}
func (l *GetDeployInstanceLogic) GetDeployInstance(req *types.GetDeployInstanceReq) (resp *types.GetDeployInstanceResp, err error) {
// todo: add your logic here and delete this line
return
}

View File

@ -6250,6 +6250,17 @@ type TextToImageInferenceResp struct {
Result []byte `json:"result"`
}
type GetDeployInstanceReq struct {
AdapterId string `form:"adapterId"`
ClusterId string `form:"clusterId"`
Id string `form:"id"`
InstanceId string `form:"instanceId"`
}
type GetDeployInstanceResp struct {
Instance interface{} `json:"instance"`
}
type DeployInstanceListReq struct {
PageInfo
}