pcm-ac/hpcAC/hpcAC_grpc.pb.go

// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.3.0
// - protoc             v3.19.4
// source: hpcAC.proto

package hpcAC

import (
	context "context"
	grpc "google.golang.org/grpc"
	codes "google.golang.org/grpc/codes"
	status "google.golang.org/grpc/status"
)

// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
// Requires gRPC-Go v1.32.0 or later.
const _ = grpc.SupportPackageIsVersion7

const (
	HpcAC_ListJob_FullMethodName                  = "/hpcAC.hpcAC/ListJob"
	HpcAC_ListHistoryJob_FullMethodName           = "/hpcAC.hpcAC/ListHistoryJob"
	HpcAC_SubmitJob_FullMethodName                = "/hpcAC.hpcAC/SubmitJob"
	HpcAC_ListJobManager_FullMethodName           = "/hpcAC.hpcAC/ListJobManager"
	HpcAC_GetJobDetail_FullMethodName             = "/hpcAC.hpcAC/GetJobDetail"
	HpcAC_DeleteJob_FullMethodName                = "/hpcAC.hpcAC/DeleteJob"
	HpcAC_FileContent_FullMethodName              = "/hpcAC.hpcAC/FileContent"
	HpcAC_SelectQueueByUser_FullMethodName        = "/hpcAC.hpcAC/SelectQueueByUser"
	HpcAC_QueryQueueDetails_FullMethodName        = "/hpcAC.hpcAC/QueryQueueDetails"
	HpcAC_QueryUserQuotasLimit_FullMethodName     = "/hpcAC.hpcAC/QueryUserQuotasLimit"
	HpcAC_ParaStorQuota_FullMethodName            = "/hpcAC.hpcAC/ParaStorQuota"
	HpcAC_WallTime_FullMethodName                 = "/hpcAC.hpcAC/WallTime"
	HpcAC_QueueJobs_FullMethodName                = "/hpcAC.hpcAC/QueueJobs"
	HpcAC_CpuCore_FullMethodName                  = "/hpcAC.hpcAC/CpuCore"
	HpcAC_Jobs_FullMethodName                     = "/hpcAC.hpcAC/jobs"
	HpcAC_HistoryJobDetail_FullMethodName         = "/hpcAC.hpcAC/HistoryJobDetail"
	HpcAC_GetACToken_FullMethodName               = "/hpcAC.hpcAC/GetACToken"
	HpcAC_GetACClusterId_FullMethodName           = "/hpcAC.hpcAC/GetACClusterId"
	HpcAC_GetComputingPower_FullMethodName        = "/hpcAC.hpcAC/GetComputingPower"
	HpcAC_GetGeneralInfo_FullMethodName           = "/hpcAC.hpcAC/GetGeneralInfo"
	HpcAC_SubmitPytorchTask_FullMethodName        = "/hpcAC.hpcAC/SubmitPytorchTask"
	HpcAC_SubmitTensorflowTask_FullMethodName     = "/hpcAC.hpcAC/SubmitTensorflowTask"
	HpcAC_GetImageListAi_FullMethodName           = "/hpcAC.hpcAC/GetImageListAi"
	HpcAC_GetImageAiById_FullMethodName           = "/hpcAC.hpcAC/GetImageAiById"
	HpcAC_GetPytorchTask_FullMethodName           = "/hpcAC.hpcAC/GetPytorchTask"
	HpcAC_GetTensorflowTask_FullMethodName        = "/hpcAC.hpcAC/GetTensorflowTask"
	HpcAC_DeleteTaskAi_FullMethodName             = "/hpcAC.hpcAC/DeleteTaskAi"
	HpcAC_StopTaskAi_FullMethodName               = "/hpcAC.hpcAC/StopTaskAi"
	HpcAC_GetResourceSpec_FullMethodName          = "/hpcAC.hpcAC/GetResourceSpec"
	HpcAC_GetInstanceLog_FullMethodName           = "/hpcAC.hpcAC/GetInstanceLog"
	HpcAC_GetInstanceListAi_FullMethodName        = "/hpcAC.hpcAC/GetInstanceListAi"
	HpcAC_GetInferUrl_FullMethodName              = "/hpcAC.hpcAC/GetInferUrl"
	HpcAC_GetFileList_FullMethodName              = "/hpcAC.hpcAC/GetFileList"
	HpcAC_GetFile_FullMethodName                  = "/hpcAC.hpcAC/GetFile"
	HpcAC_UploadFile_FullMethodName               = "/hpcAC.hpcAC/UploadFile"
	HpcAC_IsExistFile_FullMethodName              = "/hpcAC.hpcAC/IsExistFile"
	HpcAC_GetUserInfo_FullMethodName              = "/hpcAC.hpcAC/GetUserInfo"
	HpcAC_GetMemberJobs_FullMethodName            = "/hpcAC.hpcAC/GetMemberJobs"
	HpcAC_GetNodeResources_FullMethodName         = "/hpcAC.hpcAC/GetNodeResources"
	HpcAC_GetInstanceServiceList_FullMethodName   = "/hpcAC.hpcAC/GetInstanceServiceList"
	HpcAC_GetInstanceServiceDetail_FullMethodName = "/hpcAC.hpcAC/GetInstanceServiceDetail"
	HpcAC_StartInstanceService_FullMethodName     = "/hpcAC.hpcAC/StartInstanceService"
	HpcAC_StopInstanceService_FullMethodName      = "/hpcAC.hpcAC/StopInstanceService"
	HpcAC_CreateInstanceService_FullMethodName    = "/hpcAC.hpcAC/CreateInstanceService"
	HpcAC_GetImageList_FullMethodName             = "/hpcAC.hpcAC/GetImageList"
)

// HpcACClient is the client API for HpcAC service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
type HpcACClient interface {
	// ListJob list all jobs
	ListJob(ctx context.Context, in *ListJobReq, opts ...grpc.CallOption) (*ListJobResp, error)
	// ListHistoryJob list all history jobs
	ListHistoryJob(ctx context.Context, in *ListHistoryJobReq, opts ...grpc.CallOption) (*ListHistoryJobResp, error)
	// Submit job
	SubmitJob(ctx context.Context, in *SubmitJobReq, opts ...grpc.CallOption) (*SubmitJobResp, error)
	// ListJobManager list all job managers
	ListJobManager(ctx context.Context, in *JobManagerReq, opts ...grpc.CallOption) (*ListJobManagerResp, error)
	// GetJobDetail get job detail
	GetJobDetail(ctx context.Context, in *JobDetailReq, opts ...grpc.CallOption) (*GetJobDetailResp, error)
	// DeleteJob delete job
	DeleteJob(ctx context.Context, in *DeleteJobReq, opts ...grpc.CallOption) (*DeleteJobResp, error)
	// FileContent 查看文件内容
	FileContent(ctx context.Context, in *FileDataReq, opts ...grpc.CallOption) (*FileContentResp, error)
	// SelectQueueByUser 查询用户可访问队列列表
	SelectQueueByUser(ctx context.Context, in *QueueReq, opts ...grpc.CallOption) (*QueueResp, error)
	// QueryQueueDetails 查询队列资源详细信息
	QueryQueueDetails(ctx context.Context, in *QueueReq, opts ...grpc.CallOption) (*QueueDetailsResp, error)
	// /QueryUserQuotasLimit 查询用户资源限制信息
	QueryUserQuotasLimit(ctx context.Context, in *QueueReq, opts ...grpc.CallOption) (*UserQuotasLimitResp, error)
	// ParaStor Quota
	ParaStorQuota(ctx context.Context, in *ParaStorQuotaReq, opts ...grpc.CallOption) (*ParaStorQuotaResp, error)
	// WallTime
	WallTime(ctx context.Context, in *WallTimeReq, opts ...grpc.CallOption) (*WallTimeResp, error)
	// QueueJobs
	QueueJobs(ctx context.Context, in *QueueJobsReq, opts ...grpc.CallOption) (*QueueJobsResp, error)
	CpuCore(ctx context.Context, in *CpuCoreReq, opts ...grpc.CallOption) (*CpuCoreResp, error)
	Jobs(ctx context.Context, in *JobsReq, opts ...grpc.CallOption) (*JobsResp, error)
	HistoryJobDetail(ctx context.Context, in *HistoryJobDetailReq, opts ...grpc.CallOption) (*HistoryJobDetailResp, error)
	// 曙光ac获取token
	GetACToken(ctx context.Context, in *ACTokenReq, opts ...grpc.CallOption) (*TokenResp, error)
	// 曙光ac获取clusterid
	GetACClusterId(ctx context.Context, in *ACClusterReq, opts ...grpc.CallOption) (*ClusterResp, error)
	// 获取曙光账号算力
	GetComputingPower(ctx context.Context, in *ResourceReq, opts ...grpc.CallOption) (*CpResp, error)
	// 获取曙光账号cpu,内存，存储信息
	GetGeneralInfo(ctx context.Context, in *ResourceReq, opts ...grpc.CallOption) (*GiResp, error)
	// 曙光智算接口
	SubmitPytorchTask(ctx context.Context, in *SubmitPytorchTaskReq, opts ...grpc.CallOption) (*SubmitTaskAiResp, error)
	SubmitTensorflowTask(ctx context.Context, in *SubmitTensorflowTaskReq, opts ...grpc.CallOption) (*SubmitTaskAiResp, error)
	GetImageListAi(ctx context.Context, in *GetImageListAiReq, opts ...grpc.CallOption) (*GetImageListAiResp, error)
	GetImageAiById(ctx context.Context, in *GetImageAiByIdReq, opts ...grpc.CallOption) (*GetImageAiByIdResp, error)
	GetPytorchTask(ctx context.Context, in *GetPytorchTaskReq, opts ...grpc.CallOption) (*GetPytorchTaskResp, error)
	GetTensorflowTask(ctx context.Context, in *GetTensorflowTaskReq, opts ...grpc.CallOption) (*GetTensorflowTaskResp, error)
	DeleteTaskAi(ctx context.Context, in *DeleteTaskAiReq, opts ...grpc.CallOption) (*DeleteTaskAiResp, error)
	StopTaskAi(ctx context.Context, in *StopTaskAiReq, opts ...grpc.CallOption) (*StopTaskAiResp, error)
	GetResourceSpec(ctx context.Context, in *GetResourceSpecReq, opts ...grpc.CallOption) (*GetResourceSpecResp, error)
	GetInstanceLog(ctx context.Context, in *GetInstanceLogReq, opts ...grpc.CallOption) (*GetInstanceLogResp, error)
	GetInstanceListAi(ctx context.Context, in *GetInstanceListReq, opts ...grpc.CallOption) (*GetInstanceListResp, error)
	GetInferUrl(ctx context.Context, in *GetInferUrlReq, opts ...grpc.CallOption) (*GetInferUrlResp, error)
	// 曙光文件接口
	GetFileList(ctx context.Context, in *GetFileListReq, opts ...grpc.CallOption) (*GetFileListResp, error)
	GetFile(ctx context.Context, in *GetFileReq, opts ...grpc.CallOption) (*GetFileResp, error)
	UploadFile(ctx context.Context, in *UploadFileReq, opts ...grpc.CallOption) (*UploadFileResp, error)
	IsExistFile(ctx context.Context, in *IsExistFileReq, opts ...grpc.CallOption) (*IsExistFileResp, error)
	// 用户资源
	GetUserInfo(ctx context.Context, in *GetUserInfoReq, opts ...grpc.CallOption) (*GetUserInfoResp, error)
	GetMemberJobs(ctx context.Context, in *GetMemberJobsReq, opts ...grpc.CallOption) (*GetMemberJobsResp, error)
	// 容器
	GetNodeResources(ctx context.Context, in *GetNodeResourcesReq, opts ...grpc.CallOption) (*GetNodeResourcesResp, error)
	GetInstanceServiceList(ctx context.Context, in *GetInstanceServiceListReq, opts ...grpc.CallOption) (*GetInstanceServiceListResp, error)
	GetInstanceServiceDetail(ctx context.Context, in *GetInstanceServiceDetailReq, opts ...grpc.CallOption) (*GetInstanceServiceDetailResp, error)
	StartInstanceService(ctx context.Context, in *StartInstanceServiceReq, opts ...grpc.CallOption) (*StartInstanceServiceResp, error)
	StopInstanceService(ctx context.Context, in *StopInstanceServiceReq, opts ...grpc.CallOption) (*StopInstanceServiceResp, error)
	CreateInstanceService(ctx context.Context, in *CreateInstanceServiceReq, opts ...grpc.CallOption) (*CreateInstanceServiceResp, error)
	GetImageList(ctx context.Context, in *GetImageListReq, opts ...grpc.CallOption) (*GetImageListResp, error)
}

type hpcACClient struct {
	cc grpc.ClientConnInterface
}

func NewHpcACClient(cc grpc.ClientConnInterface) HpcACClient {
	return &hpcACClient{cc}
}

func (c *hpcACClient) ListJob(ctx context.Context, in *ListJobReq, opts ...grpc.CallOption) (*ListJobResp, error) {
	out := new(ListJobResp)
	err := c.cc.Invoke(ctx, HpcAC_ListJob_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) ListHistoryJob(ctx context.Context, in *ListHistoryJobReq, opts ...grpc.CallOption) (*ListHistoryJobResp, error) {
	out := new(ListHistoryJobResp)
	err := c.cc.Invoke(ctx, HpcAC_ListHistoryJob_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) SubmitJob(ctx context.Context, in *SubmitJobReq, opts ...grpc.CallOption) (*SubmitJobResp, error) {
	out := new(SubmitJobResp)
	err := c.cc.Invoke(ctx, HpcAC_SubmitJob_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) ListJobManager(ctx context.Context, in *JobManagerReq, opts ...grpc.CallOption) (*ListJobManagerResp, error) {
	out := new(ListJobManagerResp)
	err := c.cc.Invoke(ctx, HpcAC_ListJobManager_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) GetJobDetail(ctx context.Context, in *JobDetailReq, opts ...grpc.CallOption) (*GetJobDetailResp, error) {
	out := new(GetJobDetailResp)
	err := c.cc.Invoke(ctx, HpcAC_GetJobDetail_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) DeleteJob(ctx context.Context, in *DeleteJobReq, opts ...grpc.CallOption) (*DeleteJobResp, error) {
	out := new(DeleteJobResp)
	err := c.cc.Invoke(ctx, HpcAC_DeleteJob_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) FileContent(ctx context.Context, in *FileDataReq, opts ...grpc.CallOption) (*FileContentResp, error) {
	out := new(FileContentResp)
	err := c.cc.Invoke(ctx, HpcAC_FileContent_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) SelectQueueByUser(ctx context.Context, in *QueueReq, opts ...grpc.CallOption) (*QueueResp, error) {
	out := new(QueueResp)
	err := c.cc.Invoke(ctx, HpcAC_SelectQueueByUser_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) QueryQueueDetails(ctx context.Context, in *QueueReq, opts ...grpc.CallOption) (*QueueDetailsResp, error) {
	out := new(QueueDetailsResp)
	err := c.cc.Invoke(ctx, HpcAC_QueryQueueDetails_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) QueryUserQuotasLimit(ctx context.Context, in *QueueReq, opts ...grpc.CallOption) (*UserQuotasLimitResp, error) {
	out := new(UserQuotasLimitResp)
	err := c.cc.Invoke(ctx, HpcAC_QueryUserQuotasLimit_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) ParaStorQuota(ctx context.Context, in *ParaStorQuotaReq, opts ...grpc.CallOption) (*ParaStorQuotaResp, error) {
	out := new(ParaStorQuotaResp)
	err := c.cc.Invoke(ctx, HpcAC_ParaStorQuota_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) WallTime(ctx context.Context, in *WallTimeReq, opts ...grpc.CallOption) (*WallTimeResp, error) {
	out := new(WallTimeResp)
	err := c.cc.Invoke(ctx, HpcAC_WallTime_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) QueueJobs(ctx context.Context, in *QueueJobsReq, opts ...grpc.CallOption) (*QueueJobsResp, error) {
	out := new(QueueJobsResp)
	err := c.cc.Invoke(ctx, HpcAC_QueueJobs_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) CpuCore(ctx context.Context, in *CpuCoreReq, opts ...grpc.CallOption) (*CpuCoreResp, error) {
	out := new(CpuCoreResp)
	err := c.cc.Invoke(ctx, HpcAC_CpuCore_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) Jobs(ctx context.Context, in *JobsReq, opts ...grpc.CallOption) (*JobsResp, error) {
	out := new(JobsResp)
	err := c.cc.Invoke(ctx, HpcAC_Jobs_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) HistoryJobDetail(ctx context.Context, in *HistoryJobDetailReq, opts ...grpc.CallOption) (*HistoryJobDetailResp, error) {
	out := new(HistoryJobDetailResp)
	err := c.cc.Invoke(ctx, HpcAC_HistoryJobDetail_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) GetACToken(ctx context.Context, in *ACTokenReq, opts ...grpc.CallOption) (*TokenResp, error) {
	out := new(TokenResp)
	err := c.cc.Invoke(ctx, HpcAC_GetACToken_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) GetACClusterId(ctx context.Context, in *ACClusterReq, opts ...grpc.CallOption) (*ClusterResp, error) {
	out := new(ClusterResp)
	err := c.cc.Invoke(ctx, HpcAC_GetACClusterId_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) GetComputingPower(ctx context.Context, in *ResourceReq, opts ...grpc.CallOption) (*CpResp, error) {
	out := new(CpResp)
	err := c.cc.Invoke(ctx, HpcAC_GetComputingPower_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) GetGeneralInfo(ctx context.Context, in *ResourceReq, opts ...grpc.CallOption) (*GiResp, error) {
	out := new(GiResp)
	err := c.cc.Invoke(ctx, HpcAC_GetGeneralInfo_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) SubmitPytorchTask(ctx context.Context, in *SubmitPytorchTaskReq, opts ...grpc.CallOption) (*SubmitTaskAiResp, error) {
	out := new(SubmitTaskAiResp)
	err := c.cc.Invoke(ctx, HpcAC_SubmitPytorchTask_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) SubmitTensorflowTask(ctx context.Context, in *SubmitTensorflowTaskReq, opts ...grpc.CallOption) (*SubmitTaskAiResp, error) {
	out := new(SubmitTaskAiResp)
	err := c.cc.Invoke(ctx, HpcAC_SubmitTensorflowTask_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) GetImageListAi(ctx context.Context, in *GetImageListAiReq, opts ...grpc.CallOption) (*GetImageListAiResp, error) {
	out := new(GetImageListAiResp)
	err := c.cc.Invoke(ctx, HpcAC_GetImageListAi_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) GetImageAiById(ctx context.Context, in *GetImageAiByIdReq, opts ...grpc.CallOption) (*GetImageAiByIdResp, error) {
	out := new(GetImageAiByIdResp)
	err := c.cc.Invoke(ctx, HpcAC_GetImageAiById_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) GetPytorchTask(ctx context.Context, in *GetPytorchTaskReq, opts ...grpc.CallOption) (*GetPytorchTaskResp, error) {
	out := new(GetPytorchTaskResp)
	err := c.cc.Invoke(ctx, HpcAC_GetPytorchTask_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) GetTensorflowTask(ctx context.Context, in *GetTensorflowTaskReq, opts ...grpc.CallOption) (*GetTensorflowTaskResp, error) {
	out := new(GetTensorflowTaskResp)
	err := c.cc.Invoke(ctx, HpcAC_GetTensorflowTask_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) DeleteTaskAi(ctx context.Context, in *DeleteTaskAiReq, opts ...grpc.CallOption) (*DeleteTaskAiResp, error) {
	out := new(DeleteTaskAiResp)
	err := c.cc.Invoke(ctx, HpcAC_DeleteTaskAi_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) StopTaskAi(ctx context.Context, in *StopTaskAiReq, opts ...grpc.CallOption) (*StopTaskAiResp, error) {
	out := new(StopTaskAiResp)
	err := c.cc.Invoke(ctx, HpcAC_StopTaskAi_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) GetResourceSpec(ctx context.Context, in *GetResourceSpecReq, opts ...grpc.CallOption) (*GetResourceSpecResp, error) {
	out := new(GetResourceSpecResp)
	err := c.cc.Invoke(ctx, HpcAC_GetResourceSpec_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) GetInstanceLog(ctx context.Context, in *GetInstanceLogReq, opts ...grpc.CallOption) (*GetInstanceLogResp, error) {
	out := new(GetInstanceLogResp)
	err := c.cc.Invoke(ctx, HpcAC_GetInstanceLog_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) GetInstanceListAi(ctx context.Context, in *GetInstanceListReq, opts ...grpc.CallOption) (*GetInstanceListResp, error) {
	out := new(GetInstanceListResp)
	err := c.cc.Invoke(ctx, HpcAC_GetInstanceListAi_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) GetInferUrl(ctx context.Context, in *GetInferUrlReq, opts ...grpc.CallOption) (*GetInferUrlResp, error) {
	out := new(GetInferUrlResp)
	err := c.cc.Invoke(ctx, HpcAC_GetInferUrl_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) GetFileList(ctx context.Context, in *GetFileListReq, opts ...grpc.CallOption) (*GetFileListResp, error) {
	out := new(GetFileListResp)
	err := c.cc.Invoke(ctx, HpcAC_GetFileList_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) GetFile(ctx context.Context, in *GetFileReq, opts ...grpc.CallOption) (*GetFileResp, error) {
	out := new(GetFileResp)
	err := c.cc.Invoke(ctx, HpcAC_GetFile_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) UploadFile(ctx context.Context, in *UploadFileReq, opts ...grpc.CallOption) (*UploadFileResp, error) {
	out := new(UploadFileResp)
	err := c.cc.Invoke(ctx, HpcAC_UploadFile_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) IsExistFile(ctx context.Context, in *IsExistFileReq, opts ...grpc.CallOption) (*IsExistFileResp, error) {
	out := new(IsExistFileResp)
	err := c.cc.Invoke(ctx, HpcAC_IsExistFile_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) GetUserInfo(ctx context.Context, in *GetUserInfoReq, opts ...grpc.CallOption) (*GetUserInfoResp, error) {
	out := new(GetUserInfoResp)
	err := c.cc.Invoke(ctx, HpcAC_GetUserInfo_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) GetMemberJobs(ctx context.Context, in *GetMemberJobsReq, opts ...grpc.CallOption) (*GetMemberJobsResp, error) {
	out := new(GetMemberJobsResp)
	err := c.cc.Invoke(ctx, HpcAC_GetMemberJobs_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) GetNodeResources(ctx context.Context, in *GetNodeResourcesReq, opts ...grpc.CallOption) (*GetNodeResourcesResp, error) {
	out := new(GetNodeResourcesResp)
	err := c.cc.Invoke(ctx, HpcAC_GetNodeResources_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) GetInstanceServiceList(ctx context.Context, in *GetInstanceServiceListReq, opts ...grpc.CallOption) (*GetInstanceServiceListResp, error) {
	out := new(GetInstanceServiceListResp)
	err := c.cc.Invoke(ctx, HpcAC_GetInstanceServiceList_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) GetInstanceServiceDetail(ctx context.Context, in *GetInstanceServiceDetailReq, opts ...grpc.CallOption) (*GetInstanceServiceDetailResp, error) {
	out := new(GetInstanceServiceDetailResp)
	err := c.cc.Invoke(ctx, HpcAC_GetInstanceServiceDetail_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) StartInstanceService(ctx context.Context, in *StartInstanceServiceReq, opts ...grpc.CallOption) (*StartInstanceServiceResp, error) {
	out := new(StartInstanceServiceResp)
	err := c.cc.Invoke(ctx, HpcAC_StartInstanceService_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) StopInstanceService(ctx context.Context, in *StopInstanceServiceReq, opts ...grpc.CallOption) (*StopInstanceServiceResp, error) {
	out := new(StopInstanceServiceResp)
	err := c.cc.Invoke(ctx, HpcAC_StopInstanceService_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) CreateInstanceService(ctx context.Context, in *CreateInstanceServiceReq, opts ...grpc.CallOption) (*CreateInstanceServiceResp, error) {
	out := new(CreateInstanceServiceResp)
	err := c.cc.Invoke(ctx, HpcAC_CreateInstanceService_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *hpcACClient) GetImageList(ctx context.Context, in *GetImageListReq, opts ...grpc.CallOption) (*GetImageListResp, error) {
	out := new(GetImageListResp)
	err := c.cc.Invoke(ctx, HpcAC_GetImageList_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// HpcACServer is the server API for HpcAC service.
// All implementations must embed UnimplementedHpcACServer
// for forward compatibility
type HpcACServer interface {
	// ListJob list all jobs
	ListJob(context.Context, *ListJobReq) (*ListJobResp, error)
	// ListHistoryJob list all history jobs
	ListHistoryJob(context.Context, *ListHistoryJobReq) (*ListHistoryJobResp, error)
	// Submit job
	SubmitJob(context.Context, *SubmitJobReq) (*SubmitJobResp, error)
	// ListJobManager list all job managers
	ListJobManager(context.Context, *JobManagerReq) (*ListJobManagerResp, error)
	// GetJobDetail get job detail
	GetJobDetail(context.Context, *JobDetailReq) (*GetJobDetailResp, error)
	// DeleteJob delete job
	DeleteJob(context.Context, *DeleteJobReq) (*DeleteJobResp, error)
	// FileContent 查看文件内容
	FileContent(context.Context, *FileDataReq) (*FileContentResp, error)
	// SelectQueueByUser 查询用户可访问队列列表
	SelectQueueByUser(context.Context, *QueueReq) (*QueueResp, error)
	// QueryQueueDetails 查询队列资源详细信息
	QueryQueueDetails(context.Context, *QueueReq) (*QueueDetailsResp, error)
	// /QueryUserQuotasLimit 查询用户资源限制信息
	QueryUserQuotasLimit(context.Context, *QueueReq) (*UserQuotasLimitResp, error)
	// ParaStor Quota
	ParaStorQuota(context.Context, *ParaStorQuotaReq) (*ParaStorQuotaResp, error)
	// WallTime
	WallTime(context.Context, *WallTimeReq) (*WallTimeResp, error)
	// QueueJobs
	QueueJobs(context.Context, *QueueJobsReq) (*QueueJobsResp, error)
	CpuCore(context.Context, *CpuCoreReq) (*CpuCoreResp, error)
	Jobs(context.Context, *JobsReq) (*JobsResp, error)
	HistoryJobDetail(context.Context, *HistoryJobDetailReq) (*HistoryJobDetailResp, error)
	// 曙光ac获取token
	GetACToken(context.Context, *ACTokenReq) (*TokenResp, error)
	// 曙光ac获取clusterid
	GetACClusterId(context.Context, *ACClusterReq) (*ClusterResp, error)
	// 获取曙光账号算力
	GetComputingPower(context.Context, *ResourceReq) (*CpResp, error)
	// 获取曙光账号cpu,内存，存储信息
	GetGeneralInfo(context.Context, *ResourceReq) (*GiResp, error)
	// 曙光智算接口
	SubmitPytorchTask(context.Context, *SubmitPytorchTaskReq) (*SubmitTaskAiResp, error)
	SubmitTensorflowTask(context.Context, *SubmitTensorflowTaskReq) (*SubmitTaskAiResp, error)
	GetImageListAi(context.Context, *GetImageListAiReq) (*GetImageListAiResp, error)
	GetImageAiById(context.Context, *GetImageAiByIdReq) (*GetImageAiByIdResp, error)
	GetPytorchTask(context.Context, *GetPytorchTaskReq) (*GetPytorchTaskResp, error)
	GetTensorflowTask(context.Context, *GetTensorflowTaskReq) (*GetTensorflowTaskResp, error)
	DeleteTaskAi(context.Context, *DeleteTaskAiReq) (*DeleteTaskAiResp, error)
	StopTaskAi(context.Context, *StopTaskAiReq) (*StopTaskAiResp, error)
	GetResourceSpec(context.Context, *GetResourceSpecReq) (*GetResourceSpecResp, error)
	GetInstanceLog(context.Context, *GetInstanceLogReq) (*GetInstanceLogResp, error)
	GetInstanceListAi(context.Context, *GetInstanceListReq) (*GetInstanceListResp, error)
	GetInferUrl(context.Context, *GetInferUrlReq) (*GetInferUrlResp, error)
	// 曙光文件接口
	GetFileList(context.Context, *GetFileListReq) (*GetFileListResp, error)
	GetFile(context.Context, *GetFileReq) (*GetFileResp, error)
	UploadFile(context.Context, *UploadFileReq) (*UploadFileResp, error)
	IsExistFile(context.Context, *IsExistFileReq) (*IsExistFileResp, error)
	// 用户资源
	GetUserInfo(context.Context, *GetUserInfoReq) (*GetUserInfoResp, error)
	GetMemberJobs(context.Context, *GetMemberJobsReq) (*GetMemberJobsResp, error)
	// 容器
	GetNodeResources(context.Context, *GetNodeResourcesReq) (*GetNodeResourcesResp, error)
	GetInstanceServiceList(context.Context, *GetInstanceServiceListReq) (*GetInstanceServiceListResp, error)
	GetInstanceServiceDetail(context.Context, *GetInstanceServiceDetailReq) (*GetInstanceServiceDetailResp, error)
	StartInstanceService(context.Context, *StartInstanceServiceReq) (*StartInstanceServiceResp, error)
	StopInstanceService(context.Context, *StopInstanceServiceReq) (*StopInstanceServiceResp, error)
	CreateInstanceService(context.Context, *CreateInstanceServiceReq) (*CreateInstanceServiceResp, error)
	GetImageList(context.Context, *GetImageListReq) (*GetImageListResp, error)
	mustEmbedUnimplementedHpcACServer()
}

// UnimplementedHpcACServer must be embedded to have forward compatible implementations.
type UnimplementedHpcACServer struct {
}

func (UnimplementedHpcACServer) ListJob(context.Context, *ListJobReq) (*ListJobResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListJob not implemented")
}
func (UnimplementedHpcACServer) ListHistoryJob(context.Context, *ListHistoryJobReq) (*ListHistoryJobResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListHistoryJob not implemented")
}
func (UnimplementedHpcACServer) SubmitJob(context.Context, *SubmitJobReq) (*SubmitJobResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method SubmitJob not implemented")
}
func (UnimplementedHpcACServer) ListJobManager(context.Context, *JobManagerReq) (*ListJobManagerResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListJobManager not implemented")
}
func (UnimplementedHpcACServer) GetJobDetail(context.Context, *JobDetailReq) (*GetJobDetailResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetJobDetail not implemented")
}
func (UnimplementedHpcACServer) DeleteJob(context.Context, *DeleteJobReq) (*DeleteJobResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteJob not implemented")
}
func (UnimplementedHpcACServer) FileContent(context.Context, *FileDataReq) (*FileContentResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method FileContent not implemented")
}
func (UnimplementedHpcACServer) SelectQueueByUser(context.Context, *QueueReq) (*QueueResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method SelectQueueByUser not implemented")
}
func (UnimplementedHpcACServer) QueryQueueDetails(context.Context, *QueueReq) (*QueueDetailsResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method QueryQueueDetails not implemented")
}
func (UnimplementedHpcACServer) QueryUserQuotasLimit(context.Context, *QueueReq) (*UserQuotasLimitResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method QueryUserQuotasLimit not implemented")
}
func (UnimplementedHpcACServer) ParaStorQuota(context.Context, *ParaStorQuotaReq) (*ParaStorQuotaResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ParaStorQuota not implemented")
}
func (UnimplementedHpcACServer) WallTime(context.Context, *WallTimeReq) (*WallTimeResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method WallTime not implemented")
}
func (UnimplementedHpcACServer) QueueJobs(context.Context, *QueueJobsReq) (*QueueJobsResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method QueueJobs not implemented")
}
func (UnimplementedHpcACServer) CpuCore(context.Context, *CpuCoreReq) (*CpuCoreResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CpuCore not implemented")
}
func (UnimplementedHpcACServer) Jobs(context.Context, *JobsReq) (*JobsResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method Jobs not implemented")
}
func (UnimplementedHpcACServer) HistoryJobDetail(context.Context, *HistoryJobDetailReq) (*HistoryJobDetailResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method HistoryJobDetail not implemented")
}
func (UnimplementedHpcACServer) GetACToken(context.Context, *ACTokenReq) (*TokenResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetACToken not implemented")
}
func (UnimplementedHpcACServer) GetACClusterId(context.Context, *ACClusterReq) (*ClusterResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetACClusterId not implemented")
}
func (UnimplementedHpcACServer) GetComputingPower(context.Context, *ResourceReq) (*CpResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetComputingPower not implemented")
}
func (UnimplementedHpcACServer) GetGeneralInfo(context.Context, *ResourceReq) (*GiResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetGeneralInfo not implemented")
}
func (UnimplementedHpcACServer) SubmitPytorchTask(context.Context, *SubmitPytorchTaskReq) (*SubmitTaskAiResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method SubmitPytorchTask not implemented")
}
func (UnimplementedHpcACServer) SubmitTensorflowTask(context.Context, *SubmitTensorflowTaskReq) (*SubmitTaskAiResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method SubmitTensorflowTask not implemented")
}
func (UnimplementedHpcACServer) GetImageListAi(context.Context, *GetImageListAiReq) (*GetImageListAiResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetImageListAi not implemented")
}
func (UnimplementedHpcACServer) GetImageAiById(context.Context, *GetImageAiByIdReq) (*GetImageAiByIdResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetImageAiById not implemented")
}
func (UnimplementedHpcACServer) GetPytorchTask(context.Context, *GetPytorchTaskReq) (*GetPytorchTaskResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetPytorchTask not implemented")
}
func (UnimplementedHpcACServer) GetTensorflowTask(context.Context, *GetTensorflowTaskReq) (*GetTensorflowTaskResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetTensorflowTask not implemented")
}
func (UnimplementedHpcACServer) DeleteTaskAi(context.Context, *DeleteTaskAiReq) (*DeleteTaskAiResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteTaskAi not implemented")
}
func (UnimplementedHpcACServer) StopTaskAi(context.Context, *StopTaskAiReq) (*StopTaskAiResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method StopTaskAi not implemented")
}
func (UnimplementedHpcACServer) GetResourceSpec(context.Context, *GetResourceSpecReq) (*GetResourceSpecResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetResourceSpec not implemented")
}
func (UnimplementedHpcACServer) GetInstanceLog(context.Context, *GetInstanceLogReq) (*GetInstanceLogResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetInstanceLog not implemented")
}
func (UnimplementedHpcACServer) GetInstanceListAi(context.Context, *GetInstanceListReq) (*GetInstanceListResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetInstanceListAi not implemented")
}
func (UnimplementedHpcACServer) GetInferUrl(context.Context, *GetInferUrlReq) (*GetInferUrlResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetInferUrl not implemented")
}
func (UnimplementedHpcACServer) GetFileList(context.Context, *GetFileListReq) (*GetFileListResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetFileList not implemented")
}
func (UnimplementedHpcACServer) GetFile(context.Context, *GetFileReq) (*GetFileResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetFile not implemented")
}
func (UnimplementedHpcACServer) UploadFile(context.Context, *UploadFileReq) (*UploadFileResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UploadFile not implemented")
}
func (UnimplementedHpcACServer) IsExistFile(context.Context, *IsExistFileReq) (*IsExistFileResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method IsExistFile not implemented")
}
func (UnimplementedHpcACServer) GetUserInfo(context.Context, *GetUserInfoReq) (*GetUserInfoResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetUserInfo not implemented")
}
func (UnimplementedHpcACServer) GetMemberJobs(context.Context, *GetMemberJobsReq) (*GetMemberJobsResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetMemberJobs not implemented")
}
func (UnimplementedHpcACServer) GetNodeResources(context.Context, *GetNodeResourcesReq) (*GetNodeResourcesResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetNodeResources not implemented")
}
func (UnimplementedHpcACServer) GetInstanceServiceList(context.Context, *GetInstanceServiceListReq) (*GetInstanceServiceListResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetInstanceServiceList not implemented")
}
func (UnimplementedHpcACServer) GetInstanceServiceDetail(context.Context, *GetInstanceServiceDetailReq) (*GetInstanceServiceDetailResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetInstanceServiceDetail not implemented")
}
func (UnimplementedHpcACServer) StartInstanceService(context.Context, *StartInstanceServiceReq) (*StartInstanceServiceResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method StartInstanceService not implemented")
}
func (UnimplementedHpcACServer) StopInstanceService(context.Context, *StopInstanceServiceReq) (*StopInstanceServiceResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method StopInstanceService not implemented")
}
func (UnimplementedHpcACServer) CreateInstanceService(context.Context, *CreateInstanceServiceReq) (*CreateInstanceServiceResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateInstanceService not implemented")
}
func (UnimplementedHpcACServer) GetImageList(context.Context, *GetImageListReq) (*GetImageListResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetImageList not implemented")
}
func (UnimplementedHpcACServer) mustEmbedUnimplementedHpcACServer() {}

// UnsafeHpcACServer may be embedded to opt out of forward compatibility for this service.
// Use of this interface is not recommended, as added methods to HpcACServer will
// result in compilation errors.
type UnsafeHpcACServer interface {
	mustEmbedUnimplementedHpcACServer()
}

func RegisterHpcACServer(s grpc.ServiceRegistrar, srv HpcACServer) {
	s.RegisterService(&HpcAC_ServiceDesc, srv)
}

func _HpcAC_ListJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListJobReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).ListJob(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_ListJob_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).ListJob(ctx, req.(*ListJobReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_ListHistoryJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListHistoryJobReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).ListHistoryJob(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_ListHistoryJob_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).ListHistoryJob(ctx, req.(*ListHistoryJobReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_SubmitJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SubmitJobReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).SubmitJob(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_SubmitJob_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).SubmitJob(ctx, req.(*SubmitJobReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_ListJobManager_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(JobManagerReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).ListJobManager(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_ListJobManager_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).ListJobManager(ctx, req.(*JobManagerReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_GetJobDetail_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(JobDetailReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).GetJobDetail(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_GetJobDetail_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).GetJobDetail(ctx, req.(*JobDetailReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_DeleteJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeleteJobReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).DeleteJob(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_DeleteJob_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).DeleteJob(ctx, req.(*DeleteJobReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_FileContent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(FileDataReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).FileContent(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_FileContent_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).FileContent(ctx, req.(*FileDataReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_SelectQueueByUser_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(QueueReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).SelectQueueByUser(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_SelectQueueByUser_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).SelectQueueByUser(ctx, req.(*QueueReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_QueryQueueDetails_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(QueueReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).QueryQueueDetails(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_QueryQueueDetails_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).QueryQueueDetails(ctx, req.(*QueueReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_QueryUserQuotasLimit_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(QueueReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).QueryUserQuotasLimit(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_QueryUserQuotasLimit_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).QueryUserQuotasLimit(ctx, req.(*QueueReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_ParaStorQuota_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ParaStorQuotaReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).ParaStorQuota(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_ParaStorQuota_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).ParaStorQuota(ctx, req.(*ParaStorQuotaReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_WallTime_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(WallTimeReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).WallTime(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_WallTime_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).WallTime(ctx, req.(*WallTimeReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_QueueJobs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(QueueJobsReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).QueueJobs(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_QueueJobs_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).QueueJobs(ctx, req.(*QueueJobsReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_CpuCore_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CpuCoreReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).CpuCore(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_CpuCore_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).CpuCore(ctx, req.(*CpuCoreReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_Jobs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(JobsReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).Jobs(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_Jobs_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).Jobs(ctx, req.(*JobsReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_HistoryJobDetail_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(HistoryJobDetailReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).HistoryJobDetail(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_HistoryJobDetail_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).HistoryJobDetail(ctx, req.(*HistoryJobDetailReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_GetACToken_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ACTokenReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).GetACToken(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_GetACToken_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).GetACToken(ctx, req.(*ACTokenReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_GetACClusterId_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ACClusterReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).GetACClusterId(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_GetACClusterId_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).GetACClusterId(ctx, req.(*ACClusterReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_GetComputingPower_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ResourceReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).GetComputingPower(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_GetComputingPower_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).GetComputingPower(ctx, req.(*ResourceReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_GetGeneralInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ResourceReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).GetGeneralInfo(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_GetGeneralInfo_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).GetGeneralInfo(ctx, req.(*ResourceReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_SubmitPytorchTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SubmitPytorchTaskReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).SubmitPytorchTask(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_SubmitPytorchTask_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).SubmitPytorchTask(ctx, req.(*SubmitPytorchTaskReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_SubmitTensorflowTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SubmitTensorflowTaskReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).SubmitTensorflowTask(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_SubmitTensorflowTask_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).SubmitTensorflowTask(ctx, req.(*SubmitTensorflowTaskReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_GetImageListAi_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetImageListAiReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).GetImageListAi(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_GetImageListAi_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).GetImageListAi(ctx, req.(*GetImageListAiReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_GetImageAiById_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetImageAiByIdReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).GetImageAiById(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_GetImageAiById_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).GetImageAiById(ctx, req.(*GetImageAiByIdReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_GetPytorchTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetPytorchTaskReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).GetPytorchTask(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_GetPytorchTask_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).GetPytorchTask(ctx, req.(*GetPytorchTaskReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_GetTensorflowTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetTensorflowTaskReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).GetTensorflowTask(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_GetTensorflowTask_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).GetTensorflowTask(ctx, req.(*GetTensorflowTaskReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_DeleteTaskAi_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeleteTaskAiReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).DeleteTaskAi(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_DeleteTaskAi_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).DeleteTaskAi(ctx, req.(*DeleteTaskAiReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_StopTaskAi_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(StopTaskAiReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).StopTaskAi(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_StopTaskAi_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).StopTaskAi(ctx, req.(*StopTaskAiReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_GetResourceSpec_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetResourceSpecReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).GetResourceSpec(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_GetResourceSpec_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).GetResourceSpec(ctx, req.(*GetResourceSpecReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_GetInstanceLog_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetInstanceLogReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).GetInstanceLog(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_GetInstanceLog_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).GetInstanceLog(ctx, req.(*GetInstanceLogReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_GetInstanceListAi_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetInstanceListReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).GetInstanceListAi(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_GetInstanceListAi_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).GetInstanceListAi(ctx, req.(*GetInstanceListReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_GetInferUrl_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetInferUrlReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).GetInferUrl(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_GetInferUrl_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).GetInferUrl(ctx, req.(*GetInferUrlReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_GetFileList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetFileListReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).GetFileList(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_GetFileList_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).GetFileList(ctx, req.(*GetFileListReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_GetFile_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetFileReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).GetFile(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_GetFile_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).GetFile(ctx, req.(*GetFileReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_UploadFile_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UploadFileReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).UploadFile(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_UploadFile_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).UploadFile(ctx, req.(*UploadFileReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_IsExistFile_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(IsExistFileReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).IsExistFile(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_IsExistFile_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).IsExistFile(ctx, req.(*IsExistFileReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_GetUserInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetUserInfoReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).GetUserInfo(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_GetUserInfo_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).GetUserInfo(ctx, req.(*GetUserInfoReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_GetMemberJobs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetMemberJobsReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).GetMemberJobs(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_GetMemberJobs_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).GetMemberJobs(ctx, req.(*GetMemberJobsReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_GetNodeResources_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetNodeResourcesReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).GetNodeResources(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_GetNodeResources_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).GetNodeResources(ctx, req.(*GetNodeResourcesReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_GetInstanceServiceList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetInstanceServiceListReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).GetInstanceServiceList(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_GetInstanceServiceList_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).GetInstanceServiceList(ctx, req.(*GetInstanceServiceListReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_GetInstanceServiceDetail_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetInstanceServiceDetailReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).GetInstanceServiceDetail(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_GetInstanceServiceDetail_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).GetInstanceServiceDetail(ctx, req.(*GetInstanceServiceDetailReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_StartInstanceService_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(StartInstanceServiceReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).StartInstanceService(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_StartInstanceService_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).StartInstanceService(ctx, req.(*StartInstanceServiceReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_StopInstanceService_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(StopInstanceServiceReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).StopInstanceService(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_StopInstanceService_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).StopInstanceService(ctx, req.(*StopInstanceServiceReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_CreateInstanceService_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateInstanceServiceReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).CreateInstanceService(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_CreateInstanceService_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).CreateInstanceService(ctx, req.(*CreateInstanceServiceReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _HpcAC_GetImageList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetImageListReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(HpcACServer).GetImageList(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: HpcAC_GetImageList_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(HpcACServer).GetImageList(ctx, req.(*GetImageListReq))
	}
	return interceptor(ctx, in, info, handler)
}

// HpcAC_ServiceDesc is the grpc.ServiceDesc for HpcAC service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var HpcAC_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "hpcAC.hpcAC",
	HandlerType: (*HpcACServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListJob",
			Handler:    _HpcAC_ListJob_Handler,
		},
		{
			MethodName: "ListHistoryJob",
			Handler:    _HpcAC_ListHistoryJob_Handler,
		},
		{
			MethodName: "SubmitJob",
			Handler:    _HpcAC_SubmitJob_Handler,
		},
		{
			MethodName: "ListJobManager",
			Handler:    _HpcAC_ListJobManager_Handler,
		},
		{
			MethodName: "GetJobDetail",
			Handler:    _HpcAC_GetJobDetail_Handler,
		},
		{
			MethodName: "DeleteJob",
			Handler:    _HpcAC_DeleteJob_Handler,
		},
		{
			MethodName: "FileContent",
			Handler:    _HpcAC_FileContent_Handler,
		},
		{
			MethodName: "SelectQueueByUser",
			Handler:    _HpcAC_SelectQueueByUser_Handler,
		},
		{
			MethodName: "QueryQueueDetails",
			Handler:    _HpcAC_QueryQueueDetails_Handler,
		},
		{
			MethodName: "QueryUserQuotasLimit",
			Handler:    _HpcAC_QueryUserQuotasLimit_Handler,
		},
		{
			MethodName: "ParaStorQuota",
			Handler:    _HpcAC_ParaStorQuota_Handler,
		},
		{
			MethodName: "WallTime",
			Handler:    _HpcAC_WallTime_Handler,
		},
		{
			MethodName: "QueueJobs",
			Handler:    _HpcAC_QueueJobs_Handler,
		},
		{
			MethodName: "CpuCore",
			Handler:    _HpcAC_CpuCore_Handler,
		},
		{
			MethodName: "jobs",
			Handler:    _HpcAC_Jobs_Handler,
		},
		{
			MethodName: "HistoryJobDetail",
			Handler:    _HpcAC_HistoryJobDetail_Handler,
		},
		{
			MethodName: "GetACToken",
			Handler:    _HpcAC_GetACToken_Handler,
		},
		{
			MethodName: "GetACClusterId",
			Handler:    _HpcAC_GetACClusterId_Handler,
		},
		{
			MethodName: "GetComputingPower",
			Handler:    _HpcAC_GetComputingPower_Handler,
		},
		{
			MethodName: "GetGeneralInfo",
			Handler:    _HpcAC_GetGeneralInfo_Handler,
		},
		{
			MethodName: "SubmitPytorchTask",
			Handler:    _HpcAC_SubmitPytorchTask_Handler,
		},
		{
			MethodName: "SubmitTensorflowTask",
			Handler:    _HpcAC_SubmitTensorflowTask_Handler,
		},
		{
			MethodName: "GetImageListAi",
			Handler:    _HpcAC_GetImageListAi_Handler,
		},
		{
			MethodName: "GetImageAiById",
			Handler:    _HpcAC_GetImageAiById_Handler,
		},
		{
			MethodName: "GetPytorchTask",
			Handler:    _HpcAC_GetPytorchTask_Handler,
		},
		{
			MethodName: "GetTensorflowTask",
			Handler:    _HpcAC_GetTensorflowTask_Handler,
		},
		{
			MethodName: "DeleteTaskAi",
			Handler:    _HpcAC_DeleteTaskAi_Handler,
		},
		{
			MethodName: "StopTaskAi",
			Handler:    _HpcAC_StopTaskAi_Handler,
		},
		{
			MethodName: "GetResourceSpec",
			Handler:    _HpcAC_GetResourceSpec_Handler,
		},
		{
			MethodName: "GetInstanceLog",
			Handler:    _HpcAC_GetInstanceLog_Handler,
		},
		{
			MethodName: "GetInstanceListAi",
			Handler:    _HpcAC_GetInstanceListAi_Handler,
		},
		{
			MethodName: "GetInferUrl",
			Handler:    _HpcAC_GetInferUrl_Handler,
		},
		{
			MethodName: "GetFileList",
			Handler:    _HpcAC_GetFileList_Handler,
		},
		{
			MethodName: "GetFile",
			Handler:    _HpcAC_GetFile_Handler,
		},
		{
			MethodName: "UploadFile",
			Handler:    _HpcAC_UploadFile_Handler,
		},
		{
			MethodName: "IsExistFile",
			Handler:    _HpcAC_IsExistFile_Handler,
		},
		{
			MethodName: "GetUserInfo",
			Handler:    _HpcAC_GetUserInfo_Handler,
		},
		{
			MethodName: "GetMemberJobs",
			Handler:    _HpcAC_GetMemberJobs_Handler,
		},
		{
			MethodName: "GetNodeResources",
			Handler:    _HpcAC_GetNodeResources_Handler,
		},
		{
			MethodName: "GetInstanceServiceList",
			Handler:    _HpcAC_GetInstanceServiceList_Handler,
		},
		{
			MethodName: "GetInstanceServiceDetail",
			Handler:    _HpcAC_GetInstanceServiceDetail_Handler,
		},
		{
			MethodName: "StartInstanceService",
			Handler:    _HpcAC_StartInstanceService_Handler,
		},
		{
			MethodName: "StopInstanceService",
			Handler:    _HpcAC_StopInstanceService_Handler,
		},
		{
			MethodName: "CreateInstanceService",
			Handler:    _HpcAC_CreateInstanceService_Handler,
		},
		{
			MethodName: "GetImageList",
			Handler:    _HpcAC_GetImageList_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "hpcAC.proto",
}