logic

Documentation

Index

• func InitCron(svc *svc.ServiceContext)
• func JobCtoGo(cStruct *C.struct_job_info) hpcTH.Job
• func SlurmdbJobConvertCToGo(cStructJob *C.slurmdb_job_rec_t) hpcTH.HistoryJob
• type ListHistoryJobLogic
  • func NewListHistoryJobLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ListHistoryJobLogic
  • func (l *ListHistoryJobLogic) ListHistoryJob(in *hpcTH.ListHistoryJobReq) (*hpcTH.ListHistoryJobResp, error)
• type ListJobLogic
  • func NewListJobLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ListJobLogic
  • func (l *ListJobLogic) ListJob(in *hpcTH.ListJobReq) (*hpcTH.ListJobResp, error)
• type SubmitJobLogic
  • func NewSubmitJobLogic(ctx context.Context, svcCtx *svc.ServiceContext) *SubmitJobLogic
  • func (l *SubmitJobLogic) SubmitJob(in *hpcTH.SubmitJobReq) (*hpcTH.SubmitJobResp, error)

Functions

func InitCron

func InitCron(svc *svc.ServiceContext)

func JobCtoGo

func JobCtoGo(cStruct *C.struct_job_info) hpcTH.Job

func SlurmdbJobConvertCToGo

func SlurmdbJobConvertCToGo(cStructJob *C.slurmdb_job_rec_t) hpcTH.HistoryJob

Types

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 *hpcTH.ListHistoryJobReq) (*hpcTH.ListHistoryJobResp, error)

ListHistoryJob list all jobs from slurmdb

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 *hpcTH.ListJobReq) (*hpcTH.ListJobResp, error)

ListJob list all jobs

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 *hpcTH.SubmitJobReq) (*hpcTH.SubmitJobResp, error)

Submit job