forked from JointCloud/pcm-hpc
234 lines
8.2 KiB
Go
234 lines
8.2 KiB
Go
// Code generated by goctl. DO NOT EDIT.
|
|
// Source: slurm.proto
|
|
|
|
package server
|
|
|
|
import (
|
|
"context"
|
|
|
|
"gitlink.org.cn/jcce-pcm/pcm-slurm/internal/logic"
|
|
"gitlink.org.cn/jcce-pcm/pcm-slurm/internal/svc"
|
|
"gitlink.org.cn/jcce-pcm/pcm-slurm/slurm"
|
|
)
|
|
|
|
type SlurmServer struct {
|
|
svcCtx *svc.ServiceContext
|
|
slurm.UnimplementedSlurmServer
|
|
}
|
|
|
|
func NewSlurmServer(svcCtx *svc.ServiceContext) *SlurmServer {
|
|
return &SlurmServer{
|
|
svcCtx: svcCtx,
|
|
}
|
|
}
|
|
|
|
func (s *SlurmServer) SyncToken(ctx context.Context, in *slurm.SyncTokenReq) (*slurm.SyncTokenResp, error) {
|
|
l := logic.NewSyncTokenLogic(ctx, s.svcCtx)
|
|
return l.SyncToken(in)
|
|
}
|
|
|
|
func (s *SlurmServer) Ping(ctx context.Context, in *slurm.PingReq) (*slurm.PingResp, error) {
|
|
l := logic.NewPingLogic(ctx, s.svcCtx)
|
|
return l.Ping(in)
|
|
}
|
|
|
|
func (s *SlurmServer) ListJob(ctx context.Context, in *slurm.ListJobReq) (*slurm.ListJobResp, error) {
|
|
l := logic.NewListJobLogic(ctx, s.svcCtx)
|
|
return l.ListJob(in)
|
|
}
|
|
|
|
func (s *SlurmServer) GetJob(ctx context.Context, in *slurm.GetJobReq) (*slurm.GetJobResp, error) {
|
|
l := logic.NewGetJobLogic(ctx, s.svcCtx)
|
|
return l.GetJob(in)
|
|
}
|
|
|
|
func (s *SlurmServer) UpdateJob(ctx context.Context, in *slurm.UpdateJobReq) (*slurm.UpdateJobResp, error) {
|
|
l := logic.NewUpdateJobLogic(ctx, s.svcCtx)
|
|
return l.UpdateJob(in)
|
|
}
|
|
|
|
func (s *SlurmServer) CancelJob(ctx context.Context, in *slurm.CancelJobReq) (*slurm.CancelJobResp, error) {
|
|
l := logic.NewCancelJobLogic(ctx, s.svcCtx)
|
|
return l.CancelJob(in)
|
|
}
|
|
|
|
func (s *SlurmServer) SubmitJob(ctx context.Context, in *slurm.SubmitJobReq) (*slurm.SubmitJobResp, error) {
|
|
l := logic.NewSubmitJobLogic(ctx, s.svcCtx)
|
|
return l.SubmitJob(in)
|
|
}
|
|
|
|
func (s *SlurmServer) ListUser(ctx context.Context, in *slurm.ListUserReq) (*slurm.ListUserResp, error) {
|
|
l := logic.NewListUserLogic(ctx, s.svcCtx)
|
|
return l.ListUser(in)
|
|
}
|
|
|
|
func (s *SlurmServer) GetUser(ctx context.Context, in *slurm.GetUserReq) (*slurm.GetUserResp, error) {
|
|
l := logic.NewGetUserLogic(ctx, s.svcCtx)
|
|
return l.GetUser(in)
|
|
}
|
|
|
|
func (s *SlurmServer) UpdateUser(ctx context.Context, in *slurm.UpdateUserReq) (*slurm.UpdateUserResp, error) {
|
|
l := logic.NewUpdateUserLogic(ctx, s.svcCtx)
|
|
return l.UpdateUser(in)
|
|
}
|
|
|
|
func (s *SlurmServer) DeleteUser(ctx context.Context, in *slurm.DeleteUserReq) (*slurm.DeleteUserResp, error) {
|
|
l := logic.NewDeleteUserLogic(ctx, s.svcCtx)
|
|
return l.DeleteUser(in)
|
|
}
|
|
|
|
func (s *SlurmServer) ListPartition(ctx context.Context, in *slurm.ListPartitionReq) (*slurm.ListPartitionResp, error) {
|
|
l := logic.NewListPartitionLogic(ctx, s.svcCtx)
|
|
return l.ListPartition(in)
|
|
}
|
|
|
|
func (s *SlurmServer) GetPartition(ctx context.Context, in *slurm.GetPartitionReq) (*slurm.GetPartitionResp, error) {
|
|
l := logic.NewGetPartitionLogic(ctx, s.svcCtx)
|
|
return l.GetPartition(in)
|
|
}
|
|
|
|
func (s *SlurmServer) ListNode(ctx context.Context, in *slurm.ListNodeReq) (*slurm.ListNodeResp, error) {
|
|
l := logic.NewListNodeLogic(ctx, s.svcCtx)
|
|
return l.ListNode(in)
|
|
}
|
|
|
|
func (s *SlurmServer) GetNode(ctx context.Context, in *slurm.GetNodeReq) (*slurm.GetNodeResp, error) {
|
|
l := logic.NewGetNodeLogic(ctx, s.svcCtx)
|
|
return l.GetNode(in)
|
|
}
|
|
|
|
func (s *SlurmServer) ListReservation(ctx context.Context, in *slurm.ListReservationReq) (*slurm.ListReservationResp, error) {
|
|
l := logic.NewListReservationLogic(ctx, s.svcCtx)
|
|
return l.ListReservation(in)
|
|
}
|
|
|
|
func (s *SlurmServer) GetReservation(ctx context.Context, in *slurm.GetReservationReq) (*slurm.GetReservationResp, error) {
|
|
l := logic.NewGetReservationLogic(ctx, s.svcCtx)
|
|
return l.GetReservation(in)
|
|
}
|
|
|
|
func (s *SlurmServer) LoadConfiguration(ctx context.Context, in *slurm.LoadConfigurationReq) (*slurm.LoadConfigurationResp, error) {
|
|
l := logic.NewLoadConfigurationLogic(ctx, s.svcCtx)
|
|
return l.LoadConfiguration(in)
|
|
}
|
|
|
|
func (s *SlurmServer) DumpConfiguration(ctx context.Context, in *slurm.DumpConfigurationReq) (*slurm.DumpConfigurationResp, error) {
|
|
l := logic.NewDumpConfigurationLogic(ctx, s.svcCtx)
|
|
return l.DumpConfiguration(in)
|
|
}
|
|
|
|
func (s *SlurmServer) ListQos(ctx context.Context, in *slurm.ListQosReq) (*slurm.ListQosResp, error) {
|
|
l := logic.NewListQosLogic(ctx, s.svcCtx)
|
|
return l.ListQos(in)
|
|
}
|
|
|
|
func (s *SlurmServer) GetQos(ctx context.Context, in *slurm.GetQosReq) (*slurm.GetQosResp, error) {
|
|
l := logic.NewGetQosLogic(ctx, s.svcCtx)
|
|
return l.GetQos(in)
|
|
}
|
|
|
|
func (s *SlurmServer) DeleteQos(ctx context.Context, in *slurm.DeleteQosReq) (*slurm.DeleteQosResp, error) {
|
|
l := logic.NewDeleteQosLogic(ctx, s.svcCtx)
|
|
return l.DeleteQos(in)
|
|
}
|
|
|
|
func (s *SlurmServer) ListTres(ctx context.Context, in *slurm.ListTresReq) (*slurm.ListTresResp, error) {
|
|
l := logic.NewListTresLogic(ctx, s.svcCtx)
|
|
return l.ListTres(in)
|
|
}
|
|
|
|
func (s *SlurmServer) SetTres(ctx context.Context, in *slurm.SetTresReq) (*slurm.SetTresResp, error) {
|
|
l := logic.NewSetTresLogic(ctx, s.svcCtx)
|
|
return l.SetTres(in)
|
|
}
|
|
|
|
func (s *SlurmServer) ListAccount(ctx context.Context, in *slurm.ListAccountReq) (*slurm.ListAccountResp, error) {
|
|
l := logic.NewListAccountLogic(ctx, s.svcCtx)
|
|
return l.ListAccount(in)
|
|
}
|
|
|
|
func (s *SlurmServer) GetAccount(ctx context.Context, in *slurm.GetAccountReq) (*slurm.GetAccountResp, error) {
|
|
l := logic.NewGetAccountLogic(ctx, s.svcCtx)
|
|
return l.GetAccount(in)
|
|
}
|
|
|
|
func (s *SlurmServer) UpdateAccount(ctx context.Context, in *slurm.UpdateAccountReq) (*slurm.UpdateAccountResp, error) {
|
|
l := logic.NewUpdateAccountLogic(ctx, s.svcCtx)
|
|
return l.UpdateAccount(in)
|
|
}
|
|
|
|
func (s *SlurmServer) DeleteAccount(ctx context.Context, in *slurm.DeleteAccountReq) (*slurm.DeleteAccountResp, error) {
|
|
l := logic.NewDeleteAccountLogic(ctx, s.svcCtx)
|
|
return l.DeleteAccount(in)
|
|
}
|
|
|
|
func (s *SlurmServer) ListCluster(ctx context.Context, in *slurm.ListClusterReq) (*slurm.ListClusterResp, error) {
|
|
l := logic.NewListClusterLogic(ctx, s.svcCtx)
|
|
return l.ListCluster(in)
|
|
}
|
|
|
|
func (s *SlurmServer) GetCluster(ctx context.Context, in *slurm.GetClusterReq) (*slurm.GetClusterResp, error) {
|
|
l := logic.NewGetClusterLogic(ctx, s.svcCtx)
|
|
return l.GetCluster(in)
|
|
}
|
|
|
|
func (s *SlurmServer) AddCluster(ctx context.Context, in *slurm.AddClusterReq) (*slurm.AddClusterResp, error) {
|
|
l := logic.NewAddClusterLogic(ctx, s.svcCtx)
|
|
return l.AddCluster(in)
|
|
}
|
|
|
|
func (s *SlurmServer) DeleteCluster(ctx context.Context, in *slurm.DeleteClusterReq) (*slurm.DeleteClusterResp, error) {
|
|
l := logic.NewDeleteClusterLogic(ctx, s.svcCtx)
|
|
return l.DeleteCluster(in)
|
|
}
|
|
|
|
func (s *SlurmServer) ListWckey(ctx context.Context, in *slurm.ListWckeyReq) (*slurm.ListWckeyResp, error) {
|
|
l := logic.NewListWckeyLogic(ctx, s.svcCtx)
|
|
return l.ListWckey(in)
|
|
}
|
|
|
|
func (s *SlurmServer) GetWckey(ctx context.Context, in *slurm.GetWckeyReq) (*slurm.GetWckeyResp, error) {
|
|
l := logic.NewGetWckeyLogic(ctx, s.svcCtx)
|
|
return l.GetWckey(in)
|
|
}
|
|
|
|
func (s *SlurmServer) AddWckey(ctx context.Context, in *slurm.AddWckeyReq) (*slurm.AddWckeyResp, error) {
|
|
l := logic.NewAddWckeyLogic(ctx, s.svcCtx)
|
|
return l.AddWckey(in)
|
|
}
|
|
|
|
func (s *SlurmServer) DeleteWckey(ctx context.Context, in *slurm.DeleteWckeyReq) (*slurm.DeleteWckeyResp, error) {
|
|
l := logic.NewDeleteWckeyLogic(ctx, s.svcCtx)
|
|
return l.DeleteWckey(in)
|
|
}
|
|
|
|
func (s *SlurmServer) ListAssociation(ctx context.Context, in *slurm.ListAssociationReq) (*slurm.ListAssociationResp, error) {
|
|
l := logic.NewListAssociationLogic(ctx, s.svcCtx)
|
|
return l.ListAssociation(in)
|
|
}
|
|
|
|
func (s *SlurmServer) GetAssociation(ctx context.Context, in *slurm.GetAssociationReq) (*slurm.GetAssociationResp, error) {
|
|
l := logic.NewGetAssociationLogic(ctx, s.svcCtx)
|
|
return l.GetAssociation(in)
|
|
}
|
|
|
|
func (s *SlurmServer) SetAssociation(ctx context.Context, in *slurm.SetAssociationReq) (*slurm.SetAssociationResp, error) {
|
|
l := logic.NewSetAssociationLogic(ctx, s.svcCtx)
|
|
return l.SetAssociation(in)
|
|
}
|
|
|
|
func (s *SlurmServer) DeleteAssociation(ctx context.Context, in *slurm.DeleteAssociationReq) (*slurm.DeleteAssociationResp, error) {
|
|
l := logic.NewDeleteAssociationLogic(ctx, s.svcCtx)
|
|
return l.DeleteAssociation(in)
|
|
}
|
|
|
|
func (s *SlurmServer) GetDiagnostics(ctx context.Context, in *slurm.ListDiagnosticsReq) (*slurm.ListDiagnosticsResp, error) {
|
|
l := logic.NewGetDiagnosticsLogic(ctx, s.svcCtx)
|
|
return l.GetDiagnostics(in)
|
|
}
|
|
|
|
func (s *SlurmServer) GetDbDiagnostics(ctx context.Context, in *slurm.ListDbDiagnosticsReq) (*slurm.ListDbDiagnosticsResp, error) {
|
|
l := logic.NewGetDbDiagnosticsLogic(ctx, s.svcCtx)
|
|
return l.GetDbDiagnostics(in)
|
|
}
|