schedulerx

type BatchTaskStatues struct {
	Status      *int32            `protobuf:"varint,1,req,name=status" json:"status,omitempty"`
	WorkerAddr  *string           `protobuf:"bytes,2,opt,name=worker_addr,json=workerAddr" json:"worker_addr,omitempty"`
	WorkerId    *string           `protobuf:"bytes,3,opt,name=worker_id,json=workerId" json:"worker_id,omitempty"`
	TaskIds     []int64           `protobuf:"varint,4,rep,name=task_ids,json=taskIds" json:"task_ids,omitempty"`
	TaskStatues []*TaskStatusInfo `protobuf:"bytes,5,rep,name=task_statues,json=taskStatues" json:"task_statues,omitempty"`
	// contains filtered or unexported fields
}

type ContainerBatchReportTaskStatuesRequest struct {
	JobId                 *int64            `protobuf:"varint,1,req,name=job_id,json=jobId" json:"job_id,omitempty"`
	JobInstanceId         *int64            `protobuf:"varint,2,req,name=job_instance_id,json=jobInstanceId" json:"job_instance_id,omitempty"`
	TaskStatues           []*TaskStatusInfo `protobuf:"bytes,3,rep,name=task_statues,json=taskStatues" json:"task_statues,omitempty"`
	TaskMasterAkkaPath    *string           `protobuf:"bytes,4,req,name=task_master_akka_path,json=taskMasterAkkaPath" json:"task_master_akka_path,omitempty"`
	WorkerAddr            *string           `protobuf:"bytes,5,req,name=worker_addr,json=workerAddr" json:"worker_addr,omitempty"`
	WorkerId              *string           `protobuf:"bytes,6,req,name=worker_id,json=workerId" json:"worker_id,omitempty"`
	DeliveryId            *int64            `protobuf:"varint,7,opt,name=delivery_id,json=deliveryId" json:"delivery_id,omitempty"`
	AlreadyUnConfirmRetry *bool             `protobuf:"varint,8,opt,name=already_unConfirm_retry,json=alreadyUnConfirmRetry" json:"already_unConfirm_retry,omitempty"`
	SerialNum             *int64            `protobuf:"varint,9,opt,name=serial_num,json=serialNum" json:"serial_num,omitempty"`
	MetricsJson           *string           `protobuf:"bytes,10,opt,name=metrics_json,json=metricsJson" json:"metrics_json,omitempty"`
	// contains filtered or unexported fields
}

type ContainerBatchReportTaskStatuesResponse struct {
	Success    *bool   `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	Message    *string `protobuf:"bytes,2,opt,name=message,def=" json:"message,omitempty"`
	DeliveryId *int64  `protobuf:"varint,3,opt,name=delivery_id,json=deliveryId" json:"delivery_id,omitempty"`
	// contains filtered or unexported fields
}

type ContainerCheckZombieRequest struct {
	JobInstanceId []int64 `protobuf:"varint,1,rep,name=job_instance_id,json=jobInstanceId" json:"job_instance_id,omitempty"`
	// contains filtered or unexported fields
}

type ContainerCheckZombieResponse struct {
	ZombieJobInstanceId []int64 `protobuf:"varint,1,rep,name=zombie_job_instance_id,json=zombieJobInstanceId" json:"zombie_job_instance_id,omitempty"`
	// contains filtered or unexported fields
}

type ContainerReportTaskStatusRequest struct {
	JobId                   *int64  `protobuf:"varint,1,req,name=job_id,json=jobId" json:"job_id,omitempty"`
	JobInstanceId           *int64  `protobuf:"varint,2,req,name=job_instance_id,json=jobInstanceId" json:"job_instance_id,omitempty"`
	TaskId                  *int64  `protobuf:"varint,3,req,name=task_id,json=taskId" json:"task_id,omitempty"`
	Status                  *int32  `protobuf:"varint,4,req,name=status" json:"status,omitempty"`
	WorkerAddr              *string `protobuf:"bytes,5,req,name=worker_addr,json=workerAddr" json:"worker_addr,omitempty"`
	WorkerId                *string `protobuf:"bytes,6,req,name=worker_id,json=workerId" json:"worker_id,omitempty"`
	Result                  *string `protobuf:"bytes,7,opt,name=result" json:"result,omitempty"`
	TaskName                *string `protobuf:"bytes,8,opt,name=task_name,json=taskName" json:"task_name,omitempty"`
	InstanceMasterActorPath *string `protobuf:"bytes,9,opt,name=instance_master_actorPath,json=instanceMasterActorPath" json:"instance_master_actorPath,omitempty"`
	TimeType                *int32  `protobuf:"varint,10,opt,name=time_type,json=timeType" json:"time_type,omitempty"`
	SerialNum               *int64  `protobuf:"varint,11,opt,name=serial_num,json=serialNum" json:"serial_num,omitempty"`
	Progress                *string `protobuf:"bytes,12,opt,name=progress" json:"progress,omitempty"`
	TraceId                 *string `protobuf:"bytes,13,opt,name=traceId" json:"traceId,omitempty"`
	// contains filtered or unexported fields
}

type ContainerReportTaskStatusResponse struct {
	Success *bool   `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	Message *string `protobuf:"bytes,2,opt,name=message,def=" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type LabelWorkerAddrsEntry struct {
	Label       *string  `protobuf:"bytes,1,opt,name=label" json:"label,omitempty"`
	WorkerAddrs []string `protobuf:"bytes,2,rep,name=workerAddrs" json:"workerAddrs,omitempty"`
	// contains filtered or unexported fields
}

type MasterBatchStartContainersRequest struct {
	JobInstanceId *int64                         `protobuf:"varint,1,req,name=job_instance_id,json=jobInstanceId" json:"job_instance_id,omitempty"`
	StartReqs     []*MasterStartContainerRequest `protobuf:"bytes,2,rep,name=start_reqs,json=startReqs" json:"start_reqs,omitempty"`
	JobId         *int64                         `protobuf:"varint,3,opt,name=job_id,json=jobId" json:"job_id,omitempty"`
	SerialNum     *int64                         `protobuf:"varint,4,opt,name=serial_num,json=serialNum" json:"serial_num,omitempty"`
	// contains filtered or unexported fields
}

type MasterBatchStartContainersResponse struct {
	Success       *bool   `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	Message       *string `protobuf:"bytes,2,opt,name=message,def=" json:"message,omitempty"`
	FailedTaskIds []int64 `protobuf:"varint,3,rep,name=failed_taskIds,json=failedTaskIds" json:"failed_taskIds,omitempty"`
	MetricsJson   *string `protobuf:"bytes,4,opt,name=metrics_json,json=metricsJson" json:"metrics_json,omitempty"`
	// contains filtered or unexported fields
}

type MasterCheckWorkerAliveRequest struct {
	JobInstanceId *int64  `protobuf:"varint,1,req,name=job_instance_id,json=jobInstanceId" json:"job_instance_id,omitempty"`
	DispatchMode  *string `protobuf:"bytes,2,opt,name=dispatch_mode,json=dispatchMode" json:"dispatch_mode,omitempty"`
	// contains filtered or unexported fields
}

type MasterCheckWorkerAliveResponse struct {
	Success     *bool   `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	Message     *string `protobuf:"bytes,2,opt,name=message,def=" json:"message,omitempty"`
	MetricsJson *string `protobuf:"bytes,3,opt,name=metrics_json,json=metricsJson" json:"metrics_json,omitempty"`
	// contains filtered or unexported fields
}

type MasterDestroyContainerPoolRequest struct {
	JobInstanceId         *int64  `protobuf:"varint,1,req,name=job_instance_id,json=jobInstanceId" json:"job_instance_id,omitempty"`
	JobId                 *int64  `protobuf:"varint,2,opt,name=job_id,json=jobId" json:"job_id,omitempty"`
	WorkerIdAddr          *string `protobuf:"bytes,3,opt,name=worker_id_addr,json=workerIdAddr" json:"worker_id_addr,omitempty"`
	DeliveryId            *int64  `protobuf:"varint,4,opt,name=delivery_id,json=deliveryId" json:"delivery_id,omitempty"`
	AlreadyUnConfirmRetry *bool   `protobuf:"varint,5,opt,name=already_unConfirm_retry,json=alreadyUnConfirmRetry" json:"already_unConfirm_retry,omitempty"`
	SerialNum             *int64  `protobuf:"varint,6,opt,name=serial_num,json=serialNum" json:"serial_num,omitempty"`
	// contains filtered or unexported fields
}

type MasterDestroyContainerPoolResponse struct {
	Success    *bool   `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	Message    *string `protobuf:"bytes,2,opt,name=message,def=" json:"message,omitempty"`
	DeliveryId *int64  `protobuf:"varint,3,opt,name=delivery_id,json=deliveryId" json:"delivery_id,omitempty"`
	// contains filtered or unexported fields
}

type MasterKillContainerRequest struct {
	JobId                 *int64  `protobuf:"varint,1,req,name=job_id,json=jobId" json:"job_id,omitempty"`
	JobInstanceId         *int64  `protobuf:"varint,2,req,name=job_instance_id,json=jobInstanceId" json:"job_instance_id,omitempty"`
	TaskId                *int64  `protobuf:"varint,3,opt,name=task_id,json=taskId" json:"task_id,omitempty"`
	User                  *string `protobuf:"bytes,4,opt,name=user" json:"user,omitempty"`
	MayInterruptIfRunning *bool   `protobuf:"varint,5,req,name=mayInterruptIfRunning" json:"mayInterruptIfRunning,omitempty"`
	AppGroupId            *int64  `protobuf:"varint,6,opt,name=app_group_id,json=appGroupId" json:"app_group_id,omitempty"`
	// contains filtered or unexported fields
}

type MasterKillContainerResponse struct {
	Success *bool   `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	Message *string `protobuf:"bytes,2,opt,name=message,def=" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type MasterNotifyWorkerPullRequest struct {
	JobInstanceId      *int64  `protobuf:"varint,1,req,name=job_instance_id,json=jobInstanceId" json:"job_instance_id,omitempty"`
	PageSize           *int32  `protobuf:"varint,2,req,name=page_size,json=pageSize" json:"page_size,omitempty"`
	QueueSize          *int32  `protobuf:"varint,3,req,name=queue_size,json=queueSize" json:"queue_size,omitempty"`
	ConsumerSize       *int32  `protobuf:"varint,4,req,name=consumer_size,json=consumerSize" json:"consumer_size,omitempty"`
	TaskMasterAkkaPath *string `protobuf:"bytes,5,req,name=task_master_akka_path,json=taskMasterAkkaPath" json:"task_master_akka_path,omitempty"`
	SerialNum          *int64  `protobuf:"varint,6,opt,name=serial_num,json=serialNum" json:"serial_num,omitempty"`
	// contains filtered or unexported fields
}

type MasterNotifyWorkerPullResponse struct {
	Success *bool   `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	Message *string `protobuf:"bytes,2,opt,name=message,def=" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type MasterStartContainerRequest struct {
	JobId                  *int64          `protobuf:"varint,1,req,name=job_id,json=jobId" json:"job_id,omitempty"`
	JobInstanceId          *int64          `protobuf:"varint,2,req,name=job_instance_id,json=jobInstanceId" json:"job_instance_id,omitempty"`
	TaskId                 *int64          `protobuf:"varint,3,req,name=task_id,json=taskId" json:"task_id,omitempty"`
	ScheduleTime           *int64          `protobuf:"varint,4,req,name=schedule_time,json=scheduleTime" json:"schedule_time,omitempty"`
	DataTime               *int64          `protobuf:"varint,5,req,name=data_time,json=dataTime" json:"data_time,omitempty"`
	JobType                *string         `protobuf:"bytes,6,req,name=job_type,json=jobType" json:"job_type,omitempty"`
	Content                *string         `protobuf:"bytes,7,req,name=content" json:"content,omitempty"`
	User                   *string         `protobuf:"bytes,8,req,name=user" json:"user,omitempty"`
	Parameters             *string         `protobuf:"bytes,9,opt,name=parameters" json:"parameters,omitempty"`
	InstanceMasterAkkaPath *string         `protobuf:"bytes,10,req,name=instance_master_akka_path,json=instanceMasterAkkaPath" json:"instance_master_akka_path,omitempty"`
	TaskName               *string         `protobuf:"bytes,11,opt,name=task_name,json=taskName" json:"task_name,omitempty"`
	Task                   []byte          `protobuf:"bytes,12,opt,name=task" json:"task,omitempty"`
	ConsumerNum            *int32          `protobuf:"varint,13,opt,name=consumer_num,json=consumerNum" json:"consumer_num,omitempty"`
	GroupId                *string         `protobuf:"bytes,14,req,name=group_id,json=groupId" json:"group_id,omitempty"`
	InstanceParameters     *string         `protobuf:"bytes,15,opt,name=instance_parameters,json=instanceParameters" json:"instance_parameters,omitempty"`
	UpstreamData           []*UpstreamData `protobuf:"bytes,16,rep,name=upstreamData" json:"upstreamData,omitempty"`
	MaxAttempt             *int32          `protobuf:"varint,17,opt,name=max_attempt,json=maxAttempt" json:"max_attempt,omitempty"`
	Attempt                *int32          `protobuf:"varint,18,opt,name=attempt" json:"attempt,omitempty"`
	TaskMaxAttempt         *int32          `protobuf:"varint,19,opt,name=task_max_attempt,json=taskMaxAttempt" json:"task_max_attempt,omitempty"`
	TaskAttemptInterval    *int32          `protobuf:"varint,20,opt,name=task_attempt_interval,json=taskAttemptInterval" json:"task_attempt_interval,omitempty"`
	Failover               *bool           `protobuf:"varint,21,opt,name=failover,def=0" json:"failover,omitempty"`
	WfInstanceId           *int64          `protobuf:"varint,22,opt,name=wf_instance_id,json=wfInstanceId" json:"wf_instance_id,omitempty"`
	SerialNum              *int64          `protobuf:"varint,23,opt,name=serial_num,json=serialNum" json:"serial_num,omitempty"`
	ExecuteMode            *string         `protobuf:"bytes,24,opt,name=execute_mode,json=executeMode" json:"execute_mode,omitempty"`
	JobName                *string         `protobuf:"bytes,25,opt,name=job_name,json=jobName" json:"job_name,omitempty"`
	ShardingNum            *int32          `protobuf:"varint,26,opt,name=sharding_num,json=shardingNum" json:"sharding_num,omitempty"`
	TimeType               *int32          `protobuf:"varint,27,opt,name=time_type,json=timeType" json:"time_type,omitempty"`
	TimeExpression         *string         `protobuf:"bytes,28,opt,name=time_expression,json=timeExpression" json:"time_expression,omitempty"`
	Xattrs                 *string         `protobuf:"bytes,29,opt,name=xattrs" json:"xattrs,omitempty"`
	Namespace              *string         `protobuf:"bytes,30,opt,name=namespace" json:"namespace,omitempty"`
	TriggerType            *int32          `protobuf:"varint,31,opt,name=trigger_type,json=triggerType" json:"trigger_type,omitempty"`
	Template               *string         `protobuf:"bytes,32,opt,name=template" json:"template,omitempty"`
	AppGroupId             *int64          `protobuf:"varint,33,opt,name=app_group_id,json=appGroupId" json:"app_group_id,omitempty"`
	// contains filtered or unexported fields
}

type MasterStartContainerResponse struct {
	Success *bool   `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	Message *string `protobuf:"bytes,2,opt,name=message,def=" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type PullTaskFromMasterRequest struct {
	JobInstanceId *int64  `protobuf:"varint,1,req,name=job_instance_id,json=jobInstanceId" json:"job_instance_id,omitempty"`
	PageSize      *int32  `protobuf:"varint,2,req,name=page_size,json=pageSize" json:"page_size,omitempty"`
	WorkerIdAddr  *string `protobuf:"bytes,3,req,name=worker_id_addr,json=workerIdAddr" json:"worker_id_addr,omitempty"`
	SerialNum     *int64  `protobuf:"varint,4,opt,name=serial_num,json=serialNum" json:"serial_num,omitempty"`
	// contains filtered or unexported fields
}

type PullTaskFromMasterResponse struct {
	Success *bool                          `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	Message *string                        `protobuf:"bytes,2,opt,name=message,def=" json:"message,omitempty"`
	Request []*MasterStartContainerRequest `protobuf:"bytes,3,rep,name=request" json:"request,omitempty"`
	// contains filtered or unexported fields
}

type RetryTaskEntity struct {
	TaskId     *int64  `protobuf:"varint,1,req,name=task_id,json=taskId" json:"task_id,omitempty"`
	TaskName   *string `protobuf:"bytes,2,req,name=task_name,json=taskName" json:"task_name,omitempty"`
	WorkerAddr *string `protobuf:"bytes,3,req,name=worker_addr,json=workerAddr" json:"worker_addr,omitempty"`
	OldStatus  *int32  `protobuf:"varint,4,req,name=old_status,json=oldStatus" json:"old_status,omitempty"`
	// contains filtered or unexported fields
}

type ServerCallbackCalendarRequest struct {
	Processor     *string `protobuf:"bytes,1,req,name=processor" json:"processor,omitempty"`
	Timestamp     *int64  `protobuf:"varint,2,req,name=timestamp" json:"timestamp,omitempty"`
	JobInstanceId *int64  `protobuf:"varint,3,req,name=job_instance_id,json=jobInstanceId" json:"job_instance_id,omitempty"`
	// contains filtered or unexported fields
}

type ServerCallbackCalendarResponse struct {
	Success *bool   `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	Message *string `protobuf:"bytes,2,opt,name=message,def=" json:"message,omitempty"`
	Result  *bool   `protobuf:"varint,3,opt,name=result" json:"result,omitempty"`
	// contains filtered or unexported fields
}

type ServerCheckTaskMasterRequest struct {
	JobInstanceId *int64 `protobuf:"varint,1,req,name=job_instance_id,json=jobInstanceId" json:"job_instance_id,omitempty"`
	// contains filtered or unexported fields
}

type ServerCheckTaskMasterResponse struct {
	Success *bool   `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	Message *string `protobuf:"bytes,2,opt,name=message,def=" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type ServerCreateAppRequest struct {
	Name        *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Description *string `protobuf:"bytes,2,req,name=description" json:"description,omitempty"`
	RegionId    *int32  `protobuf:"varint,3,req,name=region_id,json=regionId" json:"region_id,omitempty"`
	Creator     *string `protobuf:"bytes,4,req,name=creator" json:"creator,omitempty"`
	// contains filtered or unexported fields
}

type ServerCreateAppResponse struct {
	Success *bool   `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	Message *string `protobuf:"bytes,2,opt,name=message,def=" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type ServerCreateRegionRequest struct {
	Name        *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Description *string `protobuf:"bytes,2,req,name=description" json:"description,omitempty"`
	User        *string `protobuf:"bytes,3,req,name=user" json:"user,omitempty"`
	// contains filtered or unexported fields
}

type ServerCreateRegionResponse struct {
	Success *bool   `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	Message *string `protobuf:"bytes,2,opt,name=message,def=" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type ServerKillJobInstanceRequest struct {
	JobId         *int64  `protobuf:"varint,1,req,name=job_id,json=jobId" json:"job_id,omitempty"`
	JobInstanceId *int64  `protobuf:"varint,2,req,name=job_instance_id,json=jobInstanceId" json:"job_instance_id,omitempty"`
	User          *string `protobuf:"bytes,3,opt,name=user" json:"user,omitempty"`
	DestoryJob    *bool   `protobuf:"varint,4,opt,name=destory_job,json=destoryJob" json:"destory_job,omitempty"`
	JobType       *string `protobuf:"bytes,5,opt,name=job_type,json=jobType" json:"job_type,omitempty"`
	Content       *string `protobuf:"bytes,6,opt,name=content" json:"content,omitempty"`
	Namespace     *string `protobuf:"bytes,7,opt,name=namespace" json:"namespace,omitempty"`
	Xattrs        *string `protobuf:"bytes,8,opt,name=xattrs" json:"xattrs,omitempty"`
	ExecuteMode   *string `protobuf:"bytes,9,opt,name=execute_mode,json=executeMode" json:"execute_mode,omitempty"`
	AppGroupId    *int64  `protobuf:"varint,10,opt,name=app_group_id,json=appGroupId" json:"app_group_id,omitempty"`
	// contains filtered or unexported fields
}

type ServerKillJobInstanceResponse struct {
	Success *bool   `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	Message *string `protobuf:"bytes,2,opt,name=message,def=" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type ServerKillTaskRequest struct {
	JobId         *int64  `protobuf:"varint,1,req,name=job_id,json=jobId" json:"job_id,omitempty"`
	JobInstanceId *int64  `protobuf:"varint,2,req,name=job_instance_id,json=jobInstanceId" json:"job_instance_id,omitempty"`
	TaskId        *int64  `protobuf:"varint,3,req,name=task_id,json=taskId" json:"task_id,omitempty"`
	User          *string `protobuf:"bytes,4,opt,name=user" json:"user,omitempty"`
	WorkerId      *string `protobuf:"bytes,5,req,name=worker_id,json=workerId" json:"worker_id,omitempty"`
	WorkerAddr    *string `protobuf:"bytes,6,req,name=worker_addr,json=workerAddr" json:"worker_addr,omitempty"`
	// contains filtered or unexported fields
}

type ServerKillTaskResponse struct {
	Success *bool   `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	Message *string `protobuf:"bytes,2,opt,name=message,def=" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type ServerPushLogConfigRequest struct {
	Enable *bool   `protobuf:"varint,1,req,name=enable" json:"enable,omitempty"`
	Config *string `protobuf:"bytes,2,opt,name=config" json:"config,omitempty"`
	Type   *string `protobuf:"bytes,3,opt,name=type" json:"type,omitempty"`
	Level  *string `protobuf:"bytes,4,opt,name=level" json:"level,omitempty"`
	SlsAk  *string `protobuf:"bytes,5,opt,name=sls_ak,json=slsAk" json:"sls_ak,omitempty"`
	SlsSk  *string `protobuf:"bytes,6,opt,name=sls_sk,json=slsSk" json:"sls_sk,omitempty"`
	// contains filtered or unexported fields
}

type ServerPushLogConfigResponse struct {
	Success *bool   `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	Message *string `protobuf:"bytes,2,opt,name=message,def=" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type ServerReadLogCharsRequest struct {
	JobId         *int64 `protobuf:"varint,1,req,name=job_id,json=jobId" json:"job_id,omitempty"`
	JobInstanceId *int64 `protobuf:"varint,2,req,name=job_instance_id,json=jobInstanceId" json:"job_instance_id,omitempty"`
	TaskId        *int64 `protobuf:"varint,3,opt,name=task_id,json=taskId,def=1" json:"task_id,omitempty"`
	ScheduleTime  *int64 `protobuf:"varint,4,req,name=schedule_time,json=scheduleTime" json:"schedule_time,omitempty"`
	Offset        *int64 `protobuf:"varint,5,req,name=offset" json:"offset,omitempty"`
	Size          *int32 `protobuf:"varint,6,req,name=size" json:"size,omitempty"`
	// contains filtered or unexported fields
}

type ServerReadLogCharsResponse struct {
	Success *bool   `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	Message *string `protobuf:"bytes,2,opt,name=message,def=" json:"message,omitempty"`
	Log     *string `protobuf:"bytes,3,opt,name=log" json:"log,omitempty"`
	Offset  *int64  `protobuf:"varint,4,opt,name=offset" json:"offset,omitempty"`
	IsEnd   *bool   `protobuf:"varint,5,opt,name=is_end,json=isEnd" json:"is_end,omitempty"`
	// contains filtered or unexported fields
}

type ServerReadLogRequest struct {
	JobId         *int64 `protobuf:"varint,1,req,name=job_id,json=jobId" json:"job_id,omitempty"`
	JobInstanceId *int64 `protobuf:"varint,2,req,name=job_instance_id,json=jobInstanceId" json:"job_instance_id,omitempty"`
	TaskId        *int64 `protobuf:"varint,3,opt,name=task_id,json=taskId,def=1" json:"task_id,omitempty"`
	ScheduleTime  *int64 `protobuf:"varint,4,req,name=schedule_time,json=scheduleTime" json:"schedule_time,omitempty"`
	Offset        *int64 `protobuf:"varint,5,req,name=offset" json:"offset,omitempty"`
	Size          *int32 `protobuf:"varint,6,req,name=size" json:"size,omitempty"`
	// contains filtered or unexported fields
}

type ServerReadLogResponse struct {
	Success *bool    `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	Message *string  `protobuf:"bytes,2,opt,name=message,def=" json:"message,omitempty"`
	Line    []string `protobuf:"bytes,3,rep,name=line" json:"line,omitempty"`
	Offset  *int64   `protobuf:"varint,4,opt,name=offset" json:"offset,omitempty"`
	IsEnd   *bool    `protobuf:"varint,5,req,name=is_end,json=isEnd" json:"is_end,omitempty"`
	// contains filtered or unexported fields
}

type ServerRetryTasksRequest struct {
	JobId              *int64             `protobuf:"varint,1,req,name=job_id,json=jobId" json:"job_id,omitempty"`
	JobInstanceId      *int64             `protobuf:"varint,2,req,name=job_instance_id,json=jobInstanceId" json:"job_instance_id,omitempty"`
	ScheduleTime       *int64             `protobuf:"varint,3,req,name=schedule_time,json=scheduleTime" json:"schedule_time,omitempty"`
	DataTime           *int64             `protobuf:"varint,4,req,name=data_time,json=dataTime" json:"data_time,omitempty"`
	JobType            *string            `protobuf:"bytes,5,req,name=job_type,json=jobType" json:"job_type,omitempty"`
	ExecuteMode        *string            `protobuf:"bytes,6,req,name=execute_mode,json=executeMode" json:"execute_mode,omitempty"`
	Content            *string            `protobuf:"bytes,7,req,name=content" json:"content,omitempty"`
	User               *string            `protobuf:"bytes,8,req,name=user" json:"user,omitempty"`
	Xattrs             *string            `protobuf:"bytes,9,opt,name=xattrs" json:"xattrs,omitempty"`
	Parameters         *string            `protobuf:"bytes,10,opt,name=parameters" json:"parameters,omitempty"`
	Workers            []string           `protobuf:"bytes,11,rep,name=workers" json:"workers,omitempty"`
	JobConcurrency     *int32             `protobuf:"varint,12,req,name=job_concurrency,json=jobConcurrency" json:"job_concurrency,omitempty"`
	RegionId           *int32             `protobuf:"varint,13,req,name=region_id,json=regionId" json:"region_id,omitempty"`
	AppGroupId         *int64             `protobuf:"varint,14,req,name=app_group_id,json=appGroupId" json:"app_group_id,omitempty"`
	InstanceParameters *string            `protobuf:"bytes,15,opt,name=instance_parameters,json=instanceParameters" json:"instance_parameters,omitempty"`
	UpstreamData       []*UpstreamData    `protobuf:"bytes,16,rep,name=upstreamData" json:"upstreamData,omitempty"`
	GroupId            *string            `protobuf:"bytes,17,opt,name=group_id,json=groupId" json:"group_id,omitempty"`
	TimeType           *int32             `protobuf:"varint,18,opt,name=time_type,json=timeType" json:"time_type,omitempty"`
	TimeExpression     *string            `protobuf:"bytes,19,opt,name=time_expression,json=timeExpression" json:"time_expression,omitempty"`
	MaxAttempt         *int32             `protobuf:"varint,20,opt,name=max_attempt,json=maxAttempt" json:"max_attempt,omitempty"`
	Attempt            *int32             `protobuf:"varint,21,opt,name=attempt" json:"attempt,omitempty"`
	WfInstanceId       *int64             `protobuf:"varint,22,opt,name=wf_instance_id,json=wfInstanceId" json:"wf_instance_id,omitempty"`
	RetryTaskEntity    []*RetryTaskEntity `protobuf:"bytes,23,rep,name=retry_task_entity,json=retryTaskEntity" json:"retry_task_entity,omitempty"`
	JobName            *string            `protobuf:"bytes,24,opt,name=job_name,json=jobName" json:"job_name,omitempty"`
	// contains filtered or unexported fields
}

type ServerRetryTasksResponse struct {
	Success *bool   `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	Message *string `protobuf:"bytes,2,opt,name=message,def=" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type ServerSubmitJobInstanceRequest struct {
	JobId                *int64                   `protobuf:"varint,1,req,name=job_id,json=jobId" json:"job_id,omitempty"`
	JobInstanceId        *int64                   `protobuf:"varint,2,req,name=job_instance_id,json=jobInstanceId" json:"job_instance_id,omitempty"`
	ScheduleTime         *int64                   `protobuf:"varint,3,req,name=schedule_time,json=scheduleTime" json:"schedule_time,omitempty"`
	DataTime             *int64                   `protobuf:"varint,4,req,name=data_time,json=dataTime" json:"data_time,omitempty"`
	JobType              *string                  `protobuf:"bytes,5,req,name=job_type,json=jobType" json:"job_type,omitempty"`
	ExecuteMode          *string                  `protobuf:"bytes,6,req,name=execute_mode,json=executeMode" json:"execute_mode,omitempty"`
	Content              *string                  `protobuf:"bytes,7,req,name=content" json:"content,omitempty"`
	User                 *string                  `protobuf:"bytes,8,req,name=user" json:"user,omitempty"`
	Xattrs               *string                  `protobuf:"bytes,9,opt,name=xattrs" json:"xattrs,omitempty"`
	Parameters           *string                  `protobuf:"bytes,10,opt,name=parameters" json:"parameters,omitempty"`
	Workers              []string                 `protobuf:"bytes,11,rep,name=workers" json:"workers,omitempty"`
	JobConcurrency       *int32                   `protobuf:"varint,12,req,name=job_concurrency,json=jobConcurrency" json:"job_concurrency,omitempty"`
	RegionId             *int32                   `protobuf:"varint,13,req,name=region_id,json=regionId" json:"region_id,omitempty"`
	AppGroupId           *int64                   `protobuf:"varint,14,req,name=app_group_id,json=appGroupId" json:"app_group_id,omitempty"`
	InstanceParameters   *string                  `protobuf:"bytes,15,opt,name=instance_parameters,json=instanceParameters" json:"instance_parameters,omitempty"`
	UpstreamData         []*UpstreamData          `protobuf:"bytes,16,rep,name=upstreamData" json:"upstreamData,omitempty"`
	GroupId              *string                  `protobuf:"bytes,17,opt,name=group_id,json=groupId" json:"group_id,omitempty"`
	TimeType             *int32                   `protobuf:"varint,18,opt,name=time_type,json=timeType" json:"time_type,omitempty"`
	TimeExpression       *string                  `protobuf:"bytes,19,opt,name=time_expression,json=timeExpression" json:"time_expression,omitempty"`
	MaxAttempt           *int32                   `protobuf:"varint,20,opt,name=max_attempt,json=maxAttempt" json:"max_attempt,omitempty"`
	Attempt              *int32                   `protobuf:"varint,21,opt,name=attempt" json:"attempt,omitempty"`
	WfInstanceId         *int64                   `protobuf:"varint,22,opt,name=wf_instance_id,json=wfInstanceId" json:"wf_instance_id,omitempty"`
	JobName              *string                  `protobuf:"bytes,23,opt,name=job_name,json=jobName" json:"job_name,omitempty"`
	Namespace            *string                  `protobuf:"bytes,24,opt,name=namespace" json:"namespace,omitempty"`
	TriggerType          *int32                   `protobuf:"varint,25,opt,name=trigger_type,json=triggerType" json:"trigger_type,omitempty"`
	RouteStrategyType    *int32                   `protobuf:"varint,26,opt,name=route_strategy_type,json=routeStrategyType" json:"route_strategy_type,omitempty"`
	RouteStrategyContent *string                  `protobuf:"bytes,27,opt,name=route_strategy_content,json=routeStrategyContent" json:"route_strategy_content,omitempty"`
	LabelWorkerAddrsMap  []*LabelWorkerAddrsEntry `protobuf:"bytes,28,rep,name=label_worker_addrs_map,json=labelWorkerAddrsMap" json:"label_worker_addrs_map,omitempty"`
	Template             *string                  `protobuf:"bytes,29,opt,name=template" json:"template,omitempty"`
	// contains filtered or unexported fields
}