pcm-coordinator/adaptor/pcm_slurm/server/slurmImpl.go

package server

import (
	pbslurm "code.gitlink.org.cn/JCCE/PCM.git/adaptor/pcm_slurm/gen/idl"
	slurmer "code.gitlink.org.cn/JCCE/PCM.git/adaptor/pcm_slurm/service"
	"context"
)

func ListUsers(ctx context.Context, req *pbslurm.ListUsersReq) (*pbslurm.ListUsersResp, error) {
	slurm, _ := slurmer.SelectSlurmVersion(req.SlurmVersion)
	if slurm == nil {
		return nil, nil
	}
	resp, _ := slurm.ListUsers(ctx, req)
	return resp, nil
}

func GetUser(ctx context.Context, req *pbslurm.GetUserReq) (*pbslurm.GetUserResp, error) {
	slurm, _ := slurmer.SelectSlurmVersion(req.SlurmVersion)
	if slurm == nil {
		return nil, nil
	}
	resp, _ := slurm.GetUser(ctx, req)
	return resp, nil
}

func AddUser(ctx context.Context, req *pbslurm.AddUserReq) (*pbslurm.AddUserResp, error) {
	slurm, _ := slurmer.SelectSlurmVersion(req.SlurmVersion)
	if slurm == nil {
		return nil, nil
	}
	resp, _ := slurm.AddUser(ctx, req)
	return resp, nil
}

func DeleteUser(ctx context.Context, req *pbslurm.DeleteUserReq) (*pbslurm.DeleteUserResp, error) {
	slurm, _ := slurmer.SelectSlurmVersion(req.SlurmVersion)
	if slurm == nil {
		return nil, nil
	}
	resp, _ := slurm.DeleteUser(ctx, req)
	return resp, nil
}

func ListAssociations(ctx context.Context, req *pbslurm.ListAssociationsReq) (*pbslurm.ListAssociationsResp, error) {
	slurm, _ := slurmer.SelectSlurmVersion(req.SlurmVersion)
	if slurm == nil {
		return nil, nil
	}
	resp, _ := slurm.ListAssociations(ctx, req)
	return resp, nil
}

func GetAssociation(ctx context.Context, req *pbslurm.GetAssociationReq) (*pbslurm.GetAssociationResp, error) {
	slurm, _ := slurmer.SelectSlurmVersion(req.SlurmVersion)
	if slurm == nil {
		return nil, nil
	}
	resp, _ := slurm.GetAssociation(ctx, req)
	return resp, nil
}

func ListAccounts(ctx context.Context, req *pbslurm.ListAccountsReq) (*pbslurm.ListAccountsResp, error) {
	slurm, _ := slurmer.SelectSlurmVersion(req.SlurmVersion)
	if slurm == nil {
		return nil, nil
	}
	resp, _ := slurm.ListAccounts(ctx, req)
	return resp, nil
}

func GetAccount(ctx context.Context, req *pbslurm.GetAccountReq) (*pbslurm.GetAccountResp, error) {
	slurm, _ := slurmer.SelectSlurmVersion(req.SlurmVersion)
	if slurm == nil {
		return nil, nil
	}
	resp, _ := slurm.GetAccount(ctx, req)
	return resp, nil
}

func AddAccount(ctx context.Context, req *pbslurm.AddAccountReq) (*pbslurm.AddAccountResp, error) {
	slurm, _ := slurmer.SelectSlurmVersion(req.SlurmVersion)
	if slurm == nil {
		return nil, nil
	}
	resp, _ := slurm.AddAccount(ctx, req)
	return resp, nil
}

func DeleteAccount(ctx context.Context, req *pbslurm.DeleteAccountReq) (*pbslurm.DeleteAccountResp, error) {
	slurm, _ := slurmer.SelectSlurmVersion(req.SlurmVersion)
	if slurm == nil {
		return nil, nil
	}
	resp, _ := slurm.DeleteAccount(ctx, req)
	return resp, nil
}

func ListQoss(ctx context.Context, req *pbslurm.ListQossReq) (*pbslurm.ListQossResp, error) {
	slurm, _ := slurmer.SelectSlurmVersion(req.SlurmVersion)
	if slurm == nil {
		return nil, nil
	}
	resp, _ := slurm.ListQoss(ctx, req)
	return resp, nil
}

func ListWckeys(ctx context.Context, req *pbslurm.ListWckeysReq) (*pbslurm.ListWckeysResp, error) {
	slurm, _ := slurmer.SelectSlurmVersion(req.SlurmVersion)
	if slurm == nil {
		return nil, nil
	}
	resp, _ := slurm.ListWckeys(ctx, req)
	return resp, nil
}

func GetWckey(ctx context.Context, req *pbslurm.GetWckeyReq) (*pbslurm.GetWckeyResp, error) {
	slurm, _ := slurmer.SelectSlurmVersion(req.SlurmVersion)
	if slurm == nil {
		return nil, nil
	}
	resp, _ := slurm.GetWckey(ctx, req)
	return resp, nil
}