logic

package
v0.0.0-...-549fefd Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 26, 2024 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ContentType               = "Content-Type"
	ApplicationFromUrlencoded = "application/x-www-from-urlencoded"
)
View Source 
const (
	EQUAL      = "="
	DCU        = "dcu"
	PYTORCH    = "Pytorch"
	TENSORFLOW = "Tensorflow"
)
View Source 
const (
	PYTORCH_TASK = "pytorch"
)
View Source 
const (
	TENSORFLOW_TASK = "tensorflow"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type CpuCoreLogic 

type CpuCoreLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewCpuCoreLogic 

func NewCpuCoreLogic(ctx context.Context, svcCtx *svc.ServiceContext) *CpuCoreLogic

func (*CpuCoreLogic) CpuCore 

func (l *CpuCoreLogic) CpuCore(in *hpcAC.CpuCoreReq) (*hpcAC.CpuCoreResp, error)

type DeleteJobLogic 

type DeleteJobLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewDeleteJobLogic 

func NewDeleteJobLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeleteJobLogic

func (*DeleteJobLogic) DeleteJob 

func (l *DeleteJobLogic) DeleteJob(in *hpcAC.DeleteJobReq) (*hpcAC.DeleteJobResp, error)

DeleteJob delete job

type DeleteTaskAiLogic 

type DeleteTaskAiLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewDeleteTaskAiLogic 

func NewDeleteTaskAiLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeleteTaskAiLogic

func (*DeleteTaskAiLogic) DeleteTaskAi 

func (l *DeleteTaskAiLogic) DeleteTaskAi(in *hpcAC.DeleteTaskAiReq) (*hpcAC.DeleteTaskAiResp, error)

type FileContentLogic 

type FileContentLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewFileContentLogic 

func NewFileContentLogic(ctx context.Context, svcCtx *svc.ServiceContext) *FileContentLogic

func (*FileContentLogic) FileContent 

func (l *FileContentLogic) FileContent(in *hpcAC.FileDataReq) (*hpcAC.FileContentResp, error)

FileContent 查看文件内容

type GetACClusterIdLogic 

type GetACClusterIdLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewGetACClusterIdLogic 

func NewGetACClusterIdLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetACClusterIdLogic

func (*GetACClusterIdLogic) GetACClusterId 

func (l *GetACClusterIdLogic) GetACClusterId(in *hpcAC.ACClusterReq) (*hpcAC.ClusterResp, error)

GetACClusterId 曙光ac获取clusterid

type GetACTokenLogic 

type GetACTokenLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewGetACTokenLogic 

func NewGetACTokenLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetACTokenLogic

func (*GetACTokenLogic) GetACToken 

func (l *GetACTokenLogic) GetACToken(in *hpcAC.ACTokenReq) (*hpcAC.TokenResp, error)

GetACToken 曙光ac获取token

type GetComputingPowerLogic 

type GetComputingPowerLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewGetComputingPowerLogic 

func NewGetComputingPowerLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetComputingPowerLogic

func (*GetComputingPowerLogic) GetComputingPower 

func (l *GetComputingPowerLogic) GetComputingPower(in *hpcAC.ResourceReq) (*hpcAC.CpResp, error)

获取曙光账号算力

type GetFileListLogic 

type GetFileListLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewGetFileListLogic 

func NewGetFileListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetFileListLogic

func (*GetFileListLogic) GetFileList 

func (l *GetFileListLogic) GetFileList(in *hpcAC.GetFileListReq) (*hpcAC.GetFileListResp, error)

曙光文件接口

type GetFileLogic 

type GetFileLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewGetFileLogic 

func NewGetFileLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetFileLogic

func (*GetFileLogic) GetFile 

func (l *GetFileLogic) GetFile(in *hpcAC.GetFileReq) (*hpcAC.GetFileResp, error)

type GetGeneralInfoLogic 

type GetGeneralInfoLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewGetGeneralInfoLogic 

func NewGetGeneralInfoLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetGeneralInfoLogic

func (*GetGeneralInfoLogic) GetGeneralInfo 

func (l *GetGeneralInfoLogic) GetGeneralInfo(in *hpcAC.ResourceReq) (*hpcAC.GiResp, error)

获取曙光账号cpu,内存，存储信息

type GetImageAiByIdLogic 

type GetImageAiByIdLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewGetImageAiByIdLogic 

func NewGetImageAiByIdLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetImageAiByIdLogic

func (*GetImageAiByIdLogic) GetImageAiById 

func (l *GetImageAiByIdLogic) GetImageAiById(in *hpcAC.GetImageAiByIdReq) (*hpcAC.GetImageAiByIdResp, error)

type GetImageListAiLogic 

type GetImageListAiLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewGetImageListAiLogic 

func NewGetImageListAiLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetImageListAiLogic

func (*GetImageListAiLogic) GetImageListAi 

func (l *GetImageListAiLogic) GetImageListAi(in *hpcAC.GetImageListAiReq) (*hpcAC.GetImageListAiResp, error)

type GetInstanceLogLogic 

type GetInstanceLogLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewGetInstanceLogLogic 

func NewGetInstanceLogLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetInstanceLogLogic

func (*GetInstanceLogLogic) GetInstanceLog 

func (l *GetInstanceLogLogic) GetInstanceLog(in *hpcAC.GetInstanceLogReq) (*hpcAC.GetInstanceLogResp, error)

type GetJobDetailLogic 

type GetJobDetailLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewGetJobDetailLogic 

func NewGetJobDetailLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetJobDetailLogic

func (*GetJobDetailLogic) GetJobDetail 

func (l *GetJobDetailLogic) GetJobDetail(in *hpcAC.JobDetailReq) (*hpcAC.GetJobDetailResp, error)

GetJobDetail get job detail

type GetMemberJobsLogic 

type GetMemberJobsLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewGetMemberJobsLogic 

func NewGetMemberJobsLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetMemberJobsLogic

func (*GetMemberJobsLogic) GetMemberJobs 

func (l *GetMemberJobsLogic) GetMemberJobs(in *hpcAC.GetMemberJobsReq) (*hpcAC.GetMemberJobsResp, error)

type GetNodeResourcesLogic 

type GetNodeResourcesLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewGetNodeResourcesLogic 

func NewGetNodeResourcesLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetNodeResourcesLogic

func (*GetNodeResourcesLogic) GetNodeResources 

func (l *GetNodeResourcesLogic) GetNodeResources(in *hpcAC.GetNodeResourcesReq) (*hpcAC.GetNodeResourcesResp, error)

获取节点资源限额

type GetPytorchTaskLogic 

type GetPytorchTaskLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewGetPytorchTaskLogic 

func NewGetPytorchTaskLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetPytorchTaskLogic

func (*GetPytorchTaskLogic) GetPytorchTask 

func (l *GetPytorchTaskLogic) GetPytorchTask(in *hpcAC.GetPytorchTaskReq) (*hpcAC.GetPytorchTaskResp, error)

type GetResourceSpecLogic 

type GetResourceSpecLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewGetResourceSpecLogic 

func NewGetResourceSpecLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetResourceSpecLogic

func (*GetResourceSpecLogic) GetResourceSpec 

func (l *GetResourceSpecLogic) GetResourceSpec(in *hpcAC.GetResourceSpecReq) (*hpcAC.GetResourceSpecResp, error)

type GetTensorflowTaskLogic 

type GetTensorflowTaskLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewGetTensorflowTaskLogic 

func NewGetTensorflowTaskLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetTensorflowTaskLogic

func (*GetTensorflowTaskLogic) GetTensorflowTask 

func (l *GetTensorflowTaskLogic) GetTensorflowTask(in *hpcAC.GetTensorflowTaskReq) (*hpcAC.GetTensorflowTaskResp, error)

type GetUserInfoLogic 

type GetUserInfoLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewGetUserInfoLogic 

func NewGetUserInfoLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetUserInfoLogic

func (*GetUserInfoLogic) GetUserInfo 

func (l *GetUserInfoLogic) GetUserInfo(in *hpcAC.GetUserInfoReq) (*hpcAC.GetUserInfoResp, error)

用户资源

type HistoryJobDetailLogic 

type HistoryJobDetailLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewHistoryJobDetailLogic 

func NewHistoryJobDetailLogic(ctx context.Context, svcCtx *svc.ServiceContext) *HistoryJobDetailLogic

func (*HistoryJobDetailLogic) HistoryJobDetail 

func (l *HistoryJobDetailLogic) HistoryJobDetail(in *hpcAC.HistoryJobDetailReq) (*hpcAC.HistoryJobDetailResp, error)

type JobsLogic 

type JobsLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewJobsLogic 

func NewJobsLogic(ctx context.Context, svcCtx *svc.ServiceContext) *JobsLogic

func (*JobsLogic) Jobs 

func (l *JobsLogic) Jobs(in *hpcAC.JobsReq) (*hpcAC.JobsResp, error)

type ListHistoryJobLogic 

type ListHistoryJobLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewListHistoryJobLogic 

func NewListHistoryJobLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ListHistoryJobLogic

func (*ListHistoryJobLogic) ListHistoryJob 

func (l *ListHistoryJobLogic) ListHistoryJob(in *hpcAC.ListHistoryJobReq) (*hpcAC.ListHistoryJobResp, error)

ListHistoryJob list all history jobs

type ListJobLogic 

type ListJobLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewListJobLogic 

func NewListJobLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ListJobLogic

func (*ListJobLogic) ListJob 

func (l *ListJobLogic) ListJob(in *hpcAC.ListJobReq) (*hpcAC.ListJobResp, error)

ListJob list all jobs

type ListJobManagerLogic 

type ListJobManagerLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewListJobManagerLogic 

func NewListJobManagerLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ListJobManagerLogic

func (*ListJobManagerLogic) ListJobManager 

func (l *ListJobManagerLogic) ListJobManager(in *hpcAC.JobManagerReq) (*hpcAC.ListJobManagerResp, error)

ListJobManager list all job managers

type ParaStorQuotaLogic 

type ParaStorQuotaLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewParaStorQuotaLogic 

func NewParaStorQuotaLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ParaStorQuotaLogic

func (*ParaStorQuotaLogic) ParaStorQuota 

func (l *ParaStorQuotaLogic) ParaStorQuota(in *hpcAC.ParaStorQuotaReq) (*hpcAC.ParaStorQuotaResp, error)

ParaStor Quota

type QueryQueueDetailsLogic 

type QueryQueueDetailsLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewQueryQueueDetailsLogic 

func NewQueryQueueDetailsLogic(ctx context.Context, svcCtx *svc.ServiceContext) *QueryQueueDetailsLogic

func (*QueryQueueDetailsLogic) QueryQueueDetails 

func (l *QueryQueueDetailsLogic) QueryQueueDetails(in *hpcAC.QueueReq) (*hpcAC.QueueDetailsResp, error)

QueryQueueDetails 查询队列资源详细信息

type QueryUserQuotasLimitLogic 

type QueryUserQuotasLimitLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewQueryUserQuotasLimitLogic 

func NewQueryUserQuotasLimitLogic(ctx context.Context, svcCtx *svc.ServiceContext) *QueryUserQuotasLimitLogic

func (*QueryUserQuotasLimitLogic) QueryUserQuotasLimit 

func (l *QueryUserQuotasLimitLogic) QueryUserQuotasLimit(in *hpcAC.QueueReq) (*hpcAC.UserQuotasLimitResp, error)

QueryUserQuotasLimit 查询用户资源限制信息

type QueueJobsLogic 

type QueueJobsLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewQueueJobsLogic 

func NewQueueJobsLogic(ctx context.Context, svcCtx *svc.ServiceContext) *QueueJobsLogic

func (*QueueJobsLogic) QueueJobs 

func (l *QueueJobsLogic) QueueJobs(in *hpcAC.QueueJobsReq) (*hpcAC.QueueJobsResp, error)

QueueJobs

type SelectQueueByUserLogic 

type SelectQueueByUserLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewSelectQueueByUserLogic 

func NewSelectQueueByUserLogic(ctx context.Context, svcCtx *svc.ServiceContext) *SelectQueueByUserLogic

func (*SelectQueueByUserLogic) SelectQueueByUser 

func (l *SelectQueueByUserLogic) SelectQueueByUser(in *hpcAC.QueueReq) (*hpcAC.QueueResp, error)

SelectQueueByUser 查询用户可访问队列列表

type SubmitJobLogic 

type SubmitJobLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewSubmitJobLogic 

func NewSubmitJobLogic(ctx context.Context, svcCtx *svc.ServiceContext) *SubmitJobLogic

func (*SubmitJobLogic) SubmitJob 

func (l *SubmitJobLogic) SubmitJob(in *hpcAC.SubmitJobReq) (*hpcAC.SubmitJobResp, error)

type SubmitPytorchTaskLogic 

type SubmitPytorchTaskLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewSubmitPytorchTaskLogic 

func NewSubmitPytorchTaskLogic(ctx context.Context, svcCtx *svc.ServiceContext) *SubmitPytorchTaskLogic

func (*SubmitPytorchTaskLogic) SubmitPytorchTask 

func (l *SubmitPytorchTaskLogic) SubmitPytorchTask(in *hpcAC.SubmitPytorchTaskReq) (*hpcAC.SubmitTaskAiResp, error)

曙光智算接口

type SubmitTensorflowTaskLogic 

type SubmitTensorflowTaskLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewSubmitTensorflowTaskLogic 

func NewSubmitTensorflowTaskLogic(ctx context.Context, svcCtx *svc.ServiceContext) *SubmitTensorflowTaskLogic

func (*SubmitTensorflowTaskLogic) SubmitTensorflowTask 

func (l *SubmitTensorflowTaskLogic) SubmitTensorflowTask(in *hpcAC.SubmitTensorflowTaskReq) (*hpcAC.SubmitTaskAiResp, error)

type UploadFileLogic 

type UploadFileLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewUploadFileLogic 

func NewUploadFileLogic(ctx context.Context, svcCtx *svc.ServiceContext) *UploadFileLogic

func (*UploadFileLogic) UploadFile 

func (l *UploadFileLogic) UploadFile(in *hpcAC.UploadFileReq) (*hpcAC.UploadFileResp, error)

type WallTimeLogic 

type WallTimeLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewWallTimeLogic 

func NewWallTimeLogic(ctx context.Context, svcCtx *svc.ServiceContext) *WallTimeLogic

func (*WallTimeLogic) WallTime 

func (l *WallTimeLogic) WallTime(in *hpcAC.WallTimeReq) (*hpcAC.WallTimeResp, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.