JointCloud
/
pcm-coordinator
Not watched
1
0
Fork 0
Code
Releases 0 Wiki evaluate Activity
Issues 0 Pull Requests 0 Datasets Model Cloudbrain HPC
You can not select more than 25 topics Topics must start with a chinese character,a letter or number, can include dashes ('-') and can be up to 35 characters long.
Tree: e72008043f
Branches Tags
${ item.name }
Create branch ${ searchTerm }
from 'e72008043f'
${ noResults }
pcm-coordinator/adaptor/PCM-HPC/PCM-AC/rpc/pb/hpcAC.proto

622 lines
32 kB
Raw Blame History 

  1. syntax = "proto3";

  2. 

  3. package hpcAC;

  4. option go_package = "/hpcAC";

  5. 

  6. /******************Cluster Start*************************/

  7. message JobManager{

  8.   string  job_manager_type = 1;  // @gotags: copier:"JobManagerType", json:"JobManagerType"

  9.   string  job_manager_addr = 2;  // @gotags: copier:"JobManagerAddr", json:"JobManagerAddr"

  10.   int64   id = 3;  // @gotags: copier:"ID", json:"id"

  11.   string  text = 4;  // @gotags: copier:"Text", json:"text"

  12.   string  job_manager_port = 5;  // @gotags: copier:"JobManagerPort", json:"JobManagerPort"

  13. }

  14. 

  15. message JobManagerReq{

  16. }

  17. 

  18. message ListJobManagerResp{

  19.   string              code = 1;   // @gotags: copier:"Code", json:"code"

  20.   string              msg = 2;   // @gotags: copier:"Msg", json:"msg"

  21.   repeated JobManager data = 3;   // @gotags: copier:"JobManagers", json:"data"

  22. }

  23. /******************Cluster End*************************/

  24. 

  25. /******************Job Detail Start*************************/

  26. message JobInitAttr {

  27.   string  account = 1;    // @gotags: copier:"Account", json:"Account"

  28.   string  accrue_time = 2;    // @gotags: copier:"AccrueTime", json:"AccrueTime"

  29.   string  alloc_node_sid = 3;    // @gotags: copier:"AllocNode:Sid", json:"AllocNode:Sid"

  30.   string  batch_flag = 4;    // @gotags: copier:"BatchFlag", json:"BatchFlag"

  31.   string  cpus_task = 5;    // @gotags: copier:"CPUs/Task", json:"CPUs/Task"

  32.   string  command = 6;    // @gotags: copier:"Command", json:"Command"

  33.   string  command_exist = 7;    // @gotags: copier:"CommandExist", json:"CommandExist"

  34.   string  comment = 8;    // @gotags: copier:"Comment", json:"Comment"

  35.   string  contiguous = 9;    // @gotags: copier:"Contiguous", json:"Contiguous"

  36.   string  core_spec = 10;   // @gotags: copier:"CoreSpec", json:"CoreSpec"

  37.   string  deadline = 11;   // @gotags: copier:"Deadline", json:"Deadline"

  38.   string  delay_boot = 12;   // @gotags: copier:"DelayBoot", json:"DelayBoot"

  39.   string  dependency = 13;   // @gotags: copier:"Dependency", json:"Dependency"

  40.   string  eligible_time = 14;   // @gotags: copier:"EligibleTime", json:"EligibleTime"

  41.   string  end_time = 15;   // @gotags: copier:"EndTime", json:"EndTime"

  42.   string  exc_node_list = 16;   // @gotags: copier:"ExcNodeList", json:"ExcNodeList"

  43.   string  exit_code = 17;   // @gotags: copier:"ExitCode", json:"ExitCode"

  44.   string  features = 18;   // @gotags: copier:"Features", json:"Features"

  45.   string  group_id = 19;   // @gotags: copier:"GroupId", json:"GroupId"

  46.   string  job_id = 20;   // @gotags: copier:"JobId", json:"JobId"

  47.   string  job_name = 21;   // @gotags: copier:"JobName", json:"JobName"

  48.   string  job_state = 22;   // @gotags: copier:"JobState", json:"JobState"

  49.   string  licenses = 23;   // @gotags: copier:"Licenses", json:"Licenses"

  50.   string  mcs_label = 24;   // @gotags: copier:"MCS_label", json:"MCS_label"

  51.   string  min_cpus_node = 25;   // @gotags: copier:"MinCPUsNode", json:"MinCPUsNode"

  52.   string  min_tmp_disk_node = 26;   // @gotags: copier:"MinTmpDiskNode", json:"MinTmpDiskNode"

  53.   string  network = 27;   // @gotags: copier:"Network", json:"Network"

  54.   string  nice = 28;   // @gotags: copier:"Nice", json:"Nice"

  55.   string  node_list = 29;   // @gotags: copier:"NodeList", json:"NodeList"

  56.   string  ntasks_per_nbsc = 30;   // @gotags: copier:"NtasksPerN:B:S:C", json:"NtasksPerN:B:S:C"

  57.   string  num_cpus = 31;   // @gotags: copier:"NumCPUs", json:"NumCPUs"

  58.   string  num_nodes = 32;   // @gotags: copier:"NumNodes", json:"NumNodes"

  59.   string  num_tasks = 33;   // @gotags: copier:"NumTasks", json:"NumTasks"

  60.   string  over_subscribe = 34;   // @gotags: copier:"OverSubscribe", json:"OverSubscribe"

  61.   string  partition = 35;   // @gotags: copier:"Partition", json:"Partition"

  62.   string  power = 36;   // @gotags: copier:"Power", json:"Power"

  63.   string  priority = 37;   // @gotags: copier:"Priority", json:"Priority"

  64.   string  qos = 38;   // @gotags: copier:"QOS", json:"QOS"

  65.   string  reason = 39;   // @gotags: copier:"Reason", json:"Reason"

  66.   string  reboot = 40;   // @gotags: copier:"Reboot", json:"Reboot"

  67.   string  req_bsct = 41;   // @gotags: copier:"ReqB:S:C:T", json:"ReqB:S:C:T"

  68.   string  ReqNodeList = 42;   // @gotags: copier:"ReqNodeList", json:"ReqNodeList"

  69.   string  requeue = 43;   // @gotags: copier:"Requeue", json:"Requeue"

  70.   string  restarts = 44;   // @gotags: copier:"Restarts", json:"Restarts"

  71.   string  run_time = 45;   // @gotags: copier:"RunTime", json:"RunTime"

  72.   string  batch_host = 46;   // @gotags: copier:"BatchHost", json:"BatchHost"

  73.   string  secs_pre_suspend = 47;   // @gotags: copier:"SecsPreSuspend", json:"SecsPreSuspend"

  74.   string  socks_node = 48;   // @gotags: copier:"Socks/Node", json:"Socks/Node"

  75.   string  start_time = 49;   // @gotags: copier:"StartTime", json:"StartTime"

  76.   string  std_err = 50;   // @gotags: copier:"StdErr", json:"StdErr"

  77.   string  std_in = 51;   // @gotags: copier:"StdIn", json:"StdIn"

  78.   string  std_out = 52;   // @gotags: copier:"StdOut", json:"StdOut"

  79.   string  submit_time = 53;   // @gotags: copier:"SubmitTime", json:"SubmitTime"

  80.   string  suspend_time = 54;   // @gotags: copier:"SuspendTime", json:"SuspendTime"

  81.   string  tres = 55;   // @gotags: copier:"TRES", json:"TRES"

  82.   string  time_limit = 56;   // @gotags: copier:"TimeLimit", json:"TimeLimit"

  83.   string  time_min = 57;   // @gotags: copier:"TimeMin", json:"TimeMin"

  84.   string  user_id = 58;   // @gotags: copier:"UserId", json:"UserId"

  85.   string  work_dir = 59;   // @gotags: copier:"WorkDir", json:"WorkDir"

  86. }

  87. 

  88. message JobVncSessionInfo {

  89.   string  archive = 1;    // @gotags: copier:"archive", json:"archive"

  90.   uint32  i_client_number = 2;    // @gotags: copier:"iClientNumber", json:"iClientNumber"

  91.   string  i_pixel_depth = 3;    // @gotags: copier:"iPixelDepth", json:"iPixelDepth"

  92.   string  list_clients = 4;    // @gotags: copier:"listClients", json:"listClients"

  93.   string  locale = 5;    // @gotags: copier:"locale", json:"locale"

  94.   string  loginPasswd = 6;    // @gotags: copier:"loginPasswd", json:"loginPasswd"

  95.   string  map_session_extra_attrs = 7;    // @gotags: copier:"mapSessionExtraAttrs", json:"mapSessionExtraAttrs"

  96.   string  str_auth_type = 8;    // @gotags: copier:"strAuthType", json:"strAuthType"

  97.   string  str_geometry = 9;    // @gotags: copier:"strGeometry", json:"strGeometry"

  98.   string  str_job_manager_addr = 10;   // @gotags: copier:"strJobManagerAddr", json:"strJobManagerAddr"

  99.   string  str_job_manager_id = 11;   // @gotags: copier:"strJobManagerID", json:"strJobManagerID"

  100.   string  str_job_manager_name = 12;   // @gotags: copier:"strJobManagerName", json:"strJobManagerName"

  101.   string  str_relate_job_id = 13;   // @gotags: copier:"strRelateJobID", json:"strRelateJobID"

  102.   string  str_server_addr = 14;   // @gotags: copier:"strServerAddr", json:"strServerAddr"

  103.   string  str_server_name = 15;   // @gotags: copier:"strServerName", json:"strServerName"

  104.   string  str_session_ctime = 16;   // @gotags: copier:"strSessionCTime", json:"strSessionCTime"

  105.   string  str_session_height = 17;   // @gotags: copier:"strSessionHeight", json:"strSessionHeight"

  106.   string  str_session_id = 18;   // @gotags: copier:"strSessionID", json:"strSessionID"

  107.   string  str_session_owner = 19;   // @gotags: copier:"strSessionOwner", json:"strSessionOwner"

  108.   string  str_session_type = 20;   // @gotags: copier:"strSessionType", json:"strSessionType"

  109.   string  str_session_width = 21;   // @gotags: copier:"strSessionWidth", json:"strSessionWidth"

  110.   string  vnc_code = 22;   // @gotags: copier:"vncCode", json:"vncCode"

  111. }

  112. 

  113. message JobDetail{

  114.   string app_type = 1;  // @gotags: copier:"AppType", json:"appType"

  115.   string ave_rss = 2;  // @gotags: copier:"AveRSS", json:"aveRSS"

  116.   string ave_vm_size = 3;  // @gotags: copier:"AveVMSize", json:"aveVMSize"

  117.   string cpu_time_used = 4;  // @gotags: copier:"CpuTimeUsed", json:"cpuTimeUsed"

  118.   uint32 dcu_num_req = 5;  // @gotags: copier:"DcuNumReq", json:"dcuNumReq"

  119.   uint32 dcu_num_used = 6;  // @gotags: copier:"DcuNumUsed", json:"dcuNumUsed"

  120.   string error_path = 7;  // @gotags: copier:"ErrorPath", json:"errorPath"

  121.   string exit_code = 8;  // @gotags: copier:"ExitCode", json:"exitCode"

  122.   uint32 gpu_num_req = 9;  // @gotags: copier:"GpuNumReq", json:"gpuNumReq"

  123.   uint32 gpu_num_used = 10;  // @gotags: copier:"GpuNumUsed", json:"gpuNumUsed"

  124.   string job_end_time = 11;  // @gotags: copier:"JobEndTime", json:"jobEndTime"

  125.   string job_id = 12;  // @gotags: copier:"JobId", json:"jobId"

  126.   JobInitAttr job_init_attr = 13;  // @gotags: copier:"JobInitAttr", json:"JobInitAttr"

  127.   string job_name = 14;  // @gotags: copier:"JobName", json:"jobName"

  128.   string job_run_time = 15;  // @gotags: copier:"JobRunTime", json:"jobRunTime"

  129.   string job_start_time = 16;  // @gotags: copier:"JobStartTime", json:"jobStartTime"

  130.   string job_status = 17;  // @gotags: copier:"JobStatus", json:"jobStatus"

  131.   string job_submit_time = 18;  // @gotags: copier:"JobSubmitTime", json:"jobSubmitTime"

  132.   JobVncSessionInfo job_session_info = 19;  // @gotags: copier:"JobVncSessionInfo", json:"jobVncSessionInfo"

  133.   string job_manager_id = 20;  // @gotags: copier:"JobManagerId", json:"jobmanagerId"

  134.   string job_manager_name = 21;  // @gotags: copier:"JobManagerName", json:"jobmanagerName"

  135.   string job_manager_type = 22;  // @gotags: copier:"JobManagerType", json:"jobmanagerType"

  136.   string mem_used = 23;  // @gotags: copier:"MemUsed", json:"memUsed"

  137.   uint32 node_num_req = 24;  // @gotags: copier:"NodeNumReq", json:"nodeNumReq"

  138.   string node_used = 25;  // @gotags: copier:"NodeUsed", json:"nodeUsed"

  139.   string output_path = 26;  // @gotags: copier:"OutputPath", json:"outputPath"

  140.   string priority = 27;  // @gotags: copier:"Priority", json:"priority"

  141.   uint32 proc_num_req = 28;  // @gotags: copier:"ProcNumReq", json:"procNumReq"

  142.   uint32 proc_num_used = 29;  // @gotags: copier:"procNumUsed", json:"procNumUsed"

  143.   string queue = 30;  // @gotags: copier:"Queue", json:"queue"

  144.   string restarts = 31;  // @gotags: copier:"Restarts", json:"restarts"

  145.   string scale = 32;  // @gotags: copier:"Scale", json:"scale"

  146.   string user = 33;  // @gotags: copier:"User", json:"user"

  147.   string walltime_req = 34;  // @gotags: copier:"WalltimeReq", json:"walltimeReq"

  148.   string work_dir = 35;  // @gotags: copier:"WorkDir", json:"workDir"

  149. }

  150. 

  151. message JobDetailReq{

  152.   string job_id = 1;  // @gotags: copier:"JobId", json:"jobId"

  153. }

  154. 

  155. message GetJobDetailResp{

  156.   string      code = 1;   // @gotags: copier:"Code", json:"code"

  157.   string      msg = 2;   // @gotags: copier:"Msg", json:"msg"

  158.   JobDetail   data = 3;   // @gotags: copier:"data", json:"data"

  159. }

  160. /******************Job Detail End*************************/

  161. 

  162. /******************Job(Delete) Start*************************/

  163. message DeleteJobReq{

  164.   string str_job_info_map = 1;   // @gotags: copier:"strJobInfoMap", json:"strJobInfoMap"

  165. }

  166. 

  167. message DeleteJobResp{

  168.   string                  code = 1;   // @gotags: copier:"Code", json:"code"

  169.   string                  msg = 2;   // @gotags: copier:"Msg", json:"msg"

  170.   map<string, string>     data = 3;   // @gotags: copier:"Result", json:"data"

  171. }

  172. /******************Job(Delete) End*************************/

  173. 

  174. /******************Job Start*************************/

  175. message job{

  176.   string job_id = 1;  // @gotags: copier:"JobId"

  177.   string job_name = 2;  // @gotags: copier:"Name"

  178.   string job_status = 3;  // @gotags: copier:"JobStatus"

  179.   string queue = 4;  // @gotags: copier:"Partition"

  180.   string user = 5;  // @gotags: copier:"UserId"

  181.   string node_used = 6;  // @gotags: copier:"ExcNodes"

  182.   int32  proc_num_used = 7;  // @gotags: copier:"NumCpus"

  183.   string job_start_time = 8;  // @gotags: copier:"StartTime"

  184.   string job_run_time = 9;  // @gotags: copier:"JobRunTime"

  185.   string job_manager_id = 10;  // @gotags: copier:"JobmanagerId"

  186.   string job_manager_name = 11;  // @gotags: copier:"JobmanagerName"

  187.   string job_manager_type = 12;  // @gotags: copier:"JobmanagerType"

  188.   string error_path = 13;  // @gotags: copier:"ErrorPath"

  189.   string output_path = 14;  // @gotags: copier:"OutputPath"

  190.   string work_dir = 15;  // @gotags: copier:"WorkDir"

  191.   string reason = 16;  // @gotags: copier:"Reason"

  192.   string app_type = 17;  // @gotags: copier:"AppType"

  193. }

  194. 

  195. message ListJobReq{

  196. }

  197. 

  198. message ListJobResp{

  199.   uint32       code = 1;  // @gotags: copier:"Code"

  200.   string       msg = 2;  // @gotags: copier:"Msg"

  201.   uint32       record_count = 3;  // @gotags: copier:"RecordCount"

  202.   repeated job jobs = 4;  // @gotags: copier:"Jobs"

  203. }

  204. /******************Job End*************************/

  205. 

  206. 

  207. /******************History Job Start*************************/

  208. 

  209. message ListHistoryJobReq{

  210.   string strClusterNameList = 1; // @gotags: copier:"StrClusterNameList" //调度器ID	示例:1638523853

  211.   string startTime = 2; // @gotags: copier:"StartTime" //开始时间	示例:2021-11-23 01:01:01

  212.   string endTime = 3; // @gotags: copier:"EndTime" //结束时间	示例:2021-12-23 01:01:01

  213.   string timeType = 4; // @gotags: copier:"TimeType" //CUSTOM	示例:CUSTOM

  214.   string queue = 5; // @gotags: copier:"Queue" //队列名称	示例:debug

  215.   string appType = 6; // @gotags: copier:"AppType"  //应用名称	示例:fluent

  216.   string sort = 7; // @gotags: copier:"Sort"  //排序规则	示例:DESC/ASC

  217.   string orderBy = 8; // @gotags: copier:"OrderBy"  //排序字段	示例:jobId

  218.   string jobId = 9; // @gotags: copier:"JobId" //作业ID	示例:12

  219.   string jobState = 10; // @gotags: copier:"JobState" //'statR(运行)','statQ(排队)','statH(保留)','statS(挂起)','statE(退出)','statC(完成)','statW(等待)','statX(其他)'	示例:statQ

  220.   string hostName = 11; // @gotags: copier:"HostName"  //节点名称	示例:h04r3n07

  221.   string strUser = 12; // @gotags: copier:"StrUser" //用户名称	示例:test

  222.   string jobName = 13; // @gotags: copier:"JobName" //作业名称	示例:STDIN_1208_173644

  223.   int32 start = 14; // @gotags: copier:"Start" //起始坐标	示例:0

  224.   int32 limit = 15; // @gotags: copier:"Limit"  //请求一次获取数据的数目	示例:25

  225.   string isQueryByQueueTime = 16; // @gotags: copier:"IsQueryByQueueTime" //按照结束时间查询false/按照入队时间查询true（推荐false）	示例:false

  226. }

  227. 

  228. message ListHistoryJobResp{

  229.   string              code = 1;  // @gotags: copier:"Code"

  230.   string              msg = 2;  // @gotags: copier:"Msg"

  231.   HistoryJobData data = 4;  // @gotags: copier:"Data"

  232. }

  233. 

  234. message HistoryJobData {

  235.   int32 total = 1; // @gotags: copier:"Total"

  236.   repeated HistoryJobList list = 2; // @gotags: copier:"List"

  237. }

  238. 

  239. message HistoryJobList {

  240.   string acctTime = 1;   // @gotags: copier:"AcctTime" //记账时间	示例:2021-11-04 18:07:12

  241.   string jobId = 2;  // @gotags: copier:"JobId" //作业id	示例:12

  242.   int32 jobmanagerId = 3;  // @gotags: copier:"JobmanagerId" //区域id	示例:1638523853

  243.   string userName = 4;  // @gotags: copier:"UserName" //用户名	示例:haowj

  244.   string jobName = 5; // @gotags: copier:"JobName" //作业名	示例:FLUENT_1104_181054

  245.   string queue = 6; // @gotags: copier:"Queue" //队列名	示例:debug

  246.   string jobQueueTime = 7; // @gotags: copier:"JobQueueTime" //作业入队列时间	示例:2021-11-04 17:57:34

  247.   string jobStartTime = 8; // @gotags: copier:"JobStartTime" //作业启动时间	示例:2021-11-04 17:57:34

  248.   string jobExecHost = 9; // @gotags: copier:"JobExecHost" //作业执行节点	示例:gv35New248

  249.   int32 nodect = 10; // @gotags: copier:"Nodect" //分配的节点数	示例:1

  250.   string jobEndTime = 11; // @gotags: copier:"JobEndTime" //作业结束时间	示例:2021-11-04 18:07:12

  251.   string jobWalltimeUsed = 12; // @gotags: copier:"JobWalltimeUsed" //作业实际使用的Walltime,单位为秒	示例:0.1606

  252.   string workdir = 13; // @gotags: copier:"Workdir" //工作空间	示例:/public/home/haowj/00-HPC-CASE/FLUENT_1027_105403

  253.   string appType = 14; // @gotags: copier:"AppType" //作业应用类型	示例:FLUENT

  254.   string jobState = 15; // @gotags: copier:"JobState" //作业状态	示例:statC

  255.   int32 jobExitStatus = 16; // @gotags: copier:"JobExitStatus" //作业退出码	示例:0

  256.   int32 jobProcNum = 17; // @gotags: copier:"JobProcNum" //作业CPU核数	示例:1

  257. }

  258. /******************History Job End*************************/

  259. 

  260. /******************Job(Submit) Start*************************/

  261. message SubmitJobReq{

  262.   string apptype = 1; // @gotags: copier:"Apptype"

  263.   string appname = 2; // @gotags: copier:"Appname"

  264.   int64 strJobManagerID = 3; // @gotags: copier:"StrJobManagerID"

  265.   MapAppJobInfo mapAppJobInfo = 4; // @gotags: copier:"MapAppJobInfo"

  266. }

  267. 

  268. message SubmitJobResp{

  269.   string Code = 1; // @gotags: copier:"Code"

  270.   string Msg = 2; // @gotags: copier:"Msg"

  271.   string Data = 3; // @gotags: copier:"Data"

  272. }

  273. 

  274. message MapAppJobInfo{

  275.   string GAP_CMD_FILE = 1; // @gotags: copier:"GAP_CMD_FILE" //命令行内容

  276.   string GAP_NNODE = 2; // @gotags: copier:"GAP_NNODE" //节点个数（当指定该参数时，GAP_NODE_STRING必须为""）

  277.   string GAP_NODE_STRING = 3; // @gotags: copier:"GAP_NODE_STRING" //指定节点（当指定该参数时，GAP_NNODE必须为""）

  278.   string GAP_SUBMIT_TYPE = 4; // @gotags: copier:"GAP_SUBMIT_TYPE" //cmd（命令行模式）

  279.   string GAP_JOB_NAME = 5; // @gotags: copier:"GAP_JOB_NAME" //作业名称

  280.   string GAP_WORK_DIR = 6; // @gotags: copier:"GAP_WORK_DIR" //工作路径

  281.   string GAP_QUEUE = 7; // @gotags: copier:"GAP_QUEUE" //队列名称

  282.   string GAP_NPROC = 8; // @gotags: copier:"GAP_NPROC" //总核心数（GAP_NPROC和GAP_PPN选其一填写）

  283.   string GAP_PPN = 9; // @gotags: copier:"GAP_PPN" //CPU核心/节点（GAP_NPROC和GAP_PPN选其一填写）

  284.   string GAP_NGPU = 10; // @gotags: copier:"GAP_NGPU" //GPU卡数/节点

  285.   string GAP_NDCU = 11; // @gotags: copier:"GAP_NDCU" //DCU卡数/节点

  286.   string GAP_JOB_MEM = 12; // @gotags: copier:"GAP_JOB_MEM" //每个节点内存值，单位为MB/GB

  287.   string GAP_WALL_TIME = 13; // @gotags: copier:"GAP_WALL_TIME" //最大运行时长（HH:MM:ss）

  288.   string GAP_EXCLUSIVE = 14; // @gotags: copier:"GAP_EXCLUSIVE" // 是否独占节点，1为独占，空为非独占

  289.   string GAP_APPNAME = 15; // @gotags: copier:"GAP_APPNAME" //BASE（基础应用），支持填写具体的应用英文名称

  290.   string GAP_MULTI_SUB = 16; // @gotags: copier:"GAP_MULTI_SUB" //作业组长度，建议为小于等于50的正整数

  291.   string GAP_STD_OUT_FILE = 17; // @gotags: copier:"GAP_STD_OUT_FILE" //工作路径/std.out.%j

  292.   string GAP_STD_ERR_FILE = 18; // @gotags: copier:"GAP_STD_ERR_FILE" //工作路径/std.err.%j

  293. }

  294. /******************Job(Submit) End*************************/

  295. 

  296. message ParaStorQuotaReq{

  297.   string username = 1; // @gotags: copier:"username"

  298. }

  299. 

  300. 

  301. message ParaStorQuotaResp{

  302.   string Code = 1; // @gotags: copier:"Code"

  303.   string Msg = 2; // @gotags: copier:"Msg"

  304.   repeated QuotaData data = 3; // @gotags: copier:"Data"

  305. }

  306. 

  307. message QuotaData{

  308.   string username = 1; // @gotags: copier:"username" //用户名

  309.   string path = 2; // @gotags: copier:"path" //共享存储配额路径

  310.   double threshold = 3; // @gotags: copier:"threshold" //共享存储配额量，单位GB

  311.   double usage = 4; // @gotags: copier:"usage" //共享存储使用量，单位GB

  312. }

  313. 

  314. message WallTimeReq{

  315.   string username = 1; // @gotags: copier:"username"

  316. }

  317. 

  318. message WallTimeResp{

  319.   string Code = 1; // @gotags: copier:"Code"

  320.   string Msg = 2; // @gotags: copier:"Msg"

  321.   double data = 3; // @gotags: copier:"Data"

  322. }

  323. 

  324. message QueueJobsReq{

  325.   string userName = 1;//@gotags: copier:"userName"

  326. }

  327. 

  328. message QueueJobsResp{

  329.   string Code = 1; // @gotags: copier:"Code"

  330.   string Msg = 2; // @gotags: copier:"Msg"

  331.   repeated Queue data = 3; // @gotags: copier:"Data"

  332. }

  333. 

  334. message Queue{

  335.   string name = 1; // @gotags: copier:"name"

  336.   repeated Metric values = 2;// @gotags: copier:"values"

  337. 

  338. }

  339. 

  340. message Metric{

  341.   string metricName = 1;// @gotags: copier:"metricName"

  342.   string metricValue = 2;// @gotags: copier:"metricValue"

  343. }

  344. 

  345. message CpuCoreReq{

  346. 

  347. }

  348. 

  349. message CpuCoreResp{

  350.   string Code = 1; // @gotags: copier:"Code"

  351.   string Msg = 2; // @gotags: copier:"Msg"

  352.   repeated CpuCore data = 3; // @gotags: copier:"data"

  353. }

  354. 

  355. message CpuCore{

  356.   string name = 1; // @gotags: copier:"name"

  357.   int32 y = 2;// @gotags: copier:"y"

  358. }

  359. 

  360. message JobsReq{

  361.   string userName = 1; // @gotags: copier:"userName"

  362. }

  363. 

  364. message JobsResp{

  365.   string Code = 1; // @gotags: copier:"Code"

  366.   string Msg = 2; // @gotags: copier:"Msg"

  367.   repeated JobCore data = 3; // @gotags: copier:"data"

  368. }

  369. 

  370. message JobCore{

  371.   string name = 1; // @gotags: copier:"name"

  372.   int32 y = 2;// @gotags: copier:"y"

  373. }

  374. 

  375. message HistoryJobDetailReq{

  376.   string jobId = 1;

  377.   string jobmanagerId = 2;

  378.   string acctTime = 3;

  379. }

  380. 

  381. message HistoryJobDetail {

  382.   string acctTime = 1;// @gotags: copier:"acctTime"

  383.   string appType = 2;

  384.   string command = 3;

  385.   string commandExist = 4;

  386.   string cpuNuclearHour = 5;

  387.   string cpuNuclearSec = 6;

  388.   double cpuUnitPrice = 7;

  389.   string dcuCardHour = 8;

  390.   string dcuCardSec = 9;

  391.   double dcuUnitPrice = 10;

  392.   string efficiencyCpu = 11;

  393.   int64 exclusiveCputime = 12;

  394.   int64 exclusiveMem = 13;

  395.   int64 exclusiveWalltime = 14;

  396.   string goldenable = 15;

  397.   string gpuCardHour = 16;

  398.   string gpuCardSec = 17;

  399.   double gpuUnitPrice = 18;

  400.   string groupName = 19;

  401.   string historyAccount = 20;

  402.   string historyQueuerate = 21;

  403.   string isSinglejob = 22;

  404.   int64 jobCpuTime = 23;

  405.   int64 jobDcuNum = 24;

  406.   string jobEndTime = 25;

  407.   string jobExecGpus = 26;

  408.   string jobExecHost = 27;

  409.   int64 jobExitStatus = 28;

  410.   int64 jobGpuNum = 29;

  411.   string jobId = 30;

  412.   int64 jobMemUsed = 31;

  413.   string jobName = 32;

  414.   int64 jobProcNum = 33;

  415.   string jobQueueTime = 34;

  416.   double jobReqCpu = 35;

  417.   double jobReqDcu = 36;

  418.   double jobReqGpu = 37;

  419.   string jobReqMem = 38;

  420.   double jobReqNodes = 39;

  421.   int64 jobResponseTime = 40;

  422.   string jobStartTime = 41;

  423.   string jobState = 42;

  424.   int64 jobVmemUsed = 43;

  425.   int64 jobWaitTime = 44;

  426.   int64 jobWalltimeUsed = 45;

  427.   int64 jobmanagerId = 46;

  428.   string jobmanagerName = 47;

  429.   string needNodes = 48;

  430.   int64 nodect = 49;

  431.   string owner = 50;

  432.   string queue = 51;

  433.   string scale = 52;

  434.   int64 shareCputime = 53;

  435.   int64 shareMem = 54;

  436.   int64 shareWalltime = 55;

  437.   string startCount = 56;

  438.   string userName = 57;

  439.   int64 walltime = 58;

  440.   string workdir = 59;

  441. }

  442. 

  443. message HistoryJobDetailResp {

  444.   string code = 1;

  445.   string msg = 2;

  446.   HistoryJobDetail data = 3;

  447. }

  448. 

  449. message FileContentResp{

  450.   string        code = 1;  // @gotags: copier:"Code" //状态码	示例:0

  451.   string        msg = 2;  // @gotags: copier:"Msg" //信息	示例:success

  452.   FileDataResp  data = 3;  // @gotags: copier:"Data" //对象数据

  453. }

  454. 

  455. message FileDataReq{

  456.   string hostName = 1;  // @gotags: copier:"HostName" //服务器hostname	示例:127.0.0.1

  457.   string dirPath = 2; // @gotags: copier:"DirPath" //服务器文件绝对路径		示例:/public/home/test/BASE/STDIN_1210_114429/std.out.22

  458.   int32 triggerNum = 3; // @gotags: copier:"TriggerNum" //翻页次数，第一次打开传1，文件每超过1000行，该参数累加1(类似分页，每页显示1000行数据)	示例:1

  459.   string rollDirection = 4; // @gotags: copier:"RollDirection" //文件查看方向，传参UP，从文件尾向上看；传参DOWN，从文件头向下看 示例:UP

  460. }

  461. 

  462. message FileDataResp{

  463.   int32 allLineTotal = 1; // @gotags: copier:"AllLineTotal" //文件总行数	示例:100

  464.   string success = 2; // @gotags: copier:"Success" //请求是否成功	示例:true

  465.   int32 totalTriggerTimes = 3; // @gotags: copier:"TotalTriggerTimes" //总次数（类似分页总页数）	示例:1

  466.   string errmsg = 4; // @gotags: copier:"Errmsg" //错误信息	示例:false

  467.   string data = 5; // @gotags: copier:"Data" //返回的文件内容	示例:start time is: 2021-10-14

  468. }

  469. 

  470. message QueueReq{

  471.   string user = 1; // @gotags: copier:"User" //用户	示例:test

  472.   string strJobManagerID = 2; // @gotags: copier:"StrJobManagerID" //调度器ID	示例:1626190154

  473. }

  474. 

  475. message QueueResp{

  476.   string code = 1; // @gotags: copier:"Code" //状态码	示例:0

  477.   string msg = 2;   // @gotags: copier:"Msg" //信息	示例:success

  478.   repeated QueueData data = 3; // @gotags: copier:"Data" //队列数组

  479. }

  480. 

  481. message QueueData{

  482.   string aclHosts = 1;  // @gotags: copier:"aclHosts" //可用节点，多个节点用逗号隔开	示例:node1,node2

  483.   string id = 2; // @gotags: copier:"id" //队列名称	示例:debug

  484.   string text = 3; // @gotags: copier:"text" //队列名称	示例:debug

  485.   string queNodes = 4; // @gotags: copier:"queNodes" //队列节点总数	示例:3

  486.   string queMinNodect = 5; // @gotags: copier:"queMinNodect" //队列最小节点数	示例:1

  487.   string queMaxNgpus = 6; // @gotags: copier:"queMaxNgpus" //队列最大GPU卡数	示例:0

  488.   string queMaxPPN = 7; // @gotags: copier:"queMaxPPN" //使用该队列作业最大CPU核心数	示例:4

  489.   string queChargeRate = 8; // @gotags: copier:"queChargeRate" //费率	示例:1

  490.   string queMaxNcpus = 9; // @gotags: copier:"queMaxNcpus" //用户最大可用核心数	示例:4

  491.   string queMaxNdcus = 10; // @gotags: copier:"queMaxNdcus" //队列总DCU卡数	示例:0

  492.   string queueName = 11; // @gotags: copier:"queueName" //队列名称	示例:debug

  493.   string queMinNcpus = 12; // @gotags: copier:"queMinNcpus" //队列最小CPU核数	示例:1

  494.   string queFreeNodes = 13; // @gotags: copier:"queFreeNodes" //队列空闲节点数	示例:1

  495.   string queMaxNodect = 14; // @gotags: copier:"queMaxNodect" //队列作业最大节点数	示例:1

  496.   string queMaxGpuPN = 15; // @gotags: copier:"queMaxGpuPN" //队列单作业最大GPU卡数	示例:0

  497.   string queMaxWalltime = 16; // @gotags: copier:"queMaxWalltime" //队列最大运行时间	示例:unlimit

  498.   string queMaxDcuPN = 17; // @gotags: copier:"queMaxDcuPN" //队列单作业最大DCU卡数	示例:0

  499. }

  500. 

  501. message QueueDetailsResp{

  502.   string code = 1; // @gotags: copier:"Code" //状态码	示例:0

  503.   string msg = 2;   // @gotags: copier:"Msg" //信息	示例:success

  504.   repeated QueueDetailsData data = 3; // @gotags: copier:"Data" //队列数组

  505. }

  506. 

  507. message QueueDetailsData{

  508.   int32 queNodes = 1; // @gotags: copier:"queNodes" //队列节点总数	示例:3

  509.   int32 queMinNodect = 2; // @gotags: copier:"queMinNodect" //队列最小节点数	示例:1

  510.   int32 queMaxNgpus = 3; // @gotags: copier:"queMaxNgpus" //队列最大GPU卡数 示例:0

  511.   int32 queMaxPPN = 4; // @gotags: copier:"queMaxPPN" //使用该队列作业最大CPU核心数 示例:4

  512.   float queChargeRate = 5; // @gotags: copier:"queChargeRate" //费率	示例:1

  513.   int32 queMaxNcpus = 6; // @gotags: copier:"queMaxNcpus" //用户最大可用核心数	示例:4

  514.   int32 queMaxNdcus = 7; // @gotags: copier:"queMaxNdcus" //队列总DCU卡数	示例:0

  515.   string queueName = 8; // @gotags: copier:"queueName" //队列名称	示例:debug

  516.   int32 queMinNcpus = 9; // @gotags: copier:"queMinNcpus" //队列最小CPU核数	示例:1

  517.   int32 queFreeNodes = 10; // @gotags: copier:"queFreeNodes" //队列空闲节点数	示例:1

  518.   int32 queMaxNodect = 11; // @gotags: copier:"queMaxNodect" //队列作业最大节点数	示例:1

  519.   int32 queMaxGpuPN = 12; // @gotags: copier:"queMaxGpuPN" //队列单作业最大GPU卡数	示例:0

  520.   int32 queMaxWalltime = 13; // @gotags: copier:"queMaxWalltime" //队列最大运行时间	示例:unlimit

  521.   int32 queMaxDcuPN = 14; // @gotags: copier:"queMaxDcuPN" //队列单作业最大DCU卡数	示例:0

  522. }

  523. 

  524. message UserQuotasLimitResp{

  525.   string code = 1; // @gotags: copier:"Code" //状态码	示例:0

  526.   string msg = 2;   // @gotags: copier:"Msg" //信息	示例:success

  527.   UserQuotasLimitData data = 3; // @gotags: copier:"Data" //队列数组

  528. }

  529. 

  530. message UserQuotasLimitData{

  531.   string userName = 1; // @gotags: copier:"userName" //用户名称

  532.   string accountName = 2; // @gotags: copier:"accountName" //用户所关联的默认的账号名

  533.   int64 userMaxCpu = 3; // @gotags: copier:"userMaxCpu" //用户最大CPU核数，单位：个,如果未做限制，则值为-1

  534.   int64 userMaxDcu = 4; // @gotags: copier:"userMaxDcu" //用户最大DCU卡数，单位：个,如果未做限制，则值为-1

  535.   int64 userMaxGpu = 5; // @gotags: copier:"userMaxGpu" //用户最大GPU卡数，单位：个,如果未做限制，则值为-1

  536.   int64 userMaxMlu = 6; // @gotags: copier:"userMaxMlu" //用户最大MLU卡数，单位：个,如果未做限制，则值为-1

  537.   int64 userMaxMem = 7; // @gotags: copier:"userMaxMem" //用户最大内存，单位：m,如果未做限制，则值为-1

  538.   int64 userMaxNode = 8; // @gotags: copier:"userMaxNode" //用户最大节点数，单位：个,如果未做限制，则值为-1

  539.   int64 userMaxSubmitJob = 9; // @gotags: copier:"userMaxSubmitJob" //用户最大提交作业数，单位：个,如果未做限制，则值为-1

  540.   int64 userMaxRunJob = 10; // @gotags: copier:"userMaxRunJob" //用户最大运行作业数，单位：个,如果未做限制，则值为-1

  541.   int64 accountMaxCpu = 11; // @gotags: copier:"accountMaxCpu" //账户最大CPU核数，单位：个,如果未做限制，则值为-1

  542.   int64 accountMaxDcu = 12; // @gotags: copier:"accountMaxDcu" //账户最大DCU卡数，单位：个,如果未做限制，则值为-1

  543.   int64 accountMaxGpu = 13; // @gotags: copier:"accountMaxGpu" //账户最大GPU卡数，单位：个,如果未做限制，则值为-1

  544.   int64 accountMaxMlu = 14; // @gotags: copier:"accountMaxMlu" //账户最大MLU卡数，单位：个,如果未做限制，则值为-1

  545.   int64 accountMaxMem = 15; // @gotags: copier:"accountMaxMem" //账户最大内存，单位：m,如果未做限制，则值为-1

  546.   int64 accountMaxNode = 16; // @gotags: copier:"accountMaxNode" //账户最大节点数，单位：个,如果未做限制，则值为-1

  547.   int64 accountMaxSubmitJob = 17; // @gotags: copier:"accountMaxSubmitJob" //账户最大提交作业数，单位：个,如果未做限制，则值为-1

  548.   int64 accountMaxRunJob = 18; // @gotags: copier:"accountMaxRunJob" //账户最大运行作业数，单位：个,如果未做限制，则值为-1

  549.   int64 userMinCpu = 19; // @gotags: copier:"userMinCpu" //用户最小CPU核数，单位：个,如果未做限制，则值为-1

  550.   int64 userMinNode = 20; // @gotags: copier:"userMinNode" //用户最小节点数，单位：个,如果未做限制，则值为-1

  551.   int64 maxWallTime = 21; // @gotags: copier:"maxWallTime" //用户关联的glod账号的机时，机时单位：s,如果未做限制，则值为-1

  552. }

  553. 

  554. message ACAuthReq {

  555.   string user = 1;

  556.   string password = 2;

  557.   string orgId = 3;

  558. }

  559. 

  560. message ACAuthResp {

  561.   string msg = 1;

  562.   string code = 2;

  563.   repeated ACAuthData data = 3;

  564. }

  565. 

  566. message ACAuthData  {

  567.   string clusterName = 1;

  568.   string clusterId = 2;

  569.   string token = 3;

  570. }

  571. 

  572. // HPC Services for AC

  573. service hpcAC {

  574. 

  575.   //ListJob list all jobs

  576.   rpc ListJob(ListJobReq) returns (ListJobResp);

  577. 

  578.   //ListHistoryJob list all history jobs

  579.   rpc ListHistoryJob(ListHistoryJobReq) returns (ListHistoryJobResp);

  580. 

  581.   //Submit job

  582.   rpc SubmitJob(SubmitJobReq) returns (SubmitJobResp);

  583. 

  584.   // ListJobManager list all job managers

  585.   rpc ListJobManager(JobManagerReq) returns (ListJobManagerResp);

  586. 

  587.   // GetJobDetail get job detail

  588.   rpc GetJobDetail(JobDetailReq) returns (GetJobDetailResp);

  589. 

  590.   // DeleteJob delete job

  591.   rpc DeleteJob(DeleteJobReq) returns (DeleteJobResp);

  592. 

  593.   //FileContent 查看文件内容

  594.   rpc FileContent(FileDataReq) returns (FileContentResp);

  595. 

  596.   //SelectQueueByUser 查询用户可访问队列列表

  597.   rpc SelectQueueByUser(QueueReq) returns(QueueResp);

  598. 

  599.   //QueryQueueDetails 查询队列资源详细信息

  600.   rpc QueryQueueDetails(QueueReq) returns(QueueDetailsResp);

  601. 

  602.   ///QueryUserQuotasLimit 查询用户资源限制信息

  603.   rpc QueryUserQuotasLimit(QueueReq) returns(UserQuotasLimitResp);

  604. 

  605.   //ParaStor Quota

  606.   rpc ParaStorQuota(ParaStorQuotaReq) returns (ParaStorQuotaResp);

  607. 

  608.   //WallTime

  609.   rpc WallTime(WallTimeReq) returns (WallTimeResp);

  610. 

  611.   //QueueJobs

  612.   rpc QueueJobs(QueueJobsReq)returns  (QueueJobsResp);

  613. 

  614.   rpc CpuCore(CpuCoreReq) returns (CpuCoreResp);

  615. 

  616.   rpc jobs(JobsReq) returns (JobsResp);

  617. 

  618.   rpc HistoryJobDetail(HistoryJobDetailReq)returns (HistoryJobDetailResp);

  619. 

  620.   // 曙光ac登录认证

  621.   rpc ACAuth(ACAuthReq) returns (ACAuthResp);

  622. }