logic

package
v0.1.4 Latest Latest
Warning

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

 Go to latest Published: Jul 11, 2023 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func InitCron 

func InitCron(svc *svc.ServiceContext)

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 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 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 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 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 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.