pcm-coordinator/api/internal/scheduler/service/impl/modelarts.go

package impl

import (
	"gitlink.org.cn/jcce-pcm/pcm-coordinator/api/internal/scheduler/service/collector"
	"gitlink.org.cn/jcce-pcm/pcm-coordinator/api/internal/scheduler/service/executor"
	"gitlink.org.cn/jcce-pcm/pcm-participant-modelarts/client/imagesservice"
	"gitlink.org.cn/jcce-pcm/pcm-participant-modelarts/client/modelartsservice"
)

type ModelArtsExecutor struct {
	Name            string
	pageIndex       int32
	pageSize        int32
	ModelArtsRpc    modelartsservice.ModelArtsService
	ModelArtsImgRpc imagesservice.ImagesService
}

func NewModelartsExecutor(modelArtsRpc modelartsservice.ModelArtsService, modelArtsImgRpc imagesservice.ImagesService, name string) *ModelArtsExecutor {
	return &ModelArtsExecutor{Name: name, ModelArtsRpc: modelArtsRpc, ModelArtsImgRpc: modelArtsImgRpc, pageIndex: 1, pageSize: 100}
}

func (m ModelArtsExecutor) QueryImageList() ([]executor.Image, error) {
	//TODO implement me
	panic("implement me")
}

func (m ModelArtsExecutor) SubmitTask(imageId string, cmd string, envs []string, params []string, resourceId string) (executor.Task, error) {
	//TODO implement me
	panic("implement me")
}

func (m ModelArtsExecutor) QueryTask(taskId string) (executor.Task, error) {
	//TODO implement me
	panic("implement me")
}

func (m ModelArtsExecutor) QuerySpecs() (executor.Spec, error) {
	//TODO implement me
	panic("implement me")
}

func (a *ModelArtsExecutor) GetResourceSpecs() (*collector.ResourceSpecs, error) {
	return nil, nil
}