forked from JointCloud/pcm-hpc
feature:implement cmd commands
This commit is contained in:
zhouqunjie
parent
afbfade87d
commit
19370f12a0
|
|
@ -6,6 +6,7 @@ PcmCoreRpcConf:
|
|||
#- localhost:2004
|
||||
- dev.jointcloud.net:32456
|
||||
NonBlock: true
|
||||
SvcType: cmd
|
||||
RestUrl: http://192.168.249.122:6820
|
||||
SSH:
|
||||
Url: 192.168.249.122:22
|
||||
|
|
|
|||
|
|
@ -51,6 +51,7 @@ type Path struct {
|
|||
// SlurmConf slurm 相关URL配置
|
||||
type SlurmConf struct {
|
||||
RestUrl string `json:"RestUrl"`
|
||||
SvcType string `json:"SvcType"`
|
||||
SSH SSH `json:"SSH"`
|
||||
Path Path `json:"Path"`
|
||||
SlurmRestUser string `json:"SlurmRestUser"`
|
||||
|
|
|
|||
|
|
@ -2,9 +2,12 @@ package logic
|
|||
|
||||
import (
|
||||
"context"
|
||||
"encoding/json"
|
||||
"gitlink.org.cn/jcce-pcm/pcm-slurm/internal/pkg/utils"
|
||||
"gitlink.org.cn/jcce-pcm/pcm-slurm/internal/pkg/utils/httputils"
|
||||
"gitlink.org.cn/jcce-pcm/pcm-slurm/internal/svc"
|
||||
"gitlink.org.cn/jcce-pcm/pcm-slurm/slurm"
|
||||
gossh "golang.org/x/crypto/ssh"
|
||||
|
||||
"github.com/zeromicro/go-zero/core/logx"
|
||||
)
|
||||
|
|
@ -25,16 +28,39 @@ func NewListJobLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ListJobLo
|
|||
|
||||
func (l *ListJobLogic) ListJob(in *slurm.ListJobReq) (*slurm.ListJobResp, error) {
|
||||
var resp slurm.ListJobResp
|
||||
syncTokenLogic := NewSyncTokenLogic(l.ctx, l.svcCtx)
|
||||
_, err := syncTokenLogic.SyncToken(nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
if l.svcCtx.Config.SvcType == "cmd" {
|
||||
cli := utils.Cli{
|
||||
Addr: l.svcCtx.Config.SSH.Url,
|
||||
User: l.svcCtx.Config.SSH.Username,
|
||||
Pwd: l.svcCtx.Config.SSH.Password,
|
||||
}
|
||||
// 建立连接对象
|
||||
cl, _ := cli.Connect()
|
||||
// 退出时关闭连接
|
||||
defer func(Client *gossh.Client) {
|
||||
err := Client.Close()
|
||||
if err != nil {
|
||||
|
||||
}
|
||||
}(cl.Client)
|
||||
res, _ := cl.Run("squeue --json")
|
||||
err := json.Unmarshal([]byte(res), &resp)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
} else {
|
||||
syncTokenLogic := NewSyncTokenLogic(l.ctx, l.svcCtx)
|
||||
_, err := syncTokenLogic.SyncToken(nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
slurmHttpRequest := httputils.GetHttpRequest()
|
||||
slurmHttpRequest.SetHeader(httputils.ContentType, httputils.ApplicationJson).
|
||||
SetHeader("X-SLURM-USER-NAME", l.svcCtx.Config.SlurmRestUser).
|
||||
SetHeader("X-SLURM-USER-TOKEN", l.svcCtx.Config.SlurmToken).SetBody(in).
|
||||
SetResult(&resp).Get(l.svcCtx.Config.RestUrl + l.svcCtx.Config.Path.Jobs)
|
||||
}
|
||||
|
||||
slurmHttpRequest := httputils.GetHttpRequest()
|
||||
slurmHttpRequest.SetHeader(httputils.ContentType, httputils.ApplicationJson).
|
||||
SetHeader("X-SLURM-USER-NAME", l.svcCtx.Config.SlurmRestUser).
|
||||
SetHeader("X-SLURM-USER-TOKEN", l.svcCtx.Config.SlurmToken).SetBody(in).
|
||||
SetResult(&resp).Get(l.svcCtx.Config.RestUrl + l.svcCtx.Config.Path.Jobs)
|
||||
return &resp, nil
|
||||
}
|
||||
|
|
|
|||
|
|
@ -2,7 +2,10 @@ package logic
|
|||
|
||||
import (
|
||||
"context"
|
||||
"fmt"
|
||||
"gitlink.org.cn/jcce-pcm/pcm-slurm/internal/pkg/utils"
|
||||
"gitlink.org.cn/jcce-pcm/pcm-slurm/internal/pkg/utils/httputils"
|
||||
gossh "golang.org/x/crypto/ssh"
|
||||
|
||||
"gitlink.org.cn/jcce-pcm/pcm-slurm/internal/svc"
|
||||
"gitlink.org.cn/jcce-pcm/pcm-slurm/slurm"
|
||||
|
|
@ -26,17 +29,37 @@ func NewSubmitJobLogic(ctx context.Context, svcCtx *svc.ServiceContext) *SubmitJ
|
|||
|
||||
func (l *SubmitJobLogic) SubmitJob(in *slurm.SubmitJobReq) (*slurm.SubmitJobResp, error) {
|
||||
var submitJobResp slurm.SubmitJobResp
|
||||
syncTokenLogic := NewSyncTokenLogic(l.ctx, l.svcCtx)
|
||||
_, err := syncTokenLogic.SyncToken(nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
if l.svcCtx.Config.SvcType == "cmd" {
|
||||
cli := utils.Cli{
|
||||
Addr: l.svcCtx.Config.SSH.Url,
|
||||
User: l.svcCtx.Config.SSH.Username,
|
||||
Pwd: l.svcCtx.Config.SSH.Password,
|
||||
}
|
||||
// 建立连接对象
|
||||
cl, _ := cli.Connect()
|
||||
// 退出时关闭连接
|
||||
defer func(Client *gossh.Client) {
|
||||
err := Client.Close()
|
||||
if err != nil {
|
||||
|
||||
}
|
||||
}(cl.Client)
|
||||
res, _ := cl.Run(in.Script)
|
||||
fmt.Println(res)
|
||||
} else {
|
||||
syncTokenLogic := NewSyncTokenLogic(l.ctx, l.svcCtx)
|
||||
_, err := syncTokenLogic.SyncToken(nil)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
slurmHttpRequest := httputils.GetHttpRequest()
|
||||
slurmHttpRequest.SetHeader(httputils.ContentType, httputils.ApplicationJson).
|
||||
SetHeader("X-SLURM-USER-NAME", l.svcCtx.Config.SlurmRestUser).
|
||||
SetHeader("X-SLURM-USER-TOKEN", l.svcCtx.Config.SlurmToken).
|
||||
SetBody(in).
|
||||
SetResult(&submitJobResp).Post(l.svcCtx.Config.RestUrl + l.svcCtx.Config.Path.JobSubmit)
|
||||
}
|
||||
|
||||
slurmHttpRequest := httputils.GetHttpRequest()
|
||||
slurmHttpRequest.SetHeader(httputils.ContentType, httputils.ApplicationJson).
|
||||
SetHeader("X-SLURM-USER-NAME", l.svcCtx.Config.SlurmRestUser).
|
||||
SetHeader("X-SLURM-USER-TOKEN", l.svcCtx.Config.SlurmToken).
|
||||
SetBody(in).
|
||||
SetResult(&submitJobResp).Post(l.svcCtx.Config.RestUrl + l.svcCtx.Config.Path.JobSubmit)
|
||||
return &submitJobResp, nil
|
||||
}
|
||||
|
|
|
|||
|
|
@ -8,6 +8,7 @@ import (
|
|||
"gitlink.org.cn/jcce-pcm/pcm-slurm/internal/pkg/utils"
|
||||
"gitlink.org.cn/jcce-pcm/pcm-slurm/internal/svc"
|
||||
"gitlink.org.cn/jcce-pcm/pcm-slurm/slurm"
|
||||
"strconv"
|
||||
)
|
||||
|
||||
func SyncTask(svc *svc.ServiceContext) {
|
||||
|
|
@ -77,7 +78,8 @@ func SyncTask(svc *svc.ServiceContext) {
|
|||
listReq := slurm.ListJobReq{}
|
||||
resp, _ := listLogic.ListJob(&listReq)
|
||||
for _, job := range resp.Jobs {
|
||||
if job.JobId == infoList.HpcInfoList[index].JobId {
|
||||
listId, _ := strconv.Atoi(infoList.HpcInfoList[index].JobId)
|
||||
if job.JobId == int32(listId) {
|
||||
var pcmState = svc.Config.SlurmStatus[job.JobState]
|
||||
if pcmState == "" {
|
||||
infoList.HpcInfoList[index].Status = "Other"
|
||||
|
|
|
|||
104
pb/job.proto
104
pb/job.proto
|
|
@ -90,13 +90,13 @@ message job_properties{
|
|||
//list job response
|
||||
message job_response_properties{
|
||||
string account = 1;
|
||||
uint32 accrue_time = 2;
|
||||
uint64 accrue_time = 2;
|
||||
string admin_comment = 3;
|
||||
string array_job_id = 4;
|
||||
string array_task_id = 5;
|
||||
string array_max_tasks = 6;
|
||||
uint32 array_job_id = 4;
|
||||
uint32 array_task_id = 5;
|
||||
uint32 array_max_tasks = 6;
|
||||
string array_task_string = 7;
|
||||
string association_id = 8;
|
||||
int64 association_id = 8;
|
||||
string batch_features = 9;
|
||||
bool batch_flag = 10;
|
||||
string batch_host = 11;
|
||||
|
|
@ -108,21 +108,21 @@ message job_response_properties{
|
|||
string command = 17;
|
||||
string comment = 18;
|
||||
bool contiguous = 19;
|
||||
string core_spec = 20;
|
||||
string thread_spec = 21;
|
||||
string cores_per_socket = 22;
|
||||
string billable_tres = 23;
|
||||
string cpus_per_task = 24;
|
||||
string cpu_frequency_minimum = 25;
|
||||
string cpu_frequency_maximum = 26;
|
||||
string cpu_frequency_governor = 27;
|
||||
int64 core_spec = 20;
|
||||
int64 thread_spec = 21;
|
||||
uint32 cores_per_socket = 22;
|
||||
float billable_tres = 23;
|
||||
uint32 cpus_per_task = 24;
|
||||
uint32 cpu_frequency_minimum = 25;
|
||||
uint32 cpu_frequency_maximum = 26;
|
||||
uint32 cpu_frequency_governor = 27;
|
||||
string cpus_per_tres = 28;
|
||||
string deadline = 29;
|
||||
string delay_boot = 30;
|
||||
uint64 deadline = 29;
|
||||
uint32 delay_boot = 30;
|
||||
string dependency = 31;
|
||||
string derived_exit_code = 32;
|
||||
uint32 eligible_time = 33;
|
||||
uint32 end_time = 34;
|
||||
uint32 derived_exit_code = 32;
|
||||
uint64 eligible_time = 33;
|
||||
uint64 end_time = 34;
|
||||
string excluded_nodes = 35;
|
||||
uint32 exit_code = 36;
|
||||
string features = 37;
|
||||
|
|
@ -130,60 +130,60 @@ message job_response_properties{
|
|||
string federation_siblings_active = 39;
|
||||
string federation_siblings_viable = 40;
|
||||
repeated string gres_detail = 41;
|
||||
string group_id = 42;
|
||||
string job_id = 43;
|
||||
int32 group_id = 42;
|
||||
int32 job_id = 43;
|
||||
Job_resources job_resources = 44;
|
||||
string job_state = 45;
|
||||
string last_sched_evaluation = 46;
|
||||
uint64 last_sched_evaluation = 46;
|
||||
string licenses = 47;
|
||||
string max_cpus = 48;
|
||||
string max_nodes = 49;
|
||||
uint32 max_cpus = 48;
|
||||
uint32 max_nodes = 49;
|
||||
string mcs_label = 50;
|
||||
string memory_per_tres = 51;
|
||||
string name = 52;
|
||||
string nodes = 53;
|
||||
string nice = 54;
|
||||
string tasks_per_core = 55;
|
||||
string tasks_per_socket = 56;
|
||||
string tasks_per_board = 57;
|
||||
string cpus = 58;
|
||||
string node_count = 59;
|
||||
string tasks = 60;
|
||||
string het_job_id = 61;
|
||||
int32 nice = 54;
|
||||
uint32 tasks_per_core = 55;
|
||||
uint32 tasks_per_socket = 56;
|
||||
uint32 tasks_per_board = 57;
|
||||
uint32 cpus = 58;
|
||||
uint32 node_count = 59;
|
||||
uint32 tasks = 60;
|
||||
int32 het_job_id = 61;
|
||||
string het_job_id_set = 62;
|
||||
string het_job_offset = 63;
|
||||
uint32 het_job_offset = 63;
|
||||
string partition = 64;
|
||||
string memory_per_node = 65;
|
||||
string memory_per_cpu = 66;
|
||||
string minimum_cpus_per_node = 67;
|
||||
string minimum_tmp_disk_per_node = 68;
|
||||
uint32 preempt_time = 69;
|
||||
uint32 pre_sus_time = 70;
|
||||
string priority = 71;
|
||||
uint64 memory_per_node = 65;
|
||||
uint64 memory_per_cpu = 66;
|
||||
uint32 minimum_cpus_per_node = 67;
|
||||
uint32 minimum_tmp_disk_per_node = 68;
|
||||
uint64 preempt_time = 69;
|
||||
uint64 pre_sus_time = 70;
|
||||
uint32 priority = 71;
|
||||
repeated string profile = 72;
|
||||
string qos = 73;
|
||||
bool reboot = 74;
|
||||
string required_nodes = 75;
|
||||
bool requeue = 76;
|
||||
uint32 resize_time = 77;
|
||||
string restart_cnt = 78;
|
||||
uint64 resize_time = 77;
|
||||
int32 restart_cnt = 78;
|
||||
string resv_name = 79;
|
||||
string shared = 80;
|
||||
repeated string show_flags = 81;
|
||||
string sockets_per_board = 82;
|
||||
string sockets_per_node = 83;
|
||||
uint32 start_time = 84;
|
||||
int32 sockets_per_board = 82;
|
||||
uint64 sockets_per_node = 83;
|
||||
uint64 start_time = 84;
|
||||
string state_description = 85;
|
||||
string state_reason = 86;
|
||||
string standard_error = 87;
|
||||
string standard_input = 88;
|
||||
string standard_output = 89;
|
||||
uint32 submit_time = 90;
|
||||
uint32 suspend_time = 91;
|
||||
uint64 submit_time = 90;
|
||||
uint64 suspend_time = 91;
|
||||
string system_comment = 92;
|
||||
string time_limit = 93;
|
||||
string time_minimum = 94;
|
||||
string threads_per_core = 95;
|
||||
uint32 time_limit = 93;
|
||||
uint32 time_minimum = 94;
|
||||
uint32 threads_per_core = 95;
|
||||
string tres_bind = 96;
|
||||
string tres_freq = 97;
|
||||
string tres_per_job = 98;
|
||||
|
|
@ -192,7 +192,7 @@ message job_response_properties{
|
|||
string tres_per_task = 101;
|
||||
string tres_req_str = 102;
|
||||
string tres_alloc_str = 103;
|
||||
string user_id = 104;
|
||||
int32 user_id = 104;
|
||||
string user_name = 105;
|
||||
string wckey = 106;
|
||||
string current_working_directory = 107;
|
||||
|
|
@ -203,7 +203,7 @@ message Jobs {
|
|||
string account = 1;
|
||||
uint32 accrue_time = 2;
|
||||
string admin_comment = 3;
|
||||
string array_job_id = 4;
|
||||
int32 array_job_id = 4;
|
||||
string array_task_id = 5;
|
||||
string array_max_tasks = 6;
|
||||
string array_task_string = 7;
|
||||
|
|
@ -222,7 +222,7 @@ message Jobs {
|
|||
string core_spec = 20;
|
||||
string thread_spec = 21;
|
||||
string cores_per_socket = 22;
|
||||
string billable_tres = 23;
|
||||
float billable_tres = 23;
|
||||
string cpus_per_task = 24;
|
||||
string cpu_frequency_minimum = 25;
|
||||
string cpu_frequency_maximum = 26;
|
||||
|
|
|
|||
398
slurm/job.pb.go
398
slurm/job.pb.go
|
|
@ -706,13 +706,13 @@ type JobResponseProperties struct {
|
|||
unknownFields protoimpl.UnknownFields
|
||||
|
||||
Account string `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty"`
|
||||
AccrueTime uint32 `protobuf:"varint,2,opt,name=accrue_time,json=accrueTime,proto3" json:"accrue_time,omitempty"`
|
||||
AccrueTime uint64 `protobuf:"varint,2,opt,name=accrue_time,json=accrueTime,proto3" json:"accrue_time,omitempty"`
|
||||
AdminComment string `protobuf:"bytes,3,opt,name=admin_comment,json=adminComment,proto3" json:"admin_comment,omitempty"`
|
||||
ArrayJobId string `protobuf:"bytes,4,opt,name=array_job_id,json=arrayJobId,proto3" json:"array_job_id,omitempty"`
|
||||
ArrayTaskId string `protobuf:"bytes,5,opt,name=array_task_id,json=arrayTaskId,proto3" json:"array_task_id,omitempty"`
|
||||
ArrayMaxTasks string `protobuf:"bytes,6,opt,name=array_max_tasks,json=arrayMaxTasks,proto3" json:"array_max_tasks,omitempty"`
|
||||
ArrayJobId uint32 `protobuf:"varint,4,opt,name=array_job_id,json=arrayJobId,proto3" json:"array_job_id,omitempty"`
|
||||
ArrayTaskId uint32 `protobuf:"varint,5,opt,name=array_task_id,json=arrayTaskId,proto3" json:"array_task_id,omitempty"`
|
||||
ArrayMaxTasks uint32 `protobuf:"varint,6,opt,name=array_max_tasks,json=arrayMaxTasks,proto3" json:"array_max_tasks,omitempty"`
|
||||
ArrayTaskString string `protobuf:"bytes,7,opt,name=array_task_string,json=arrayTaskString,proto3" json:"array_task_string,omitempty"`
|
||||
AssociationId string `protobuf:"bytes,8,opt,name=association_id,json=associationId,proto3" json:"association_id,omitempty"`
|
||||
AssociationId int64 `protobuf:"varint,8,opt,name=association_id,json=associationId,proto3" json:"association_id,omitempty"`
|
||||
BatchFeatures string `protobuf:"bytes,9,opt,name=batch_features,json=batchFeatures,proto3" json:"batch_features,omitempty"`
|
||||
BatchFlag bool `protobuf:"varint,10,opt,name=batch_flag,json=batchFlag,proto3" json:"batch_flag,omitempty"`
|
||||
BatchHost string `protobuf:"bytes,11,opt,name=batch_host,json=batchHost,proto3" json:"batch_host,omitempty"`
|
||||
|
|
@ -724,21 +724,21 @@ type JobResponseProperties struct {
|
|||
Command string `protobuf:"bytes,17,opt,name=command,proto3" json:"command,omitempty"`
|
||||
Comment string `protobuf:"bytes,18,opt,name=comment,proto3" json:"comment,omitempty"`
|
||||
Contiguous bool `protobuf:"varint,19,opt,name=contiguous,proto3" json:"contiguous,omitempty"`
|
||||
CoreSpec string `protobuf:"bytes,20,opt,name=core_spec,json=coreSpec,proto3" json:"core_spec,omitempty"`
|
||||
ThreadSpec string `protobuf:"bytes,21,opt,name=thread_spec,json=threadSpec,proto3" json:"thread_spec,omitempty"`
|
||||
CoresPerSocket string `protobuf:"bytes,22,opt,name=cores_per_socket,json=coresPerSocket,proto3" json:"cores_per_socket,omitempty"`
|
||||
BillableTres string `protobuf:"bytes,23,opt,name=billable_tres,json=billableTres,proto3" json:"billable_tres,omitempty"`
|
||||
CpusPerTask string `protobuf:"bytes,24,opt,name=cpus_per_task,json=cpusPerTask,proto3" json:"cpus_per_task,omitempty"`
|
||||
CpuFrequencyMinimum string `protobuf:"bytes,25,opt,name=cpu_frequency_minimum,json=cpuFrequencyMinimum,proto3" json:"cpu_frequency_minimum,omitempty"`
|
||||
CpuFrequencyMaximum string `protobuf:"bytes,26,opt,name=cpu_frequency_maximum,json=cpuFrequencyMaximum,proto3" json:"cpu_frequency_maximum,omitempty"`
|
||||
CpuFrequencyGovernor string `protobuf:"bytes,27,opt,name=cpu_frequency_governor,json=cpuFrequencyGovernor,proto3" json:"cpu_frequency_governor,omitempty"`
|
||||
CoreSpec int64 `protobuf:"varint,20,opt,name=core_spec,json=coreSpec,proto3" json:"core_spec,omitempty"`
|
||||
ThreadSpec int64 `protobuf:"varint,21,opt,name=thread_spec,json=threadSpec,proto3" json:"thread_spec,omitempty"`
|
||||
CoresPerSocket uint32 `protobuf:"varint,22,opt,name=cores_per_socket,json=coresPerSocket,proto3" json:"cores_per_socket,omitempty"`
|
||||
BillableTres float32 `protobuf:"fixed32,23,opt,name=billable_tres,json=billableTres,proto3" json:"billable_tres,omitempty"`
|
||||
CpusPerTask uint32 `protobuf:"varint,24,opt,name=cpus_per_task,json=cpusPerTask,proto3" json:"cpus_per_task,omitempty"`
|
||||
CpuFrequencyMinimum uint32 `protobuf:"varint,25,opt,name=cpu_frequency_minimum,json=cpuFrequencyMinimum,proto3" json:"cpu_frequency_minimum,omitempty"`
|
||||
CpuFrequencyMaximum uint32 `protobuf:"varint,26,opt,name=cpu_frequency_maximum,json=cpuFrequencyMaximum,proto3" json:"cpu_frequency_maximum,omitempty"`
|
||||
CpuFrequencyGovernor uint32 `protobuf:"varint,27,opt,name=cpu_frequency_governor,json=cpuFrequencyGovernor,proto3" json:"cpu_frequency_governor,omitempty"`
|
||||
CpusPerTres string `protobuf:"bytes,28,opt,name=cpus_per_tres,json=cpusPerTres,proto3" json:"cpus_per_tres,omitempty"`
|
||||
Deadline string `protobuf:"bytes,29,opt,name=deadline,proto3" json:"deadline,omitempty"`
|
||||
DelayBoot string `protobuf:"bytes,30,opt,name=delay_boot,json=delayBoot,proto3" json:"delay_boot,omitempty"`
|
||||
Deadline uint64 `protobuf:"varint,29,opt,name=deadline,proto3" json:"deadline,omitempty"`
|
||||
DelayBoot uint32 `protobuf:"varint,30,opt,name=delay_boot,json=delayBoot,proto3" json:"delay_boot,omitempty"`
|
||||
Dependency string `protobuf:"bytes,31,opt,name=dependency,proto3" json:"dependency,omitempty"`
|
||||
DerivedExitCode string `protobuf:"bytes,32,opt,name=derived_exit_code,json=derivedExitCode,proto3" json:"derived_exit_code,omitempty"`
|
||||
EligibleTime uint32 `protobuf:"varint,33,opt,name=eligible_time,json=eligibleTime,proto3" json:"eligible_time,omitempty"`
|
||||
EndTime uint32 `protobuf:"varint,34,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
|
||||
DerivedExitCode uint32 `protobuf:"varint,32,opt,name=derived_exit_code,json=derivedExitCode,proto3" json:"derived_exit_code,omitempty"`
|
||||
EligibleTime uint64 `protobuf:"varint,33,opt,name=eligible_time,json=eligibleTime,proto3" json:"eligible_time,omitempty"`
|
||||
EndTime uint64 `protobuf:"varint,34,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
|
||||
ExcludedNodes string `protobuf:"bytes,35,opt,name=excluded_nodes,json=excludedNodes,proto3" json:"excluded_nodes,omitempty"`
|
||||
ExitCode uint32 `protobuf:"varint,36,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
|
||||
Features string `protobuf:"bytes,37,opt,name=features,proto3" json:"features,omitempty"`
|
||||
|
|
@ -746,60 +746,60 @@ type JobResponseProperties struct {
|
|||
FederationSiblingsActive string `protobuf:"bytes,39,opt,name=federation_siblings_active,json=federationSiblingsActive,proto3" json:"federation_siblings_active,omitempty"`
|
||||
FederationSiblingsViable string `protobuf:"bytes,40,opt,name=federation_siblings_viable,json=federationSiblingsViable,proto3" json:"federation_siblings_viable,omitempty"`
|
||||
GresDetail []string `protobuf:"bytes,41,rep,name=gres_detail,json=gresDetail,proto3" json:"gres_detail,omitempty"`
|
||||
GroupId string `protobuf:"bytes,42,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
|
||||
JobId string `protobuf:"bytes,43,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
|
||||
GroupId int32 `protobuf:"varint,42,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
|
||||
JobId int32 `protobuf:"varint,43,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
|
||||
JobResources *JobResources `protobuf:"bytes,44,opt,name=job_resources,json=jobResources,proto3" json:"job_resources,omitempty"`
|
||||
JobState string `protobuf:"bytes,45,opt,name=job_state,json=jobState,proto3" json:"job_state,omitempty"`
|
||||
LastSchedEvaluation string `protobuf:"bytes,46,opt,name=last_sched_evaluation,json=lastSchedEvaluation,proto3" json:"last_sched_evaluation,omitempty"`
|
||||
LastSchedEvaluation uint64 `protobuf:"varint,46,opt,name=last_sched_evaluation,json=lastSchedEvaluation,proto3" json:"last_sched_evaluation,omitempty"`
|
||||
Licenses string `protobuf:"bytes,47,opt,name=licenses,proto3" json:"licenses,omitempty"`
|
||||
MaxCpus string `protobuf:"bytes,48,opt,name=max_cpus,json=maxCpus,proto3" json:"max_cpus,omitempty"`
|
||||
MaxNodes string `protobuf:"bytes,49,opt,name=max_nodes,json=maxNodes,proto3" json:"max_nodes,omitempty"`
|
||||
MaxCpus uint32 `protobuf:"varint,48,opt,name=max_cpus,json=maxCpus,proto3" json:"max_cpus,omitempty"`
|
||||
MaxNodes uint32 `protobuf:"varint,49,opt,name=max_nodes,json=maxNodes,proto3" json:"max_nodes,omitempty"`
|
||||
McsLabel string `protobuf:"bytes,50,opt,name=mcs_label,json=mcsLabel,proto3" json:"mcs_label,omitempty"`
|
||||
MemoryPerTres string `protobuf:"bytes,51,opt,name=memory_per_tres,json=memoryPerTres,proto3" json:"memory_per_tres,omitempty"`
|
||||
Name string `protobuf:"bytes,52,opt,name=name,proto3" json:"name,omitempty"`
|
||||
Nodes string `protobuf:"bytes,53,opt,name=nodes,proto3" json:"nodes,omitempty"`
|
||||
Nice string `protobuf:"bytes,54,opt,name=nice,proto3" json:"nice,omitempty"`
|
||||
TasksPerCore string `protobuf:"bytes,55,opt,name=tasks_per_core,json=tasksPerCore,proto3" json:"tasks_per_core,omitempty"`
|
||||
TasksPerSocket string `protobuf:"bytes,56,opt,name=tasks_per_socket,json=tasksPerSocket,proto3" json:"tasks_per_socket,omitempty"`
|
||||
TasksPerBoard string `protobuf:"bytes,57,opt,name=tasks_per_board,json=tasksPerBoard,proto3" json:"tasks_per_board,omitempty"`
|
||||
Cpus string `protobuf:"bytes,58,opt,name=cpus,proto3" json:"cpus,omitempty"`
|
||||
NodeCount string `protobuf:"bytes,59,opt,name=node_count,json=nodeCount,proto3" json:"node_count,omitempty"`
|
||||
Tasks string `protobuf:"bytes,60,opt,name=tasks,proto3" json:"tasks,omitempty"`
|
||||
HetJobId string `protobuf:"bytes,61,opt,name=het_job_id,json=hetJobId,proto3" json:"het_job_id,omitempty"`
|
||||
Nice int32 `protobuf:"varint,54,opt,name=nice,proto3" json:"nice,omitempty"`
|
||||
TasksPerCore uint32 `protobuf:"varint,55,opt,name=tasks_per_core,json=tasksPerCore,proto3" json:"tasks_per_core,omitempty"`
|
||||
TasksPerSocket uint32 `protobuf:"varint,56,opt,name=tasks_per_socket,json=tasksPerSocket,proto3" json:"tasks_per_socket,omitempty"`
|
||||
TasksPerBoard uint32 `protobuf:"varint,57,opt,name=tasks_per_board,json=tasksPerBoard,proto3" json:"tasks_per_board,omitempty"`
|
||||
Cpus uint32 `protobuf:"varint,58,opt,name=cpus,proto3" json:"cpus,omitempty"`
|
||||
NodeCount uint32 `protobuf:"varint,59,opt,name=node_count,json=nodeCount,proto3" json:"node_count,omitempty"`
|
||||
Tasks uint32 `protobuf:"varint,60,opt,name=tasks,proto3" json:"tasks,omitempty"`
|
||||
HetJobId int32 `protobuf:"varint,61,opt,name=het_job_id,json=hetJobId,proto3" json:"het_job_id,omitempty"`
|
||||
HetJobIdSet string `protobuf:"bytes,62,opt,name=het_job_id_set,json=hetJobIdSet,proto3" json:"het_job_id_set,omitempty"`
|
||||
HetJobOffset string `protobuf:"bytes,63,opt,name=het_job_offset,json=hetJobOffset,proto3" json:"het_job_offset,omitempty"`
|
||||
HetJobOffset uint32 `protobuf:"varint,63,opt,name=het_job_offset,json=hetJobOffset,proto3" json:"het_job_offset,omitempty"`
|
||||
Partition string `protobuf:"bytes,64,opt,name=partition,proto3" json:"partition,omitempty"`
|
||||
MemoryPerNode string `protobuf:"bytes,65,opt,name=memory_per_node,json=memoryPerNode,proto3" json:"memory_per_node,omitempty"`
|
||||
MemoryPerCpu string `protobuf:"bytes,66,opt,name=memory_per_cpu,json=memoryPerCpu,proto3" json:"memory_per_cpu,omitempty"`
|
||||
MinimumCpusPerNode string `protobuf:"bytes,67,opt,name=minimum_cpus_per_node,json=minimumCpusPerNode,proto3" json:"minimum_cpus_per_node,omitempty"`
|
||||
MinimumTmpDiskPerNode string `protobuf:"bytes,68,opt,name=minimum_tmp_disk_per_node,json=minimumTmpDiskPerNode,proto3" json:"minimum_tmp_disk_per_node,omitempty"`
|
||||
PreemptTime uint32 `protobuf:"varint,69,opt,name=preempt_time,json=preemptTime,proto3" json:"preempt_time,omitempty"`
|
||||
PreSusTime uint32 `protobuf:"varint,70,opt,name=pre_sus_time,json=preSusTime,proto3" json:"pre_sus_time,omitempty"`
|
||||
Priority string `protobuf:"bytes,71,opt,name=priority,proto3" json:"priority,omitempty"`
|
||||
MemoryPerNode uint64 `protobuf:"varint,65,opt,name=memory_per_node,json=memoryPerNode,proto3" json:"memory_per_node,omitempty"`
|
||||
MemoryPerCpu uint64 `protobuf:"varint,66,opt,name=memory_per_cpu,json=memoryPerCpu,proto3" json:"memory_per_cpu,omitempty"`
|
||||
MinimumCpusPerNode uint32 `protobuf:"varint,67,opt,name=minimum_cpus_per_node,json=minimumCpusPerNode,proto3" json:"minimum_cpus_per_node,omitempty"`
|
||||
MinimumTmpDiskPerNode uint32 `protobuf:"varint,68,opt,name=minimum_tmp_disk_per_node,json=minimumTmpDiskPerNode,proto3" json:"minimum_tmp_disk_per_node,omitempty"`
|
||||
PreemptTime uint64 `protobuf:"varint,69,opt,name=preempt_time,json=preemptTime,proto3" json:"preempt_time,omitempty"`
|
||||
PreSusTime uint64 `protobuf:"varint,70,opt,name=pre_sus_time,json=preSusTime,proto3" json:"pre_sus_time,omitempty"`
|
||||
Priority uint32 `protobuf:"varint,71,opt,name=priority,proto3" json:"priority,omitempty"`
|
||||
Profile []string `protobuf:"bytes,72,rep,name=profile,proto3" json:"profile,omitempty"`
|
||||
Qos string `protobuf:"bytes,73,opt,name=qos,proto3" json:"qos,omitempty"`
|
||||
Reboot bool `protobuf:"varint,74,opt,name=reboot,proto3" json:"reboot,omitempty"`
|
||||
RequiredNodes string `protobuf:"bytes,75,opt,name=required_nodes,json=requiredNodes,proto3" json:"required_nodes,omitempty"`
|
||||
Requeue bool `protobuf:"varint,76,opt,name=requeue,proto3" json:"requeue,omitempty"`
|
||||
ResizeTime uint32 `protobuf:"varint,77,opt,name=resize_time,json=resizeTime,proto3" json:"resize_time,omitempty"`
|
||||
RestartCnt string `protobuf:"bytes,78,opt,name=restart_cnt,json=restartCnt,proto3" json:"restart_cnt,omitempty"`
|
||||
ResizeTime uint64 `protobuf:"varint,77,opt,name=resize_time,json=resizeTime,proto3" json:"resize_time,omitempty"`
|
||||
RestartCnt int32 `protobuf:"varint,78,opt,name=restart_cnt,json=restartCnt,proto3" json:"restart_cnt,omitempty"`
|
||||
ResvName string `protobuf:"bytes,79,opt,name=resv_name,json=resvName,proto3" json:"resv_name,omitempty"`
|
||||
Shared string `protobuf:"bytes,80,opt,name=shared,proto3" json:"shared,omitempty"`
|
||||
ShowFlags []string `protobuf:"bytes,81,rep,name=show_flags,json=showFlags,proto3" json:"show_flags,omitempty"`
|
||||
SocketsPerBoard string `protobuf:"bytes,82,opt,name=sockets_per_board,json=socketsPerBoard,proto3" json:"sockets_per_board,omitempty"`
|
||||
SocketsPerNode string `protobuf:"bytes,83,opt,name=sockets_per_node,json=socketsPerNode,proto3" json:"sockets_per_node,omitempty"`
|
||||
StartTime uint32 `protobuf:"varint,84,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
|
||||
SocketsPerBoard int32 `protobuf:"varint,82,opt,name=sockets_per_board,json=socketsPerBoard,proto3" json:"sockets_per_board,omitempty"`
|
||||
SocketsPerNode uint64 `protobuf:"varint,83,opt,name=sockets_per_node,json=socketsPerNode,proto3" json:"sockets_per_node,omitempty"`
|
||||
StartTime uint64 `protobuf:"varint,84,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
|
||||
StateDescription string `protobuf:"bytes,85,opt,name=state_description,json=stateDescription,proto3" json:"state_description,omitempty"`
|
||||
StateReason string `protobuf:"bytes,86,opt,name=state_reason,json=stateReason,proto3" json:"state_reason,omitempty"`
|
||||
StandardError string `protobuf:"bytes,87,opt,name=standard_error,json=standardError,proto3" json:"standard_error,omitempty"`
|
||||
StandardInput string `protobuf:"bytes,88,opt,name=standard_input,json=standardInput,proto3" json:"standard_input,omitempty"`
|
||||
StandardOutput string `protobuf:"bytes,89,opt,name=standard_output,json=standardOutput,proto3" json:"standard_output,omitempty"`
|
||||
SubmitTime uint32 `protobuf:"varint,90,opt,name=submit_time,json=submitTime,proto3" json:"submit_time,omitempty"`
|
||||
SuspendTime uint32 `protobuf:"varint,91,opt,name=suspend_time,json=suspendTime,proto3" json:"suspend_time,omitempty"`
|
||||
SubmitTime uint64 `protobuf:"varint,90,opt,name=submit_time,json=submitTime,proto3" json:"submit_time,omitempty"`
|
||||
SuspendTime uint64 `protobuf:"varint,91,opt,name=suspend_time,json=suspendTime,proto3" json:"suspend_time,omitempty"`
|
||||
SystemComment string `protobuf:"bytes,92,opt,name=system_comment,json=systemComment,proto3" json:"system_comment,omitempty"`
|
||||
TimeLimit string `protobuf:"bytes,93,opt,name=time_limit,json=timeLimit,proto3" json:"time_limit,omitempty"`
|
||||
TimeMinimum string `protobuf:"bytes,94,opt,name=time_minimum,json=timeMinimum,proto3" json:"time_minimum,omitempty"`
|
||||
ThreadsPerCore string `protobuf:"bytes,95,opt,name=threads_per_core,json=threadsPerCore,proto3" json:"threads_per_core,omitempty"`
|
||||
TimeLimit uint32 `protobuf:"varint,93,opt,name=time_limit,json=timeLimit,proto3" json:"time_limit,omitempty"`
|
||||
TimeMinimum uint32 `protobuf:"varint,94,opt,name=time_minimum,json=timeMinimum,proto3" json:"time_minimum,omitempty"`
|
||||
ThreadsPerCore uint32 `protobuf:"varint,95,opt,name=threads_per_core,json=threadsPerCore,proto3" json:"threads_per_core,omitempty"`
|
||||
TresBind string `protobuf:"bytes,96,opt,name=tres_bind,json=tresBind,proto3" json:"tres_bind,omitempty"`
|
||||
TresFreq string `protobuf:"bytes,97,opt,name=tres_freq,json=tresFreq,proto3" json:"tres_freq,omitempty"`
|
||||
TresPerJob string `protobuf:"bytes,98,opt,name=tres_per_job,json=tresPerJob,proto3" json:"tres_per_job,omitempty"`
|
||||
|
|
@ -808,7 +808,7 @@ type JobResponseProperties struct {
|
|||
TresPerTask string `protobuf:"bytes,101,opt,name=tres_per_task,json=tresPerTask,proto3" json:"tres_per_task,omitempty"`
|
||||
TresReqStr string `protobuf:"bytes,102,opt,name=tres_req_str,json=tresReqStr,proto3" json:"tres_req_str,omitempty"`
|
||||
TresAllocStr string `protobuf:"bytes,103,opt,name=tres_alloc_str,json=tresAllocStr,proto3" json:"tres_alloc_str,omitempty"`
|
||||
UserId string `protobuf:"bytes,104,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
|
||||
UserId int32 `protobuf:"varint,104,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
|
||||
UserName string `protobuf:"bytes,105,opt,name=user_name,json=userName,proto3" json:"user_name,omitempty"`
|
||||
Wckey string `protobuf:"bytes,106,opt,name=wckey,proto3" json:"wckey,omitempty"`
|
||||
CurrentWorkingDirectory string `protobuf:"bytes,107,opt,name=current_working_directory,json=currentWorkingDirectory,proto3" json:"current_working_directory,omitempty"`
|
||||
|
|
@ -853,7 +853,7 @@ func (x *JobResponseProperties) GetAccount() string {
|
|||
return ""
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetAccrueTime() uint32 {
|
||||
func (x *JobResponseProperties) GetAccrueTime() uint64 {
|
||||
if x != nil {
|
||||
return x.AccrueTime
|
||||
}
|
||||
|
|
@ -867,25 +867,25 @@ func (x *JobResponseProperties) GetAdminComment() string {
|
|||
return ""
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetArrayJobId() string {
|
||||
func (x *JobResponseProperties) GetArrayJobId() uint32 {
|
||||
if x != nil {
|
||||
return x.ArrayJobId
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetArrayTaskId() string {
|
||||
func (x *JobResponseProperties) GetArrayTaskId() uint32 {
|
||||
if x != nil {
|
||||
return x.ArrayTaskId
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetArrayMaxTasks() string {
|
||||
func (x *JobResponseProperties) GetArrayMaxTasks() uint32 {
|
||||
if x != nil {
|
||||
return x.ArrayMaxTasks
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetArrayTaskString() string {
|
||||
|
|
@ -895,11 +895,11 @@ func (x *JobResponseProperties) GetArrayTaskString() string {
|
|||
return ""
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetAssociationId() string {
|
||||
func (x *JobResponseProperties) GetAssociationId() int64 {
|
||||
if x != nil {
|
||||
return x.AssociationId
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetBatchFeatures() string {
|
||||
|
|
@ -979,60 +979,60 @@ func (x *JobResponseProperties) GetContiguous() bool {
|
|||
return false
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetCoreSpec() string {
|
||||
func (x *JobResponseProperties) GetCoreSpec() int64 {
|
||||
if x != nil {
|
||||
return x.CoreSpec
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetThreadSpec() string {
|
||||
func (x *JobResponseProperties) GetThreadSpec() int64 {
|
||||
if x != nil {
|
||||
return x.ThreadSpec
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetCoresPerSocket() string {
|
||||
func (x *JobResponseProperties) GetCoresPerSocket() uint32 {
|
||||
if x != nil {
|
||||
return x.CoresPerSocket
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetBillableTres() string {
|
||||
func (x *JobResponseProperties) GetBillableTres() float32 {
|
||||
if x != nil {
|
||||
return x.BillableTres
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetCpusPerTask() string {
|
||||
func (x *JobResponseProperties) GetCpusPerTask() uint32 {
|
||||
if x != nil {
|
||||
return x.CpusPerTask
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetCpuFrequencyMinimum() string {
|
||||
func (x *JobResponseProperties) GetCpuFrequencyMinimum() uint32 {
|
||||
if x != nil {
|
||||
return x.CpuFrequencyMinimum
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetCpuFrequencyMaximum() string {
|
||||
func (x *JobResponseProperties) GetCpuFrequencyMaximum() uint32 {
|
||||
if x != nil {
|
||||
return x.CpuFrequencyMaximum
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetCpuFrequencyGovernor() string {
|
||||
func (x *JobResponseProperties) GetCpuFrequencyGovernor() uint32 {
|
||||
if x != nil {
|
||||
return x.CpuFrequencyGovernor
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetCpusPerTres() string {
|
||||
|
|
@ -1042,18 +1042,18 @@ func (x *JobResponseProperties) GetCpusPerTres() string {
|
|||
return ""
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetDeadline() string {
|
||||
func (x *JobResponseProperties) GetDeadline() uint64 {
|
||||
if x != nil {
|
||||
return x.Deadline
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetDelayBoot() string {
|
||||
func (x *JobResponseProperties) GetDelayBoot() uint32 {
|
||||
if x != nil {
|
||||
return x.DelayBoot
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetDependency() string {
|
||||
|
|
@ -1063,21 +1063,21 @@ func (x *JobResponseProperties) GetDependency() string {
|
|||
return ""
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetDerivedExitCode() string {
|
||||
func (x *JobResponseProperties) GetDerivedExitCode() uint32 {
|
||||
if x != nil {
|
||||
return x.DerivedExitCode
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetEligibleTime() uint32 {
|
||||
func (x *JobResponseProperties) GetEligibleTime() uint64 {
|
||||
if x != nil {
|
||||
return x.EligibleTime
|
||||
}
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetEndTime() uint32 {
|
||||
func (x *JobResponseProperties) GetEndTime() uint64 {
|
||||
if x != nil {
|
||||
return x.EndTime
|
||||
}
|
||||
|
|
@ -1133,18 +1133,18 @@ func (x *JobResponseProperties) GetGresDetail() []string {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetGroupId() string {
|
||||
func (x *JobResponseProperties) GetGroupId() int32 {
|
||||
if x != nil {
|
||||
return x.GroupId
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetJobId() string {
|
||||
func (x *JobResponseProperties) GetJobId() int32 {
|
||||
if x != nil {
|
||||
return x.JobId
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetJobResources() *JobResources {
|
||||
|
|
@ -1161,11 +1161,11 @@ func (x *JobResponseProperties) GetJobState() string {
|
|||
return ""
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetLastSchedEvaluation() string {
|
||||
func (x *JobResponseProperties) GetLastSchedEvaluation() uint64 {
|
||||
if x != nil {
|
||||
return x.LastSchedEvaluation
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetLicenses() string {
|
||||
|
|
@ -1175,18 +1175,18 @@ func (x *JobResponseProperties) GetLicenses() string {
|
|||
return ""
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetMaxCpus() string {
|
||||
func (x *JobResponseProperties) GetMaxCpus() uint32 {
|
||||
if x != nil {
|
||||
return x.MaxCpus
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetMaxNodes() string {
|
||||
func (x *JobResponseProperties) GetMaxNodes() uint32 {
|
||||
if x != nil {
|
||||
return x.MaxNodes
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetMcsLabel() string {
|
||||
|
|
@ -1217,60 +1217,60 @@ func (x *JobResponseProperties) GetNodes() string {
|
|||
return ""
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetNice() string {
|
||||
func (x *JobResponseProperties) GetNice() int32 {
|
||||
if x != nil {
|
||||
return x.Nice
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetTasksPerCore() string {
|
||||
func (x *JobResponseProperties) GetTasksPerCore() uint32 {
|
||||
if x != nil {
|
||||
return x.TasksPerCore
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetTasksPerSocket() string {
|
||||
func (x *JobResponseProperties) GetTasksPerSocket() uint32 {
|
||||
if x != nil {
|
||||
return x.TasksPerSocket
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetTasksPerBoard() string {
|
||||
func (x *JobResponseProperties) GetTasksPerBoard() uint32 {
|
||||
if x != nil {
|
||||
return x.TasksPerBoard
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetCpus() string {
|
||||
func (x *JobResponseProperties) GetCpus() uint32 {
|
||||
if x != nil {
|
||||
return x.Cpus
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetNodeCount() string {
|
||||
func (x *JobResponseProperties) GetNodeCount() uint32 {
|
||||
if x != nil {
|
||||
return x.NodeCount
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetTasks() string {
|
||||
func (x *JobResponseProperties) GetTasks() uint32 {
|
||||
if x != nil {
|
||||
return x.Tasks
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetHetJobId() string {
|
||||
func (x *JobResponseProperties) GetHetJobId() int32 {
|
||||
if x != nil {
|
||||
return x.HetJobId
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetHetJobIdSet() string {
|
||||
|
|
@ -1280,11 +1280,11 @@ func (x *JobResponseProperties) GetHetJobIdSet() string {
|
|||
return ""
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetHetJobOffset() string {
|
||||
func (x *JobResponseProperties) GetHetJobOffset() uint32 {
|
||||
if x != nil {
|
||||
return x.HetJobOffset
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetPartition() string {
|
||||
|
|
@ -1294,53 +1294,53 @@ func (x *JobResponseProperties) GetPartition() string {
|
|||
return ""
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetMemoryPerNode() string {
|
||||
func (x *JobResponseProperties) GetMemoryPerNode() uint64 {
|
||||
if x != nil {
|
||||
return x.MemoryPerNode
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetMemoryPerCpu() string {
|
||||
func (x *JobResponseProperties) GetMemoryPerCpu() uint64 {
|
||||
if x != nil {
|
||||
return x.MemoryPerCpu
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetMinimumCpusPerNode() string {
|
||||
func (x *JobResponseProperties) GetMinimumCpusPerNode() uint32 {
|
||||
if x != nil {
|
||||
return x.MinimumCpusPerNode
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetMinimumTmpDiskPerNode() string {
|
||||
func (x *JobResponseProperties) GetMinimumTmpDiskPerNode() uint32 {
|
||||
if x != nil {
|
||||
return x.MinimumTmpDiskPerNode
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetPreemptTime() uint32 {
|
||||
func (x *JobResponseProperties) GetPreemptTime() uint64 {
|
||||
if x != nil {
|
||||
return x.PreemptTime
|
||||
}
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetPreSusTime() uint32 {
|
||||
func (x *JobResponseProperties) GetPreSusTime() uint64 {
|
||||
if x != nil {
|
||||
return x.PreSusTime
|
||||
}
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetPriority() string {
|
||||
func (x *JobResponseProperties) GetPriority() uint32 {
|
||||
if x != nil {
|
||||
return x.Priority
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetProfile() []string {
|
||||
|
|
@ -1378,18 +1378,18 @@ func (x *JobResponseProperties) GetRequeue() bool {
|
|||
return false
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetResizeTime() uint32 {
|
||||
func (x *JobResponseProperties) GetResizeTime() uint64 {
|
||||
if x != nil {
|
||||
return x.ResizeTime
|
||||
}
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetRestartCnt() string {
|
||||
func (x *JobResponseProperties) GetRestartCnt() int32 {
|
||||
if x != nil {
|
||||
return x.RestartCnt
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetResvName() string {
|
||||
|
|
@ -1413,21 +1413,21 @@ func (x *JobResponseProperties) GetShowFlags() []string {
|
|||
return nil
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetSocketsPerBoard() string {
|
||||
func (x *JobResponseProperties) GetSocketsPerBoard() int32 {
|
||||
if x != nil {
|
||||
return x.SocketsPerBoard
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetSocketsPerNode() string {
|
||||
func (x *JobResponseProperties) GetSocketsPerNode() uint64 {
|
||||
if x != nil {
|
||||
return x.SocketsPerNode
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetStartTime() uint32 {
|
||||
func (x *JobResponseProperties) GetStartTime() uint64 {
|
||||
if x != nil {
|
||||
return x.StartTime
|
||||
}
|
||||
|
|
@ -1469,14 +1469,14 @@ func (x *JobResponseProperties) GetStandardOutput() string {
|
|||
return ""
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetSubmitTime() uint32 {
|
||||
func (x *JobResponseProperties) GetSubmitTime() uint64 {
|
||||
if x != nil {
|
||||
return x.SubmitTime
|
||||
}
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetSuspendTime() uint32 {
|
||||
func (x *JobResponseProperties) GetSuspendTime() uint64 {
|
||||
if x != nil {
|
||||
return x.SuspendTime
|
||||
}
|
||||
|
|
@ -1490,25 +1490,25 @@ func (x *JobResponseProperties) GetSystemComment() string {
|
|||
return ""
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetTimeLimit() string {
|
||||
func (x *JobResponseProperties) GetTimeLimit() uint32 {
|
||||
if x != nil {
|
||||
return x.TimeLimit
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetTimeMinimum() string {
|
||||
func (x *JobResponseProperties) GetTimeMinimum() uint32 {
|
||||
if x != nil {
|
||||
return x.TimeMinimum
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetThreadsPerCore() string {
|
||||
func (x *JobResponseProperties) GetThreadsPerCore() uint32 {
|
||||
if x != nil {
|
||||
return x.ThreadsPerCore
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetTresBind() string {
|
||||
|
|
@ -1567,11 +1567,11 @@ func (x *JobResponseProperties) GetTresAllocStr() string {
|
|||
return ""
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetUserId() string {
|
||||
func (x *JobResponseProperties) GetUserId() int32 {
|
||||
if x != nil {
|
||||
return x.UserId
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *JobResponseProperties) GetUserName() string {
|
||||
|
|
@ -1604,7 +1604,7 @@ type Jobs struct {
|
|||
Account string `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty"`
|
||||
AccrueTime uint32 `protobuf:"varint,2,opt,name=accrue_time,json=accrueTime,proto3" json:"accrue_time,omitempty"`
|
||||
AdminComment string `protobuf:"bytes,3,opt,name=admin_comment,json=adminComment,proto3" json:"admin_comment,omitempty"`
|
||||
ArrayJobId string `protobuf:"bytes,4,opt,name=array_job_id,json=arrayJobId,proto3" json:"array_job_id,omitempty"`
|
||||
ArrayJobId int32 `protobuf:"varint,4,opt,name=array_job_id,json=arrayJobId,proto3" json:"array_job_id,omitempty"`
|
||||
ArrayTaskId string `protobuf:"bytes,5,opt,name=array_task_id,json=arrayTaskId,proto3" json:"array_task_id,omitempty"`
|
||||
ArrayMaxTasks string `protobuf:"bytes,6,opt,name=array_max_tasks,json=arrayMaxTasks,proto3" json:"array_max_tasks,omitempty"`
|
||||
ArrayTaskString string `protobuf:"bytes,7,opt,name=array_task_string,json=arrayTaskString,proto3" json:"array_task_string,omitempty"`
|
||||
|
|
@ -1623,7 +1623,7 @@ type Jobs struct {
|
|||
CoreSpec string `protobuf:"bytes,20,opt,name=core_spec,json=coreSpec,proto3" json:"core_spec,omitempty"`
|
||||
ThreadSpec string `protobuf:"bytes,21,opt,name=thread_spec,json=threadSpec,proto3" json:"thread_spec,omitempty"`
|
||||
CoresPerSocket string `protobuf:"bytes,22,opt,name=cores_per_socket,json=coresPerSocket,proto3" json:"cores_per_socket,omitempty"`
|
||||
BillableTres string `protobuf:"bytes,23,opt,name=billable_tres,json=billableTres,proto3" json:"billable_tres,omitempty"`
|
||||
BillableTres float32 `protobuf:"fixed32,23,opt,name=billable_tres,json=billableTres,proto3" json:"billable_tres,omitempty"`
|
||||
CpusPerTask string `protobuf:"bytes,24,opt,name=cpus_per_task,json=cpusPerTask,proto3" json:"cpus_per_task,omitempty"`
|
||||
CpuFrequencyMinimum string `protobuf:"bytes,25,opt,name=cpu_frequency_minimum,json=cpuFrequencyMinimum,proto3" json:"cpu_frequency_minimum,omitempty"`
|
||||
CpuFrequencyMaximum string `protobuf:"bytes,26,opt,name=cpu_frequency_maximum,json=cpuFrequencyMaximum,proto3" json:"cpu_frequency_maximum,omitempty"`
|
||||
|
|
@ -1763,11 +1763,11 @@ func (x *Jobs) GetAdminComment() string {
|
|||
return ""
|
||||
}
|
||||
|
||||
func (x *Jobs) GetArrayJobId() string {
|
||||
func (x *Jobs) GetArrayJobId() int32 {
|
||||
if x != nil {
|
||||
return x.ArrayJobId
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *Jobs) GetArrayTaskId() string {
|
||||
|
|
@ -1896,11 +1896,11 @@ func (x *Jobs) GetCoresPerSocket() string {
|
|||
return ""
|
||||
}
|
||||
|
||||
func (x *Jobs) GetBillableTres() string {
|
||||
func (x *Jobs) GetBillableTres() float32 {
|
||||
if x != nil {
|
||||
return x.BillableTres
|
||||
}
|
||||
return ""
|
||||
return 0
|
||||
}
|
||||
|
||||
func (x *Jobs) GetCpusPerTask() string {
|
||||
|
|
@ -3278,21 +3278,21 @@ var file_job_proto_rawDesc = []byte{
|
|||
0x73, 0x65, 0x5f, 0x70, 0x72, 0x6f, 0x70, 0x65, 0x72, 0x74, 0x69, 0x65, 0x73, 0x12, 0x18, 0x0a,
|
||||
0x07, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07,
|
||||
0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x12, 0x1f, 0x0a, 0x0b, 0x61, 0x63, 0x63, 0x72, 0x75,
|
||||
0x65, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0a, 0x61, 0x63,
|
||||
0x65, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0a, 0x61, 0x63,
|
||||
0x63, 0x72, 0x75, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x23, 0x0a, 0x0d, 0x61, 0x64, 0x6d, 0x69,
|
||||
0x6e, 0x5f, 0x63, 0x6f, 0x6d, 0x6d, 0x65, 0x6e, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52,
|
||||
0x0c, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x43, 0x6f, 0x6d, 0x6d, 0x65, 0x6e, 0x74, 0x12, 0x20, 0x0a,
|
||||
0x0c, 0x61, 0x72, 0x72, 0x61, 0x79, 0x5f, 0x6a, 0x6f, 0x62, 0x5f, 0x69, 0x64, 0x18, 0x04, 0x20,
|
||||
0x01, 0x28, 0x09, 0x52, 0x0a, 0x61, 0x72, 0x72, 0x61, 0x79, 0x4a, 0x6f, 0x62, 0x49, 0x64, 0x12,
|
||||
0x01, 0x28, 0x0d, 0x52, 0x0a, 0x61, 0x72, 0x72, 0x61, 0x79, 0x4a, 0x6f, 0x62, 0x49, 0x64, 0x12,
|
||||
0x22, 0x0a, 0x0d, 0x61, 0x72, 0x72, 0x61, 0x79, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x5f, 0x69, 0x64,
|
||||
0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x61, 0x72, 0x72, 0x61, 0x79, 0x54, 0x61, 0x73,
|
||||
0x18, 0x05, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0b, 0x61, 0x72, 0x72, 0x61, 0x79, 0x54, 0x61, 0x73,
|
||||
0x6b, 0x49, 0x64, 0x12, 0x26, 0x0a, 0x0f, 0x61, 0x72, 0x72, 0x61, 0x79, 0x5f, 0x6d, 0x61, 0x78,
|
||||
0x5f, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x61, 0x72,
|
||||
0x5f, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0d, 0x61, 0x72,
|
||||
0x72, 0x61, 0x79, 0x4d, 0x61, 0x78, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x12, 0x2a, 0x0a, 0x11, 0x61,
|
||||
0x72, 0x72, 0x61, 0x79, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x5f, 0x73, 0x74, 0x72, 0x69, 0x6e, 0x67,
|
||||
0x18, 0x07, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0f, 0x61, 0x72, 0x72, 0x61, 0x79, 0x54, 0x61, 0x73,
|
||||
0x6b, 0x53, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x12, 0x25, 0x0a, 0x0e, 0x61, 0x73, 0x73, 0x6f, 0x63,
|
||||
0x69, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x08, 0x20, 0x01, 0x28, 0x09, 0x52,
|
||||
0x69, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x08, 0x20, 0x01, 0x28, 0x03, 0x52,
|
||||
0x0d, 0x61, 0x73, 0x73, 0x6f, 0x63, 0x69, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x12, 0x25,
|
||||
0x0a, 0x0e, 0x62, 0x61, 0x74, 0x63, 0x68, 0x5f, 0x66, 0x65, 0x61, 0x74, 0x75, 0x72, 0x65, 0x73,
|
||||
0x18, 0x09, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x62, 0x61, 0x74, 0x63, 0x68, 0x46, 0x65, 0x61,
|
||||
|
|
@ -3317,41 +3317,41 @@ var file_job_proto_rawDesc = []byte{
|
|||
0x65, 0x6e, 0x74, 0x12, 0x1e, 0x0a, 0x0a, 0x63, 0x6f, 0x6e, 0x74, 0x69, 0x67, 0x75, 0x6f, 0x75,
|
||||
0x73, 0x18, 0x13, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0a, 0x63, 0x6f, 0x6e, 0x74, 0x69, 0x67, 0x75,
|
||||
0x6f, 0x75, 0x73, 0x12, 0x1b, 0x0a, 0x09, 0x63, 0x6f, 0x72, 0x65, 0x5f, 0x73, 0x70, 0x65, 0x63,
|
||||
0x18, 0x14, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x63, 0x6f, 0x72, 0x65, 0x53, 0x70, 0x65, 0x63,
|
||||
0x18, 0x14, 0x20, 0x01, 0x28, 0x03, 0x52, 0x08, 0x63, 0x6f, 0x72, 0x65, 0x53, 0x70, 0x65, 0x63,
|
||||
0x12, 0x1f, 0x0a, 0x0b, 0x74, 0x68, 0x72, 0x65, 0x61, 0x64, 0x5f, 0x73, 0x70, 0x65, 0x63, 0x18,
|
||||
0x15, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x74, 0x68, 0x72, 0x65, 0x61, 0x64, 0x53, 0x70, 0x65,
|
||||
0x15, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0a, 0x74, 0x68, 0x72, 0x65, 0x61, 0x64, 0x53, 0x70, 0x65,
|
||||
0x63, 0x12, 0x28, 0x0a, 0x10, 0x63, 0x6f, 0x72, 0x65, 0x73, 0x5f, 0x70, 0x65, 0x72, 0x5f, 0x73,
|
||||
0x6f, 0x63, 0x6b, 0x65, 0x74, 0x18, 0x16, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0e, 0x63, 0x6f, 0x72,
|
||||
0x6f, 0x63, 0x6b, 0x65, 0x74, 0x18, 0x16, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0e, 0x63, 0x6f, 0x72,
|
||||
0x65, 0x73, 0x50, 0x65, 0x72, 0x53, 0x6f, 0x63, 0x6b, 0x65, 0x74, 0x12, 0x23, 0x0a, 0x0d, 0x62,
|
||||
0x69, 0x6c, 0x6c, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x74, 0x72, 0x65, 0x73, 0x18, 0x17, 0x20, 0x01,
|
||||
0x28, 0x09, 0x52, 0x0c, 0x62, 0x69, 0x6c, 0x6c, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x72, 0x65, 0x73,
|
||||
0x28, 0x02, 0x52, 0x0c, 0x62, 0x69, 0x6c, 0x6c, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x72, 0x65, 0x73,
|
||||
0x12, 0x22, 0x0a, 0x0d, 0x63, 0x70, 0x75, 0x73, 0x5f, 0x70, 0x65, 0x72, 0x5f, 0x74, 0x61, 0x73,
|
||||
0x6b, 0x18, 0x18, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x70, 0x75, 0x73, 0x50, 0x65, 0x72,
|
||||
0x6b, 0x18, 0x18, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0b, 0x63, 0x70, 0x75, 0x73, 0x50, 0x65, 0x72,
|
||||
0x54, 0x61, 0x73, 0x6b, 0x12, 0x32, 0x0a, 0x15, 0x63, 0x70, 0x75, 0x5f, 0x66, 0x72, 0x65, 0x71,
|
||||
0x75, 0x65, 0x6e, 0x63, 0x79, 0x5f, 0x6d, 0x69, 0x6e, 0x69, 0x6d, 0x75, 0x6d, 0x18, 0x19, 0x20,
|
||||
0x01, 0x28, 0x09, 0x52, 0x13, 0x63, 0x70, 0x75, 0x46, 0x72, 0x65, 0x71, 0x75, 0x65, 0x6e, 0x63,
|
||||
0x01, 0x28, 0x0d, 0x52, 0x13, 0x63, 0x70, 0x75, 0x46, 0x72, 0x65, 0x71, 0x75, 0x65, 0x6e, 0x63,
|
||||
0x79, 0x4d, 0x69, 0x6e, 0x69, 0x6d, 0x75, 0x6d, 0x12, 0x32, 0x0a, 0x15, 0x63, 0x70, 0x75, 0x5f,
|
||||
0x66, 0x72, 0x65, 0x71, 0x75, 0x65, 0x6e, 0x63, 0x79, 0x5f, 0x6d, 0x61, 0x78, 0x69, 0x6d, 0x75,
|
||||
0x6d, 0x18, 0x1a, 0x20, 0x01, 0x28, 0x09, 0x52, 0x13, 0x63, 0x70, 0x75, 0x46, 0x72, 0x65, 0x71,
|
||||
0x6d, 0x18, 0x1a, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x13, 0x63, 0x70, 0x75, 0x46, 0x72, 0x65, 0x71,
|
||||
0x75, 0x65, 0x6e, 0x63, 0x79, 0x4d, 0x61, 0x78, 0x69, 0x6d, 0x75, 0x6d, 0x12, 0x34, 0x0a, 0x16,
|
||||
0x63, 0x70, 0x75, 0x5f, 0x66, 0x72, 0x65, 0x71, 0x75, 0x65, 0x6e, 0x63, 0x79, 0x5f, 0x67, 0x6f,
|
||||
0x76, 0x65, 0x72, 0x6e, 0x6f, 0x72, 0x18, 0x1b, 0x20, 0x01, 0x28, 0x09, 0x52, 0x14, 0x63, 0x70,
|
||||
0x76, 0x65, 0x72, 0x6e, 0x6f, 0x72, 0x18, 0x1b, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x14, 0x63, 0x70,
|
||||
0x75, 0x46, 0x72, 0x65, 0x71, 0x75, 0x65, 0x6e, 0x63, 0x79, 0x47, 0x6f, 0x76, 0x65, 0x72, 0x6e,
|
||||
0x6f, 0x72, 0x12, 0x22, 0x0a, 0x0d, 0x63, 0x70, 0x75, 0x73, 0x5f, 0x70, 0x65, 0x72, 0x5f, 0x74,
|
||||
0x72, 0x65, 0x73, 0x18, 0x1c, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x70, 0x75, 0x73, 0x50,
|
||||
0x65, 0x72, 0x54, 0x72, 0x65, 0x73, 0x12, 0x1a, 0x0a, 0x08, 0x64, 0x65, 0x61, 0x64, 0x6c, 0x69,
|
||||
0x6e, 0x65, 0x18, 0x1d, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x64, 0x65, 0x61, 0x64, 0x6c, 0x69,
|
||||
0x6e, 0x65, 0x18, 0x1d, 0x20, 0x01, 0x28, 0x04, 0x52, 0x08, 0x64, 0x65, 0x61, 0x64, 0x6c, 0x69,
|
||||
0x6e, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x64, 0x65, 0x6c, 0x61, 0x79, 0x5f, 0x62, 0x6f, 0x6f, 0x74,
|
||||
0x18, 0x1e, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x64, 0x65, 0x6c, 0x61, 0x79, 0x42, 0x6f, 0x6f,
|
||||
0x18, 0x1e, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x09, 0x64, 0x65, 0x6c, 0x61, 0x79, 0x42, 0x6f, 0x6f,
|
||||
0x74, 0x12, 0x1e, 0x0a, 0x0a, 0x64, 0x65, 0x70, 0x65, 0x6e, 0x64, 0x65, 0x6e, 0x63, 0x79, 0x18,
|
||||
0x1f, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x64, 0x65, 0x70, 0x65, 0x6e, 0x64, 0x65, 0x6e, 0x63,
|
||||
0x79, 0x12, 0x2a, 0x0a, 0x11, 0x64, 0x65, 0x72, 0x69, 0x76, 0x65, 0x64, 0x5f, 0x65, 0x78, 0x69,
|
||||
0x74, 0x5f, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x20, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0f, 0x64, 0x65,
|
||||
0x74, 0x5f, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x20, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0f, 0x64, 0x65,
|
||||
0x72, 0x69, 0x76, 0x65, 0x64, 0x45, 0x78, 0x69, 0x74, 0x43, 0x6f, 0x64, 0x65, 0x12, 0x23, 0x0a,
|
||||
0x0d, 0x65, 0x6c, 0x69, 0x67, 0x69, 0x62, 0x6c, 0x65, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x21,
|
||||
0x20, 0x01, 0x28, 0x0d, 0x52, 0x0c, 0x65, 0x6c, 0x69, 0x67, 0x69, 0x62, 0x6c, 0x65, 0x54, 0x69,
|
||||
0x20, 0x01, 0x28, 0x04, 0x52, 0x0c, 0x65, 0x6c, 0x69, 0x67, 0x69, 0x62, 0x6c, 0x65, 0x54, 0x69,
|
||||
0x6d, 0x65, 0x12, 0x19, 0x0a, 0x08, 0x65, 0x6e, 0x64, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x22,
|
||||
0x20, 0x01, 0x28, 0x0d, 0x52, 0x07, 0x65, 0x6e, 0x64, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x25, 0x0a,
|
||||
0x20, 0x01, 0x28, 0x04, 0x52, 0x07, 0x65, 0x6e, 0x64, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x25, 0x0a,
|
||||
0x0e, 0x65, 0x78, 0x63, 0x6c, 0x75, 0x64, 0x65, 0x64, 0x5f, 0x6e, 0x6f, 0x64, 0x65, 0x73, 0x18,
|
||||
0x23, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x65, 0x78, 0x63, 0x6c, 0x75, 0x64, 0x65, 0x64, 0x4e,
|
||||
0x6f, 0x64, 0x65, 0x73, 0x12, 0x1b, 0x0a, 0x09, 0x65, 0x78, 0x69, 0x74, 0x5f, 0x63, 0x6f, 0x64,
|
||||
|
|
@ -3371,22 +3371,22 @@ var file_job_proto_rawDesc = []byte{
|
|||
0x56, 0x69, 0x61, 0x62, 0x6c, 0x65, 0x12, 0x1f, 0x0a, 0x0b, 0x67, 0x72, 0x65, 0x73, 0x5f, 0x64,
|
||||
0x65, 0x74, 0x61, 0x69, 0x6c, 0x18, 0x29, 0x20, 0x03, 0x28, 0x09, 0x52, 0x0a, 0x67, 0x72, 0x65,
|
||||
0x73, 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x12, 0x19, 0x0a, 0x08, 0x67, 0x72, 0x6f, 0x75, 0x70,
|
||||
0x5f, 0x69, 0x64, 0x18, 0x2a, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x67, 0x72, 0x6f, 0x75, 0x70,
|
||||
0x5f, 0x69, 0x64, 0x18, 0x2a, 0x20, 0x01, 0x28, 0x05, 0x52, 0x07, 0x67, 0x72, 0x6f, 0x75, 0x70,
|
||||
0x49, 0x64, 0x12, 0x15, 0x0a, 0x06, 0x6a, 0x6f, 0x62, 0x5f, 0x69, 0x64, 0x18, 0x2b, 0x20, 0x01,
|
||||
0x28, 0x09, 0x52, 0x05, 0x6a, 0x6f, 0x62, 0x49, 0x64, 0x12, 0x39, 0x0a, 0x0d, 0x6a, 0x6f, 0x62,
|
||||
0x28, 0x05, 0x52, 0x05, 0x6a, 0x6f, 0x62, 0x49, 0x64, 0x12, 0x39, 0x0a, 0x0d, 0x6a, 0x6f, 0x62,
|
||||
0x5f, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x73, 0x18, 0x2c, 0x20, 0x01, 0x28, 0x0b,
|
||||
0x32, 0x14, 0x2e, 0x73, 0x6c, 0x75, 0x72, 0x6d, 0x2e, 0x4a, 0x6f, 0x62, 0x5f, 0x72, 0x65, 0x73,
|
||||
0x6f, 0x75, 0x72, 0x63, 0x65, 0x73, 0x52, 0x0c, 0x6a, 0x6f, 0x62, 0x52, 0x65, 0x73, 0x6f, 0x75,
|
||||
0x72, 0x63, 0x65, 0x73, 0x12, 0x1b, 0x0a, 0x09, 0x6a, 0x6f, 0x62, 0x5f, 0x73, 0x74, 0x61, 0x74,
|
||||
0x65, 0x18, 0x2d, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x6a, 0x6f, 0x62, 0x53, 0x74, 0x61, 0x74,
|
||||
0x65, 0x12, 0x32, 0x0a, 0x15, 0x6c, 0x61, 0x73, 0x74, 0x5f, 0x73, 0x63, 0x68, 0x65, 0x64, 0x5f,
|
||||
0x65, 0x76, 0x61, 0x6c, 0x75, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x2e, 0x20, 0x01, 0x28, 0x09,
|
||||
0x65, 0x76, 0x61, 0x6c, 0x75, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x2e, 0x20, 0x01, 0x28, 0x04,
|
||||
0x52, 0x13, 0x6c, 0x61, 0x73, 0x74, 0x53, 0x63, 0x68, 0x65, 0x64, 0x45, 0x76, 0x61, 0x6c, 0x75,
|
||||
0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x1a, 0x0a, 0x08, 0x6c, 0x69, 0x63, 0x65, 0x6e, 0x73, 0x65,
|
||||
0x73, 0x18, 0x2f, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x6c, 0x69, 0x63, 0x65, 0x6e, 0x73, 0x65,
|
||||
0x73, 0x12, 0x19, 0x0a, 0x08, 0x6d, 0x61, 0x78, 0x5f, 0x63, 0x70, 0x75, 0x73, 0x18, 0x30, 0x20,
|
||||
0x01, 0x28, 0x09, 0x52, 0x07, 0x6d, 0x61, 0x78, 0x43, 0x70, 0x75, 0x73, 0x12, 0x1b, 0x0a, 0x09,
|
||||
0x6d, 0x61, 0x78, 0x5f, 0x6e, 0x6f, 0x64, 0x65, 0x73, 0x18, 0x31, 0x20, 0x01, 0x28, 0x09, 0x52,
|
||||
0x01, 0x28, 0x0d, 0x52, 0x07, 0x6d, 0x61, 0x78, 0x43, 0x70, 0x75, 0x73, 0x12, 0x1b, 0x0a, 0x09,
|
||||
0x6d, 0x61, 0x78, 0x5f, 0x6e, 0x6f, 0x64, 0x65, 0x73, 0x18, 0x31, 0x20, 0x01, 0x28, 0x0d, 0x52,
|
||||
0x08, 0x6d, 0x61, 0x78, 0x4e, 0x6f, 0x64, 0x65, 0x73, 0x12, 0x1b, 0x0a, 0x09, 0x6d, 0x63, 0x73,
|
||||
0x5f, 0x6c, 0x61, 0x62, 0x65, 0x6c, 0x18, 0x32, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x6d, 0x63,
|
||||
0x73, 0x4c, 0x61, 0x62, 0x65, 0x6c, 0x12, 0x26, 0x0a, 0x0f, 0x6d, 0x65, 0x6d, 0x6f, 0x72, 0x79,
|
||||
|
|
@ -3395,45 +3395,45 @@ var file_job_proto_rawDesc = []byte{
|
|||
0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x34, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61,
|
||||
0x6d, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x6e, 0x6f, 0x64, 0x65, 0x73, 0x18, 0x35, 0x20, 0x01, 0x28,
|
||||
0x09, 0x52, 0x05, 0x6e, 0x6f, 0x64, 0x65, 0x73, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x69, 0x63, 0x65,
|
||||
0x18, 0x36, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x69, 0x63, 0x65, 0x12, 0x24, 0x0a, 0x0e,
|
||||
0x18, 0x36, 0x20, 0x01, 0x28, 0x05, 0x52, 0x04, 0x6e, 0x69, 0x63, 0x65, 0x12, 0x24, 0x0a, 0x0e,
|
||||
0x74, 0x61, 0x73, 0x6b, 0x73, 0x5f, 0x70, 0x65, 0x72, 0x5f, 0x63, 0x6f, 0x72, 0x65, 0x18, 0x37,
|
||||
0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x50, 0x65, 0x72, 0x43, 0x6f,
|
||||
0x20, 0x01, 0x28, 0x0d, 0x52, 0x0c, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x50, 0x65, 0x72, 0x43, 0x6f,
|
||||
0x72, 0x65, 0x12, 0x28, 0x0a, 0x10, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x5f, 0x70, 0x65, 0x72, 0x5f,
|
||||
0x73, 0x6f, 0x63, 0x6b, 0x65, 0x74, 0x18, 0x38, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0e, 0x74, 0x61,
|
||||
0x73, 0x6f, 0x63, 0x6b, 0x65, 0x74, 0x18, 0x38, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0e, 0x74, 0x61,
|
||||
0x73, 0x6b, 0x73, 0x50, 0x65, 0x72, 0x53, 0x6f, 0x63, 0x6b, 0x65, 0x74, 0x12, 0x26, 0x0a, 0x0f,
|
||||
0x74, 0x61, 0x73, 0x6b, 0x73, 0x5f, 0x70, 0x65, 0x72, 0x5f, 0x62, 0x6f, 0x61, 0x72, 0x64, 0x18,
|
||||
0x39, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x50, 0x65, 0x72, 0x42,
|
||||
0x39, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0d, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x50, 0x65, 0x72, 0x42,
|
||||
0x6f, 0x61, 0x72, 0x64, 0x12, 0x12, 0x0a, 0x04, 0x63, 0x70, 0x75, 0x73, 0x18, 0x3a, 0x20, 0x01,
|
||||
0x28, 0x09, 0x52, 0x04, 0x63, 0x70, 0x75, 0x73, 0x12, 0x1d, 0x0a, 0x0a, 0x6e, 0x6f, 0x64, 0x65,
|
||||
0x5f, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x3b, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x6e, 0x6f,
|
||||
0x28, 0x0d, 0x52, 0x04, 0x63, 0x70, 0x75, 0x73, 0x12, 0x1d, 0x0a, 0x0a, 0x6e, 0x6f, 0x64, 0x65,
|
||||
0x5f, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x3b, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x09, 0x6e, 0x6f,
|
||||
0x64, 0x65, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x12, 0x14, 0x0a, 0x05, 0x74, 0x61, 0x73, 0x6b, 0x73,
|
||||
0x18, 0x3c, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x12, 0x1c, 0x0a,
|
||||
0x18, 0x3c, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x05, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x12, 0x1c, 0x0a,
|
||||
0x0a, 0x68, 0x65, 0x74, 0x5f, 0x6a, 0x6f, 0x62, 0x5f, 0x69, 0x64, 0x18, 0x3d, 0x20, 0x01, 0x28,
|
||||
0x09, 0x52, 0x08, 0x68, 0x65, 0x74, 0x4a, 0x6f, 0x62, 0x49, 0x64, 0x12, 0x23, 0x0a, 0x0e, 0x68,
|
||||
0x05, 0x52, 0x08, 0x68, 0x65, 0x74, 0x4a, 0x6f, 0x62, 0x49, 0x64, 0x12, 0x23, 0x0a, 0x0e, 0x68,
|
||||
0x65, 0x74, 0x5f, 0x6a, 0x6f, 0x62, 0x5f, 0x69, 0x64, 0x5f, 0x73, 0x65, 0x74, 0x18, 0x3e, 0x20,
|
||||
0x01, 0x28, 0x09, 0x52, 0x0b, 0x68, 0x65, 0x74, 0x4a, 0x6f, 0x62, 0x49, 0x64, 0x53, 0x65, 0x74,
|
||||
0x12, 0x24, 0x0a, 0x0e, 0x68, 0x65, 0x74, 0x5f, 0x6a, 0x6f, 0x62, 0x5f, 0x6f, 0x66, 0x66, 0x73,
|
||||
0x65, 0x74, 0x18, 0x3f, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x68, 0x65, 0x74, 0x4a, 0x6f, 0x62,
|
||||
0x65, 0x74, 0x18, 0x3f, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0c, 0x68, 0x65, 0x74, 0x4a, 0x6f, 0x62,
|
||||
0x4f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x12, 0x1c, 0x0a, 0x09, 0x70, 0x61, 0x72, 0x74, 0x69, 0x74,
|
||||
0x69, 0x6f, 0x6e, 0x18, 0x40, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x70, 0x61, 0x72, 0x74, 0x69,
|
||||
0x74, 0x69, 0x6f, 0x6e, 0x12, 0x26, 0x0a, 0x0f, 0x6d, 0x65, 0x6d, 0x6f, 0x72, 0x79, 0x5f, 0x70,
|
||||
0x65, 0x72, 0x5f, 0x6e, 0x6f, 0x64, 0x65, 0x18, 0x41, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x6d,
|
||||
0x65, 0x72, 0x5f, 0x6e, 0x6f, 0x64, 0x65, 0x18, 0x41, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0d, 0x6d,
|
||||
0x65, 0x6d, 0x6f, 0x72, 0x79, 0x50, 0x65, 0x72, 0x4e, 0x6f, 0x64, 0x65, 0x12, 0x24, 0x0a, 0x0e,
|
||||
0x6d, 0x65, 0x6d, 0x6f, 0x72, 0x79, 0x5f, 0x70, 0x65, 0x72, 0x5f, 0x63, 0x70, 0x75, 0x18, 0x42,
|
||||
0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x6d, 0x65, 0x6d, 0x6f, 0x72, 0x79, 0x50, 0x65, 0x72, 0x43,
|
||||
0x20, 0x01, 0x28, 0x04, 0x52, 0x0c, 0x6d, 0x65, 0x6d, 0x6f, 0x72, 0x79, 0x50, 0x65, 0x72, 0x43,
|
||||
0x70, 0x75, 0x12, 0x31, 0x0a, 0x15, 0x6d, 0x69, 0x6e, 0x69, 0x6d, 0x75, 0x6d, 0x5f, 0x63, 0x70,
|
||||
0x75, 0x73, 0x5f, 0x70, 0x65, 0x72, 0x5f, 0x6e, 0x6f, 0x64, 0x65, 0x18, 0x43, 0x20, 0x01, 0x28,
|
||||
0x09, 0x52, 0x12, 0x6d, 0x69, 0x6e, 0x69, 0x6d, 0x75, 0x6d, 0x43, 0x70, 0x75, 0x73, 0x50, 0x65,
|
||||
0x0d, 0x52, 0x12, 0x6d, 0x69, 0x6e, 0x69, 0x6d, 0x75, 0x6d, 0x43, 0x70, 0x75, 0x73, 0x50, 0x65,
|
||||
0x72, 0x4e, 0x6f, 0x64, 0x65, 0x12, 0x38, 0x0a, 0x19, 0x6d, 0x69, 0x6e, 0x69, 0x6d, 0x75, 0x6d,
|
||||
0x5f, 0x74, 0x6d, 0x70, 0x5f, 0x64, 0x69, 0x73, 0x6b, 0x5f, 0x70, 0x65, 0x72, 0x5f, 0x6e, 0x6f,
|
||||
0x64, 0x65, 0x18, 0x44, 0x20, 0x01, 0x28, 0x09, 0x52, 0x15, 0x6d, 0x69, 0x6e, 0x69, 0x6d, 0x75,
|
||||
0x64, 0x65, 0x18, 0x44, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x15, 0x6d, 0x69, 0x6e, 0x69, 0x6d, 0x75,
|
||||
0x6d, 0x54, 0x6d, 0x70, 0x44, 0x69, 0x73, 0x6b, 0x50, 0x65, 0x72, 0x4e, 0x6f, 0x64, 0x65, 0x12,
|
||||
0x21, 0x0a, 0x0c, 0x70, 0x72, 0x65, 0x65, 0x6d, 0x70, 0x74, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18,
|
||||
0x45, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0b, 0x70, 0x72, 0x65, 0x65, 0x6d, 0x70, 0x74, 0x54, 0x69,
|
||||
0x45, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0b, 0x70, 0x72, 0x65, 0x65, 0x6d, 0x70, 0x74, 0x54, 0x69,
|
||||
0x6d, 0x65, 0x12, 0x20, 0x0a, 0x0c, 0x70, 0x72, 0x65, 0x5f, 0x73, 0x75, 0x73, 0x5f, 0x74, 0x69,
|
||||
0x6d, 0x65, 0x18, 0x46, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0a, 0x70, 0x72, 0x65, 0x53, 0x75, 0x73,
|
||||
0x6d, 0x65, 0x18, 0x46, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0a, 0x70, 0x72, 0x65, 0x53, 0x75, 0x73,
|
||||
0x54, 0x69, 0x6d, 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x70, 0x72, 0x69, 0x6f, 0x72, 0x69, 0x74, 0x79,
|
||||
0x18, 0x47, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x70, 0x72, 0x69, 0x6f, 0x72, 0x69, 0x74, 0x79,
|
||||
0x18, 0x47, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x08, 0x70, 0x72, 0x69, 0x6f, 0x72, 0x69, 0x74, 0x79,
|
||||
0x12, 0x18, 0x0a, 0x07, 0x70, 0x72, 0x6f, 0x66, 0x69, 0x6c, 0x65, 0x18, 0x48, 0x20, 0x03, 0x28,
|
||||
0x09, 0x52, 0x07, 0x70, 0x72, 0x6f, 0x66, 0x69, 0x6c, 0x65, 0x12, 0x10, 0x0a, 0x03, 0x71, 0x6f,
|
||||
0x73, 0x18, 0x49, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x71, 0x6f, 0x73, 0x12, 0x16, 0x0a, 0x06,
|
||||
|
|
@ -3443,9 +3443,9 @@ var file_job_proto_rawDesc = []byte{
|
|||
0x71, 0x75, 0x69, 0x72, 0x65, 0x64, 0x4e, 0x6f, 0x64, 0x65, 0x73, 0x12, 0x18, 0x0a, 0x07, 0x72,
|
||||
0x65, 0x71, 0x75, 0x65, 0x75, 0x65, 0x18, 0x4c, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x72, 0x65,
|
||||
0x71, 0x75, 0x65, 0x75, 0x65, 0x12, 0x1f, 0x0a, 0x0b, 0x72, 0x65, 0x73, 0x69, 0x7a, 0x65, 0x5f,
|
||||
0x74, 0x69, 0x6d, 0x65, 0x18, 0x4d, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0a, 0x72, 0x65, 0x73, 0x69,
|
||||
0x74, 0x69, 0x6d, 0x65, 0x18, 0x4d, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0a, 0x72, 0x65, 0x73, 0x69,
|
||||
0x7a, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x1f, 0x0a, 0x0b, 0x72, 0x65, 0x73, 0x74, 0x61, 0x72,
|
||||
0x74, 0x5f, 0x63, 0x6e, 0x74, 0x18, 0x4e, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x72, 0x65, 0x73,
|
||||
0x74, 0x5f, 0x63, 0x6e, 0x74, 0x18, 0x4e, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0a, 0x72, 0x65, 0x73,
|
||||
0x74, 0x61, 0x72, 0x74, 0x43, 0x6e, 0x74, 0x12, 0x1b, 0x0a, 0x09, 0x72, 0x65, 0x73, 0x76, 0x5f,
|
||||
0x6e, 0x61, 0x6d, 0x65, 0x18, 0x4f, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x72, 0x65, 0x73, 0x76,
|
||||
0x4e, 0x61, 0x6d, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x68, 0x61, 0x72, 0x65, 0x64, 0x18, 0x50,
|
||||
|
|
@ -3453,12 +3453,12 @@ var file_job_proto_rawDesc = []byte{
|
|||
0x73, 0x68, 0x6f, 0x77, 0x5f, 0x66, 0x6c, 0x61, 0x67, 0x73, 0x18, 0x51, 0x20, 0x03, 0x28, 0x09,
|
||||
0x52, 0x09, 0x73, 0x68, 0x6f, 0x77, 0x46, 0x6c, 0x61, 0x67, 0x73, 0x12, 0x2a, 0x0a, 0x11, 0x73,
|
||||
0x6f, 0x63, 0x6b, 0x65, 0x74, 0x73, 0x5f, 0x70, 0x65, 0x72, 0x5f, 0x62, 0x6f, 0x61, 0x72, 0x64,
|
||||
0x18, 0x52, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0f, 0x73, 0x6f, 0x63, 0x6b, 0x65, 0x74, 0x73, 0x50,
|
||||
0x18, 0x52, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0f, 0x73, 0x6f, 0x63, 0x6b, 0x65, 0x74, 0x73, 0x50,
|
||||
0x65, 0x72, 0x42, 0x6f, 0x61, 0x72, 0x64, 0x12, 0x28, 0x0a, 0x10, 0x73, 0x6f, 0x63, 0x6b, 0x65,
|
||||
0x74, 0x73, 0x5f, 0x70, 0x65, 0x72, 0x5f, 0x6e, 0x6f, 0x64, 0x65, 0x18, 0x53, 0x20, 0x01, 0x28,
|
||||
0x09, 0x52, 0x0e, 0x73, 0x6f, 0x63, 0x6b, 0x65, 0x74, 0x73, 0x50, 0x65, 0x72, 0x4e, 0x6f, 0x64,
|
||||
0x04, 0x52, 0x0e, 0x73, 0x6f, 0x63, 0x6b, 0x65, 0x74, 0x73, 0x50, 0x65, 0x72, 0x4e, 0x6f, 0x64,
|
||||
0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x73, 0x74, 0x61, 0x72, 0x74, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18,
|
||||
0x54, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x09, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65,
|
||||
0x54, 0x20, 0x01, 0x28, 0x04, 0x52, 0x09, 0x73, 0x74, 0x61, 0x72, 0x74, 0x54, 0x69, 0x6d, 0x65,
|
||||
0x12, 0x2b, 0x0a, 0x11, 0x73, 0x74, 0x61, 0x74, 0x65, 0x5f, 0x64, 0x65, 0x73, 0x63, 0x72, 0x69,
|
||||
0x70, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x55, 0x20, 0x01, 0x28, 0x09, 0x52, 0x10, 0x73, 0x74, 0x61,
|
||||
0x74, 0x65, 0x44, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x21, 0x0a,
|
||||
|
|
@ -3472,18 +3472,18 @@ var file_job_proto_rawDesc = []byte{
|
|||
0x0a, 0x0f, 0x73, 0x74, 0x61, 0x6e, 0x64, 0x61, 0x72, 0x64, 0x5f, 0x6f, 0x75, 0x74, 0x70, 0x75,
|
||||
0x74, 0x18, 0x59, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0e, 0x73, 0x74, 0x61, 0x6e, 0x64, 0x61, 0x72,
|
||||
0x64, 0x4f, 0x75, 0x74, 0x70, 0x75, 0x74, 0x12, 0x1f, 0x0a, 0x0b, 0x73, 0x75, 0x62, 0x6d, 0x69,
|
||||
0x74, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x5a, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0a, 0x73, 0x75,
|
||||
0x74, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x5a, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0a, 0x73, 0x75,
|
||||
0x62, 0x6d, 0x69, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x21, 0x0a, 0x0c, 0x73, 0x75, 0x73, 0x70,
|
||||
0x65, 0x6e, 0x64, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x5b, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0b,
|
||||
0x65, 0x6e, 0x64, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x5b, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0b,
|
||||
0x73, 0x75, 0x73, 0x70, 0x65, 0x6e, 0x64, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x25, 0x0a, 0x0e, 0x73,
|
||||
0x79, 0x73, 0x74, 0x65, 0x6d, 0x5f, 0x63, 0x6f, 0x6d, 0x6d, 0x65, 0x6e, 0x74, 0x18, 0x5c, 0x20,
|
||||
0x01, 0x28, 0x09, 0x52, 0x0d, 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x43, 0x6f, 0x6d, 0x6d, 0x65,
|
||||
0x6e, 0x74, 0x12, 0x1d, 0x0a, 0x0a, 0x74, 0x69, 0x6d, 0x65, 0x5f, 0x6c, 0x69, 0x6d, 0x69, 0x74,
|
||||
0x18, 0x5d, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x4c, 0x69, 0x6d, 0x69,
|
||||
0x18, 0x5d, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x4c, 0x69, 0x6d, 0x69,
|
||||
0x74, 0x12, 0x21, 0x0a, 0x0c, 0x74, 0x69, 0x6d, 0x65, 0x5f, 0x6d, 0x69, 0x6e, 0x69, 0x6d, 0x75,
|
||||
0x6d, 0x18, 0x5e, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x74, 0x69, 0x6d, 0x65, 0x4d, 0x69, 0x6e,
|
||||
0x6d, 0x18, 0x5e, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0b, 0x74, 0x69, 0x6d, 0x65, 0x4d, 0x69, 0x6e,
|
||||
0x69, 0x6d, 0x75, 0x6d, 0x12, 0x28, 0x0a, 0x10, 0x74, 0x68, 0x72, 0x65, 0x61, 0x64, 0x73, 0x5f,
|
||||
0x70, 0x65, 0x72, 0x5f, 0x63, 0x6f, 0x72, 0x65, 0x18, 0x5f, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0e,
|
||||
0x70, 0x65, 0x72, 0x5f, 0x63, 0x6f, 0x72, 0x65, 0x18, 0x5f, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0e,
|
||||
0x74, 0x68, 0x72, 0x65, 0x61, 0x64, 0x73, 0x50, 0x65, 0x72, 0x43, 0x6f, 0x72, 0x65, 0x12, 0x1b,
|
||||
0x0a, 0x09, 0x74, 0x72, 0x65, 0x73, 0x5f, 0x62, 0x69, 0x6e, 0x64, 0x18, 0x60, 0x20, 0x01, 0x28,
|
||||
0x09, 0x52, 0x08, 0x74, 0x72, 0x65, 0x73, 0x42, 0x69, 0x6e, 0x64, 0x12, 0x1b, 0x0a, 0x09, 0x74,
|
||||
|
|
@ -3503,7 +3503,7 @@ var file_job_proto_rawDesc = []byte{
|
|||
0x74, 0x72, 0x65, 0x73, 0x5f, 0x61, 0x6c, 0x6c, 0x6f, 0x63, 0x5f, 0x73, 0x74, 0x72, 0x18, 0x67,
|
||||
0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x74, 0x72, 0x65, 0x73, 0x41, 0x6c, 0x6c, 0x6f, 0x63, 0x53,
|
||||
0x74, 0x72, 0x12, 0x17, 0x0a, 0x07, 0x75, 0x73, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x68, 0x20,
|
||||
0x01, 0x28, 0x09, 0x52, 0x06, 0x75, 0x73, 0x65, 0x72, 0x49, 0x64, 0x12, 0x1b, 0x0a, 0x09, 0x75,
|
||||
0x01, 0x28, 0x05, 0x52, 0x06, 0x75, 0x73, 0x65, 0x72, 0x49, 0x64, 0x12, 0x1b, 0x0a, 0x09, 0x75,
|
||||
0x73, 0x65, 0x72, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x69, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08,
|
||||
0x75, 0x73, 0x65, 0x72, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x77, 0x63, 0x6b, 0x65,
|
||||
0x79, 0x18, 0x6a, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x77, 0x63, 0x6b, 0x65, 0x79, 0x12, 0x3a,
|
||||
|
|
@ -3518,7 +3518,7 @@ var file_job_proto_rawDesc = []byte{
|
|||
0x0a, 0x0d, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x5f, 0x63, 0x6f, 0x6d, 0x6d, 0x65, 0x6e, 0x74, 0x18,
|
||||
0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x43, 0x6f, 0x6d, 0x6d,
|
||||
0x65, 0x6e, 0x74, 0x12, 0x20, 0x0a, 0x0c, 0x61, 0x72, 0x72, 0x61, 0x79, 0x5f, 0x6a, 0x6f, 0x62,
|
||||
0x5f, 0x69, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x61, 0x72, 0x72, 0x61, 0x79,
|
||||
0x5f, 0x69, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0a, 0x61, 0x72, 0x72, 0x61, 0x79,
|
||||
0x4a, 0x6f, 0x62, 0x49, 0x64, 0x12, 0x22, 0x0a, 0x0d, 0x61, 0x72, 0x72, 0x61, 0x79, 0x5f, 0x74,
|
||||
0x61, 0x73, 0x6b, 0x5f, 0x69, 0x64, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x61, 0x72,
|
||||
0x72, 0x61, 0x79, 0x54, 0x61, 0x73, 0x6b, 0x49, 0x64, 0x12, 0x26, 0x0a, 0x0f, 0x61, 0x72, 0x72,
|
||||
|
|
@ -3559,7 +3559,7 @@ var file_job_proto_rawDesc = []byte{
|
|||
0x5f, 0x70, 0x65, 0x72, 0x5f, 0x73, 0x6f, 0x63, 0x6b, 0x65, 0x74, 0x18, 0x16, 0x20, 0x01, 0x28,
|
||||
0x09, 0x52, 0x0e, 0x63, 0x6f, 0x72, 0x65, 0x73, 0x50, 0x65, 0x72, 0x53, 0x6f, 0x63, 0x6b, 0x65,
|
||||
0x74, 0x12, 0x23, 0x0a, 0x0d, 0x62, 0x69, 0x6c, 0x6c, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x74, 0x72,
|
||||
0x65, 0x73, 0x18, 0x17, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x62, 0x69, 0x6c, 0x6c, 0x61, 0x62,
|
||||
0x65, 0x73, 0x18, 0x17, 0x20, 0x01, 0x28, 0x02, 0x52, 0x0c, 0x62, 0x69, 0x6c, 0x6c, 0x61, 0x62,
|
||||
0x6c, 0x65, 0x54, 0x72, 0x65, 0x73, 0x12, 0x22, 0x0a, 0x0d, 0x63, 0x70, 0x75, 0x73, 0x5f, 0x70,
|
||||
0x65, 0x72, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x18, 0x18, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63,
|
||||
0x70, 0x75, 0x73, 0x50, 0x65, 0x72, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x32, 0x0a, 0x15, 0x63, 0x70,
|
||||
|
|
|
|||
|
|
@ -1,7 +1,7 @@
|
|||
// Code generated by goctl. DO NOT EDIT.
|
||||
// Source: slurm.proto
|
||||
|
||||
package slurmclient
|
||||
package slurmClient
|
||||
|
||||
import (
|
||||
"context"
|
||||
|
|
|
|||
Loading…
Reference in New Issue