schedulerx

package
v1.0.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 24, 2024 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Default_ServerThreadDumpRequest_TaskId = int64(1)
	Default_ServerThreadDumpRequest_Line   = int32(20)
)

Default values for ServerThreadDumpRequest fields.

View Source 
const (
	Default_ContainerBatchReportTaskStatuesResponse_Message = string("")
)

Default values for ContainerBatchReportTaskStatuesResponse fields.

View Source 
const (
	Default_ContainerReportTaskStatusResponse_Message = string("")
)

Default values for ContainerReportTaskStatusResponse fields.

View Source 
const (
	Default_MasterBatchStartContainersResponse_Message = string("")
)

Default values for MasterBatchStartContainersResponse fields.

View Source 
const (
	Default_MasterCheckWorkerAliveResponse_Message = string("")
)

Default values for MasterCheckWorkerAliveResponse fields.

View Source 
const (
	Default_MasterDestroyContainerPoolResponse_Message = string("")
)

Default values for MasterDestroyContainerPoolResponse fields.

View Source 
const (
	Default_MasterKillContainerResponse_Message = string("")
)

Default values for MasterKillContainerResponse fields.

View Source 
const (
	Default_MasterNotifyWorkerPullResponse_Message = string("")
)

Default values for MasterNotifyWorkerPullResponse fields.

View Source 
const (
	Default_MasterStartContainerRequest_Failover = bool(false)
)

Default values for MasterStartContainerRequest fields.

View Source 
const (
	Default_MasterStartContainerResponse_Message = string("")
)

Default values for MasterStartContainerResponse fields.

View Source 
const (
	Default_PullTaskFromMasterResponse_Message = string("")
)

Default values for PullTaskFromMasterResponse fields.

View Source 
const (
	Default_ServerCallbackCalendarResponse_Message = string("")
)

Default values for ServerCallbackCalendarResponse fields.

View Source 
const (
	Default_ServerCheckTaskMasterResponse_Message = string("")
)

Default values for ServerCheckTaskMasterResponse fields.

View Source 
const (
	Default_ServerCreateAppResponse_Message = string("")
)

Default values for ServerCreateAppResponse fields.

View Source 
const (
	Default_ServerCreateRegionResponse_Message = string("")
)

Default values for ServerCreateRegionResponse fields.

View Source 
const (
	Default_ServerKillJobInstanceResponse_Message = string("")
)

Default values for ServerKillJobInstanceResponse fields.

View Source 
const (
	Default_ServerKillTaskResponse_Message = string("")
)

Default values for ServerKillTaskResponse fields.

View Source 
const (
	Default_ServerPushLogConfigResponse_Message = string("")
)

Default values for ServerPushLogConfigResponse fields.

View Source 
const (
	Default_ServerReadLogCharsRequest_TaskId = int64(1)
)

Default values for ServerReadLogCharsRequest fields.

View Source 
const (
	Default_ServerReadLogCharsResponse_Message = string("")
)

Default values for ServerReadLogCharsResponse fields.

View Source 
const (
	Default_ServerReadLogRequest_TaskId = int64(1)
)

Default values for ServerReadLogRequest fields.

View Source 
const (
	Default_ServerReadLogResponse_Message = string("")
)

Default values for ServerReadLogResponse fields.

View Source 
const (
	Default_ServerRetryTasksResponse_Message = string("")
)

Default values for ServerRetryTasksResponse fields.

View Source 
const (
	Default_ServerSubmitJobInstanceResponse_Message = string("")
)

Default values for ServerSubmitJobInstanceResponse fields.

View Source 
const (
	Default_ServerSyncK8SCronJobResponse_Message = string("")
)

Default values for ServerSyncK8SCronJobResponse fields.

View Source 
const (
	Default_ServerSyncK8SJobResponse_Message = string("")
)

Default values for ServerSyncK8SJobResponse fields.

View Source 
const (
	Default_ServerTailLogRequest_TaskId = int64(1)
)

Default values for ServerTailLogRequest fields.

View Source 
const (
	Default_ServerTailLogResponse_Message = string("")
)

Default values for ServerTailLogResponse fields.

View Source 
const (
	Default_ServerThreadDumpResponse_Message = string("")
)

Default values for ServerThreadDumpResponse fields.

View Source 
const (
	Default_WorkerBatchCreateTasksResponse_Message = string("")
)

Default values for WorkerBatchCreateTasksResponse fields.

View Source 
const (
	Default_WorkerBatchReportTaskStatuesResponse_Message = string("")
)

Default values for WorkerBatchReportTaskStatuesResponse fields.

View Source 
const (
	Default_WorkerBatchUpdateTaskStatusResponse_Message = string("")
)

Default values for WorkerBatchUpdateTaskStatusResponse fields.

View Source 
const (
	Default_WorkerClearTasksResponse_Message = string("")
)

Default values for WorkerClearTasksResponse fields.

View Source 
const (
	Default_WorkerCreateTaskResponse_Message = string("")
)

Default values for WorkerCreateTaskResponse fields.

View Source 
const (
	Default_WorkerHeartBeatResponse_Message = string("")
)

Default values for WorkerHeartBeatResponse fields.

View Source 
const (
	Default_WorkerMapTaskResponse_Message = string("")
)

Default values for WorkerMapTaskResponse fields.

View Source 
const (
	Default_WorkerOfflineResponse_Message = string("")
)

Default values for WorkerOfflineResponse fields.

View Source 
const (
	Default_WorkerPullTasksResponse_Message = string("")
)

Default values for WorkerPullTasksResponse fields.

View Source 
const (
	Default_WorkerQueryJobInstanceStatusResponse_Message = string("")
)

Default values for WorkerQueryJobInstanceStatusResponse fields.

View Source 
const (
	Default_WorkerReportJobInstanceProgressResponse_Message = string("")
)

Default values for WorkerReportJobInstanceProgressResponse fields.

View Source 
const (
	Default_WorkerReportJobInstanceStatusResponse_Message = string("")
)

Default values for WorkerReportJobInstanceStatusResponse fields.

View Source 
const (
	Default_WorkerReportTaskListStatusResponse_Message = string("")
)

Default values for WorkerReportTaskListStatusResponse fields.

View Source 
const (
	Default_WorkerReportTaskProgressResponse_Message = string("")
)

Default values for WorkerReportTaskProgressResponse fields.

View Source 
const (
	Default_WorkerReportTaskStatusResponse_Message = string("")
)

Default values for WorkerReportTaskStatusResponse fields.

Variables

View Source 
var File_common_proto protoreflect.FileDescriptor
View Source 
var File_server_proto protoreflect.FileDescriptor
View Source 
var File_worker_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BatchTaskStatues 

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
}

func (*BatchTaskStatues) Descriptor deprecated 

func (*BatchTaskStatues) Descriptor() ([]byte, []int)

Deprecated: Use BatchTaskStatues.ProtoReflect.Descriptor instead.

func (*BatchTaskStatues) GetStatus 

func (x *BatchTaskStatues) GetStatus() int32

func (*BatchTaskStatues) GetTaskIds 

func (x *BatchTaskStatues) GetTaskIds() []int64

func (*BatchTaskStatues) GetTaskStatues 

func (x *BatchTaskStatues) GetTaskStatues() []*TaskStatusInfo

func (*BatchTaskStatues) GetWorkerAddr 

func (x *BatchTaskStatues) GetWorkerAddr() string

func (*BatchTaskStatues) GetWorkerId 

func (x *BatchTaskStatues) GetWorkerId() string

func (*BatchTaskStatues) ProtoMessage 

func (*BatchTaskStatues) ProtoMessage()

func (*BatchTaskStatues) ProtoReflect 

func (x *BatchTaskStatues) ProtoReflect() protoreflect.Message

func (*BatchTaskStatues) Reset 

func (x *BatchTaskStatues) Reset()

func (*BatchTaskStatues) String 

func (x *BatchTaskStatues) String() string

type ContainerBatchReportTaskStatuesRequest 

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
}

func (*ContainerBatchReportTaskStatuesRequest) Descriptor deprecated 

func (*ContainerBatchReportTaskStatuesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ContainerBatchReportTaskStatuesRequest.ProtoReflect.Descriptor instead.

func (*ContainerBatchReportTaskStatuesRequest) GetAlreadyUnConfirmRetry 

func (x *ContainerBatchReportTaskStatuesRequest) GetAlreadyUnConfirmRetry() bool

func (*ContainerBatchReportTaskStatuesRequest) GetDeliveryId 

func (x *ContainerBatchReportTaskStatuesRequest) GetDeliveryId() int64

func (*ContainerBatchReportTaskStatuesRequest) GetJobId 

func (x *ContainerBatchReportTaskStatuesRequest) GetJobId() int64

func (*ContainerBatchReportTaskStatuesRequest) GetJobInstanceId 

func (x *ContainerBatchReportTaskStatuesRequest) GetJobInstanceId() int64

func (*ContainerBatchReportTaskStatuesRequest) GetMetricsJson 

func (x *ContainerBatchReportTaskStatuesRequest) GetMetricsJson() string

func (*ContainerBatchReportTaskStatuesRequest) GetSerialNum 

func (x *ContainerBatchReportTaskStatuesRequest) GetSerialNum() int64

func (*ContainerBatchReportTaskStatuesRequest) GetTaskMasterAkkaPath 

func (x *ContainerBatchReportTaskStatuesRequest) GetTaskMasterAkkaPath() string

func (*ContainerBatchReportTaskStatuesRequest) GetTaskStatues 

func (x *ContainerBatchReportTaskStatuesRequest) GetTaskStatues() []*TaskStatusInfo

func (*ContainerBatchReportTaskStatuesRequest) GetWorkerAddr 

func (x *ContainerBatchReportTaskStatuesRequest) GetWorkerAddr() string

func (*ContainerBatchReportTaskStatuesRequest) GetWorkerId 

func (x *ContainerBatchReportTaskStatuesRequest) GetWorkerId() string

func (*ContainerBatchReportTaskStatuesRequest) ProtoMessage 

func (*ContainerBatchReportTaskStatuesRequest) ProtoMessage()

func (*ContainerBatchReportTaskStatuesRequest) ProtoReflect 

func (x *ContainerBatchReportTaskStatuesRequest) ProtoReflect() protoreflect.Message

func (*ContainerBatchReportTaskStatuesRequest) Reset 

func (x *ContainerBatchReportTaskStatuesRequest) Reset()

func (*ContainerBatchReportTaskStatuesRequest) String 

func (x *ContainerBatchReportTaskStatuesRequest) String() string

type ContainerBatchReportTaskStatuesResponse 

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
}

func (*ContainerBatchReportTaskStatuesResponse) Descriptor deprecated 

func (*ContainerBatchReportTaskStatuesResponse) Descriptor() ([]byte, []int)

Deprecated: Use ContainerBatchReportTaskStatuesResponse.ProtoReflect.Descriptor instead.

func (*ContainerBatchReportTaskStatuesResponse) GetDeliveryId 

func (x *ContainerBatchReportTaskStatuesResponse) GetDeliveryId() int64

func (*ContainerBatchReportTaskStatuesResponse) GetMessage 

func (x *ContainerBatchReportTaskStatuesResponse) GetMessage() string

func (*ContainerBatchReportTaskStatuesResponse) GetSuccess 

func (x *ContainerBatchReportTaskStatuesResponse) GetSuccess() bool

func (*ContainerBatchReportTaskStatuesResponse) ProtoMessage 

func (*ContainerBatchReportTaskStatuesResponse) ProtoMessage()

func (*ContainerBatchReportTaskStatuesResponse) ProtoReflect 

func (x *ContainerBatchReportTaskStatuesResponse) ProtoReflect() protoreflect.Message

func (*ContainerBatchReportTaskStatuesResponse) Reset 

func (x *ContainerBatchReportTaskStatuesResponse) Reset()

func (*ContainerBatchReportTaskStatuesResponse) String 

func (x *ContainerBatchReportTaskStatuesResponse) String() string

type ContainerCheckZombieRequest 

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
}

func (*ContainerCheckZombieRequest) Descriptor deprecated 

func (*ContainerCheckZombieRequest) Descriptor() ([]byte, []int)

Deprecated: Use ContainerCheckZombieRequest.ProtoReflect.Descriptor instead.

func (*ContainerCheckZombieRequest) GetJobInstanceId 

func (x *ContainerCheckZombieRequest) GetJobInstanceId() []int64

func (*ContainerCheckZombieRequest) ProtoMessage 

func (*ContainerCheckZombieRequest) ProtoMessage()

func (*ContainerCheckZombieRequest) ProtoReflect 

func (x *ContainerCheckZombieRequest) ProtoReflect() protoreflect.Message

func (*ContainerCheckZombieRequest) Reset 

func (x *ContainerCheckZombieRequest) Reset()

func (*ContainerCheckZombieRequest) String 

func (x *ContainerCheckZombieRequest) String() string

type ContainerCheckZombieResponse 

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
}

func (*ContainerCheckZombieResponse) Descriptor deprecated 

func (*ContainerCheckZombieResponse) Descriptor() ([]byte, []int)

Deprecated: Use ContainerCheckZombieResponse.ProtoReflect.Descriptor instead.

func (*ContainerCheckZombieResponse) GetZombieJobInstanceId 

func (x *ContainerCheckZombieResponse) GetZombieJobInstanceId() []int64

func (*ContainerCheckZombieResponse) ProtoMessage 

func (*ContainerCheckZombieResponse) ProtoMessage()

func (*ContainerCheckZombieResponse) ProtoReflect 

func (x *ContainerCheckZombieResponse) ProtoReflect() protoreflect.Message

func (*ContainerCheckZombieResponse) Reset 

func (x *ContainerCheckZombieResponse) Reset()

func (*ContainerCheckZombieResponse) String 

func (x *ContainerCheckZombieResponse) String() string

type ContainerReportTaskStatusRequest 

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
}

Container report task status

func (*ContainerReportTaskStatusRequest) Descriptor deprecated 

func (*ContainerReportTaskStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use ContainerReportTaskStatusRequest.ProtoReflect.Descriptor instead.

func (*ContainerReportTaskStatusRequest) GetInstanceMasterActorPath 

func (x *ContainerReportTaskStatusRequest) GetInstanceMasterActorPath() string

func (*ContainerReportTaskStatusRequest) GetJobId 

func (x *ContainerReportTaskStatusRequest) GetJobId() int64

func (*ContainerReportTaskStatusRequest) GetJobInstanceId 

func (x *ContainerReportTaskStatusRequest) GetJobInstanceId() int64

func (*ContainerReportTaskStatusRequest) GetProgress 

func (x *ContainerReportTaskStatusRequest) GetProgress() string

func (*ContainerReportTaskStatusRequest) GetResult 

func (x *ContainerReportTaskStatusRequest) GetResult() string

func (*ContainerReportTaskStatusRequest) GetSerialNum 

func (x *ContainerReportTaskStatusRequest) GetSerialNum() int64

func (*ContainerReportTaskStatusRequest) GetStatus 

func (x *ContainerReportTaskStatusRequest) GetStatus() int32

func (*ContainerReportTaskStatusRequest) GetTaskId 

func (x *ContainerReportTaskStatusRequest) GetTaskId() int64

func (*ContainerReportTaskStatusRequest) GetTaskName 

func (x *ContainerReportTaskStatusRequest) GetTaskName() string

func (*ContainerReportTaskStatusRequest) GetTimeType 

func (x *ContainerReportTaskStatusRequest) GetTimeType() int32

func (*ContainerReportTaskStatusRequest) GetTraceId 

func (x *ContainerReportTaskStatusRequest) GetTraceId() string

func (*ContainerReportTaskStatusRequest) GetWorkerAddr 

func (x *ContainerReportTaskStatusRequest) GetWorkerAddr() string

func (*ContainerReportTaskStatusRequest) GetWorkerId 

func (x *ContainerReportTaskStatusRequest) GetWorkerId() string

func (*ContainerReportTaskStatusRequest) ProtoMessage 

func (*ContainerReportTaskStatusRequest) ProtoMessage()

func (*ContainerReportTaskStatusRequest) ProtoReflect 

func (x *ContainerReportTaskStatusRequest) ProtoReflect() protoreflect.Message

func (*ContainerReportTaskStatusRequest) Reset 

func (x *ContainerReportTaskStatusRequest) Reset()

func (*ContainerReportTaskStatusRequest) String 

func (x *ContainerReportTaskStatusRequest) String() string

type ContainerReportTaskStatusResponse 

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
}

func (*ContainerReportTaskStatusResponse) Descriptor deprecated 

func (*ContainerReportTaskStatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use ContainerReportTaskStatusResponse.ProtoReflect.Descriptor instead.

func (*ContainerReportTaskStatusResponse) GetMessage 

func (x *ContainerReportTaskStatusResponse) GetMessage() string

func (*ContainerReportTaskStatusResponse) GetSuccess 

func (x *ContainerReportTaskStatusResponse) GetSuccess() bool

func (*ContainerReportTaskStatusResponse) ProtoMessage 

func (*ContainerReportTaskStatusResponse) ProtoMessage()

func (*ContainerReportTaskStatusResponse) ProtoReflect 

func (x *ContainerReportTaskStatusResponse) ProtoReflect() protoreflect.Message

func (*ContainerReportTaskStatusResponse) Reset 

func (x *ContainerReportTaskStatusResponse) Reset()

func (*ContainerReportTaskStatusResponse) String 

func (x *ContainerReportTaskStatusResponse) String() string

type LabelWorkerAddrsEntry 

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
}

func (*LabelWorkerAddrsEntry) Descriptor deprecated 

func (*LabelWorkerAddrsEntry) Descriptor() ([]byte, []int)

Deprecated: Use LabelWorkerAddrsEntry.ProtoReflect.Descriptor instead.

func (*LabelWorkerAddrsEntry) GetLabel 

func (x *LabelWorkerAddrsEntry) GetLabel() string

func (*LabelWorkerAddrsEntry) GetWorkerAddrs 

func (x *LabelWorkerAddrsEntry) GetWorkerAddrs() []string

func (*LabelWorkerAddrsEntry) ProtoMessage 

func (*LabelWorkerAddrsEntry) ProtoMessage()

func (*LabelWorkerAddrsEntry) ProtoReflect 

func (x *LabelWorkerAddrsEntry) ProtoReflect() protoreflect.Message

func (*LabelWorkerAddrsEntry) Reset 

func (x *LabelWorkerAddrsEntry) Reset()

func (*LabelWorkerAddrsEntry) String 

func (x *LabelWorkerAddrsEntry) String() string

type MasterBatchStartContainersRequest 

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
}

TaskMaster batch start containers

func (*MasterBatchStartContainersRequest) Descriptor deprecated 

func (*MasterBatchStartContainersRequest) Descriptor() ([]byte, []int)

Deprecated: Use MasterBatchStartContainersRequest.ProtoReflect.Descriptor instead.

func (*MasterBatchStartContainersRequest) GetJobId 

func (x *MasterBatchStartContainersRequest) GetJobId() int64

func (*MasterBatchStartContainersRequest) GetJobInstanceId 

func (x *MasterBatchStartContainersRequest) GetJobInstanceId() int64

func (*MasterBatchStartContainersRequest) GetSerialNum 

func (x *MasterBatchStartContainersRequest) GetSerialNum() int64

func (*MasterBatchStartContainersRequest) GetStartReqs 

func (x *MasterBatchStartContainersRequest) GetStartReqs() []*MasterStartContainerRequest

func (*MasterBatchStartContainersRequest) ProtoMessage 

func (*MasterBatchStartContainersRequest) ProtoMessage()

func (*MasterBatchStartContainersRequest) ProtoReflect 

func (x *MasterBatchStartContainersRequest) ProtoReflect() protoreflect.Message

func (*MasterBatchStartContainersRequest) Reset 

func (x *MasterBatchStartContainersRequest) Reset()

func (*MasterBatchStartContainersRequest) String 

func (x *MasterBatchStartContainersRequest) String() string

type MasterBatchStartContainersResponse 

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
}

func (*MasterBatchStartContainersResponse) Descriptor deprecated 

func (*MasterBatchStartContainersResponse) Descriptor() ([]byte, []int)

Deprecated: Use MasterBatchStartContainersResponse.ProtoReflect.Descriptor instead.

func (*MasterBatchStartContainersResponse) GetFailedTaskIds 

func (x *MasterBatchStartContainersResponse) GetFailedTaskIds() []int64

func (*MasterBatchStartContainersResponse) GetMessage 

func (x *MasterBatchStartContainersResponse) GetMessage() string

func (*MasterBatchStartContainersResponse) GetMetricsJson 

func (x *MasterBatchStartContainersResponse) GetMetricsJson() string

func (*MasterBatchStartContainersResponse) GetSuccess 

func (x *MasterBatchStartContainersResponse) GetSuccess() bool

func (*MasterBatchStartContainersResponse) ProtoMessage 

func (*MasterBatchStartContainersResponse) ProtoMessage()

func (*MasterBatchStartContainersResponse) ProtoReflect 

func (x *MasterBatchStartContainersResponse) ProtoReflect() protoreflect.Message

func (*MasterBatchStartContainersResponse) Reset 

func (x *MasterBatchStartContainersResponse) Reset()

func (*MasterBatchStartContainersResponse) String 

func (x *MasterBatchStartContainersResponse) String() string

type MasterCheckWorkerAliveRequest 

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
}

TaskMaster check worker if alive

func (*MasterCheckWorkerAliveRequest) Descriptor deprecated 

func (*MasterCheckWorkerAliveRequest) Descriptor() ([]byte, []int)

Deprecated: Use MasterCheckWorkerAliveRequest.ProtoReflect.Descriptor instead.

func (*MasterCheckWorkerAliveRequest) GetDispatchMode 

func (x *MasterCheckWorkerAliveRequest) GetDispatchMode() string

func (*MasterCheckWorkerAliveRequest) GetJobInstanceId 

func (x *MasterCheckWorkerAliveRequest) GetJobInstanceId() int64

func (*MasterCheckWorkerAliveRequest) ProtoMessage 

func (*MasterCheckWorkerAliveRequest) ProtoMessage()

func (*MasterCheckWorkerAliveRequest) ProtoReflect 

func (x *MasterCheckWorkerAliveRequest) ProtoReflect() protoreflect.Message

func (*MasterCheckWorkerAliveRequest) Reset 

func (x *MasterCheckWorkerAliveRequest) Reset()

func (*MasterCheckWorkerAliveRequest) String 

func (x *MasterCheckWorkerAliveRequest) String() string

type MasterCheckWorkerAliveResponse 

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
}

func (*MasterCheckWorkerAliveResponse) Descriptor deprecated 

func (*MasterCheckWorkerAliveResponse) Descriptor() ([]byte, []int)

Deprecated: Use MasterCheckWorkerAliveResponse.ProtoReflect.Descriptor instead.

func (*MasterCheckWorkerAliveResponse) GetMessage 

func (x *MasterCheckWorkerAliveResponse) GetMessage() string

func (*MasterCheckWorkerAliveResponse) GetMetricsJson 

func (x *MasterCheckWorkerAliveResponse) GetMetricsJson() string

func (*MasterCheckWorkerAliveResponse) GetSuccess 

func (x *MasterCheckWorkerAliveResponse) GetSuccess() bool

func (*MasterCheckWorkerAliveResponse) ProtoMessage 

func (*MasterCheckWorkerAliveResponse) ProtoMessage()

func (*MasterCheckWorkerAliveResponse) ProtoReflect 

func (x *MasterCheckWorkerAliveResponse) ProtoReflect() protoreflect.Message

func (*MasterCheckWorkerAliveResponse) Reset 

func (x *MasterCheckWorkerAliveResponse) Reset()

func (*MasterCheckWorkerAliveResponse) String 

func (x *MasterCheckWorkerAliveResponse) String() string

type MasterDestroyContainerPoolRequest 

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
}

TaskMaster destroy containerPool by jobInstance when finished

func (*MasterDestroyContainerPoolRequest) Descriptor deprecated 

func (*MasterDestroyContainerPoolRequest) Descriptor() ([]byte, []int)

Deprecated: Use MasterDestroyContainerPoolRequest.ProtoReflect.Descriptor instead.

func (*MasterDestroyContainerPoolRequest) GetAlreadyUnConfirmRetry 

func (x *MasterDestroyContainerPoolRequest) GetAlreadyUnConfirmRetry() bool

func (*MasterDestroyContainerPoolRequest) GetDeliveryId 

func (x *MasterDestroyContainerPoolRequest) GetDeliveryId() int64

func (*MasterDestroyContainerPoolRequest) GetJobId 

func (x *MasterDestroyContainerPoolRequest) GetJobId() int64

func (*MasterDestroyContainerPoolRequest) GetJobInstanceId 

func (x *MasterDestroyContainerPoolRequest) GetJobInstanceId() int64

func (*MasterDestroyContainerPoolRequest) GetSerialNum 

func (x *MasterDestroyContainerPoolRequest) GetSerialNum() int64

func (*MasterDestroyContainerPoolRequest) GetWorkerIdAddr 

func (x *MasterDestroyContainerPoolRequest) GetWorkerIdAddr() string

func (*MasterDestroyContainerPoolRequest) ProtoMessage 

func (*MasterDestroyContainerPoolRequest) ProtoMessage()

func (*MasterDestroyContainerPoolRequest) ProtoReflect 

func (x *MasterDestroyContainerPoolRequest) ProtoReflect() protoreflect.Message

func (*MasterDestroyContainerPoolRequest) Reset 

func (x *MasterDestroyContainerPoolRequest) Reset()

func (*MasterDestroyContainerPoolRequest) String 

func (x *MasterDestroyContainerPoolRequest) String() string

type MasterDestroyContainerPoolResponse 

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
}

func (*MasterDestroyContainerPoolResponse) Descriptor deprecated 

func (*MasterDestroyContainerPoolResponse) Descriptor() ([]byte, []int)

Deprecated: Use MasterDestroyContainerPoolResponse.ProtoReflect.Descriptor instead.

func (*MasterDestroyContainerPoolResponse) GetDeliveryId 

func (x *MasterDestroyContainerPoolResponse) GetDeliveryId() int64

func (*MasterDestroyContainerPoolResponse) GetMessage 

func (x *MasterDestroyContainerPoolResponse) GetMessage() string

func (*MasterDestroyContainerPoolResponse) GetSuccess 

func (x *MasterDestroyContainerPoolResponse) GetSuccess() bool

func (*MasterDestroyContainerPoolResponse) ProtoMessage 

func (*MasterDestroyContainerPoolResponse) ProtoMessage()

func (*MasterDestroyContainerPoolResponse) ProtoReflect 

func (x *MasterDestroyContainerPoolResponse) ProtoReflect() protoreflect.Message

func (*MasterDestroyContainerPoolResponse) Reset 

func (x *MasterDestroyContainerPoolResponse) Reset()

func (*MasterDestroyContainerPoolResponse) String 

func (x *MasterDestroyContainerPoolResponse) String() string

type MasterKillContainerRequest 

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
}

TaskMaster kill container

func (*MasterKillContainerRequest) Descriptor deprecated 

func (*MasterKillContainerRequest) Descriptor() ([]byte, []int)

Deprecated: Use MasterKillContainerRequest.ProtoReflect.Descriptor instead.

func (*MasterKillContainerRequest) GetAppGroupId 

func (x *MasterKillContainerRequest) GetAppGroupId() int64

func (*MasterKillContainerRequest) GetJobId 

func (x *MasterKillContainerRequest) GetJobId() int64

func (*MasterKillContainerRequest) GetJobInstanceId 

func (x *MasterKillContainerRequest) GetJobInstanceId() int64

func (*MasterKillContainerRequest) GetMayInterruptIfRunning 

func (x *MasterKillContainerRequest) GetMayInterruptIfRunning() bool

func (*MasterKillContainerRequest) GetTaskId 

func (x *MasterKillContainerRequest) GetTaskId() int64

func (*MasterKillContainerRequest) GetUser 

func (x *MasterKillContainerRequest) GetUser() string

func (*MasterKillContainerRequest) ProtoMessage 

func (*MasterKillContainerRequest) ProtoMessage()

func (*MasterKillContainerRequest) ProtoReflect 

func (x *MasterKillContainerRequest) ProtoReflect() protoreflect.Message

func (*MasterKillContainerRequest) Reset 

func (x *MasterKillContainerRequest) Reset()

func (*MasterKillContainerRequest) String 

func (x *MasterKillContainerRequest) String() string

type MasterKillContainerResponse 

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
}

func (*MasterKillContainerResponse) Descriptor deprecated 

func (*MasterKillContainerResponse) Descriptor() ([]byte, []int)

Deprecated: Use MasterKillContainerResponse.ProtoReflect.Descriptor instead.

func (*MasterKillContainerResponse) GetMessage 

func (x *MasterKillContainerResponse) GetMessage() string

func (*MasterKillContainerResponse) GetSuccess 

func (x *MasterKillContainerResponse) GetSuccess() bool

func (*MasterKillContainerResponse) ProtoMessage 

func (*MasterKillContainerResponse) ProtoMessage()

func (*MasterKillContainerResponse) ProtoReflect 

func (x *MasterKillContainerResponse) ProtoReflect() protoreflect.Message

func (*MasterKillContainerResponse) Reset 

func (x *MasterKillContainerResponse) Reset()

func (*MasterKillContainerResponse) String 

func (x *MasterKillContainerResponse) String() string

type MasterNotifyWorkerPullRequest 

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
}

Pull model, master notify all workers to init PullManager

func (*MasterNotifyWorkerPullRequest) Descriptor deprecated 

func (*MasterNotifyWorkerPullRequest) Descriptor() ([]byte, []int)

Deprecated: Use MasterNotifyWorkerPullRequest.ProtoReflect.Descriptor instead.

func (*MasterNotifyWorkerPullRequest) GetConsumerSize 

func (x *MasterNotifyWorkerPullRequest) GetConsumerSize() int32

func (*MasterNotifyWorkerPullRequest) GetJobInstanceId 

func (x *MasterNotifyWorkerPullRequest) GetJobInstanceId() int64

func (*MasterNotifyWorkerPullRequest) GetPageSize 

func (x *MasterNotifyWorkerPullRequest) GetPageSize() int32

func (*MasterNotifyWorkerPullRequest) GetQueueSize 

func (x *MasterNotifyWorkerPullRequest) GetQueueSize() int32

func (*MasterNotifyWorkerPullRequest) GetSerialNum 

func (x *MasterNotifyWorkerPullRequest) GetSerialNum() int64

func (*MasterNotifyWorkerPullRequest) GetTaskMasterAkkaPath 

func (x *MasterNotifyWorkerPullRequest) GetTaskMasterAkkaPath() string

func (*MasterNotifyWorkerPullRequest) ProtoMessage 

func (*MasterNotifyWorkerPullRequest) ProtoMessage()

func (*MasterNotifyWorkerPullRequest) ProtoReflect 

func (x *MasterNotifyWorkerPullRequest) ProtoReflect() protoreflect.Message

func (*MasterNotifyWorkerPullRequest) Reset 

func (x *MasterNotifyWorkerPullRequest) Reset()

func (*MasterNotifyWorkerPullRequest) String 

func (x *MasterNotifyWorkerPullRequest) String() string

type MasterNotifyWorkerPullResponse 

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
}

func (*MasterNotifyWorkerPullResponse) Descriptor deprecated 

func (*MasterNotifyWorkerPullResponse) Descriptor() ([]byte, []int)

Deprecated: Use MasterNotifyWorkerPullResponse.ProtoReflect.Descriptor instead.

func (*MasterNotifyWorkerPullResponse) GetMessage 

func (x *MasterNotifyWorkerPullResponse) GetMessage() string

func (*MasterNotifyWorkerPullResponse) GetSuccess 

func (x *MasterNotifyWorkerPullResponse) GetSuccess() bool

func (*MasterNotifyWorkerPullResponse) ProtoMessage 

func (*MasterNotifyWorkerPullResponse) ProtoMessage()

func (*MasterNotifyWorkerPullResponse) ProtoReflect 

func (x *MasterNotifyWorkerPullResponse) ProtoReflect() protoreflect.Message

func (*MasterNotifyWorkerPullResponse) Reset 

func (x *MasterNotifyWorkerPullResponse) Reset()

func (*MasterNotifyWorkerPullResponse) String 

func (x *MasterNotifyWorkerPullResponse) String() string

type MasterStartContainerRequest 

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
}

TaskMaster start container

func (*MasterStartContainerRequest) Descriptor deprecated 

func (*MasterStartContainerRequest) Descriptor() ([]byte, []int)

Deprecated: Use MasterStartContainerRequest.ProtoReflect.Descriptor instead.

func (*MasterStartContainerRequest) GetAppGroupId 

func (x *MasterStartContainerRequest) GetAppGroupId() int64

func (*MasterStartContainerRequest) GetAttempt 

func (x *MasterStartContainerRequest) GetAttempt() int32

func (*MasterStartContainerRequest) GetConsumerNum 

func (x *MasterStartContainerRequest) GetConsumerNum() int32

func (*MasterStartContainerRequest) GetContent 

func (x *MasterStartContainerRequest) GetContent() string

func (*MasterStartContainerRequest) GetDataTime 

func (x *MasterStartContainerRequest) GetDataTime() int64

func (*MasterStartContainerRequest) GetExecuteMode 

func (x *MasterStartContainerRequest) GetExecuteMode() string

func (*MasterStartContainerRequest) GetFailover 

func (x *MasterStartContainerRequest) GetFailover() bool

func (*MasterStartContainerRequest) GetGroupId 

func (x *MasterStartContainerRequest) GetGroupId() string

func (*MasterStartContainerRequest) GetInstanceMasterAkkaPath 

func (x *MasterStartContainerRequest) GetInstanceMasterAkkaPath() string

func (*MasterStartContainerRequest) GetInstanceParameters 

func (x *MasterStartContainerRequest) GetInstanceParameters() string

func (*MasterStartContainerRequest) GetJobId 

func (x *MasterStartContainerRequest) GetJobId() int64

func (*MasterStartContainerRequest) GetJobInstanceId 

func (x *MasterStartContainerRequest) GetJobInstanceId() int64

func (*MasterStartContainerRequest) GetJobName 

func (x *MasterStartContainerRequest) GetJobName() string

func (*MasterStartContainerRequest) GetJobType 

func (x *MasterStartContainerRequest) GetJobType() string

func (*MasterStartContainerRequest) GetMaxAttempt 

func (x *MasterStartContainerRequest) GetMaxAttempt() int32

func (*MasterStartContainerRequest) GetNamespace 

func (x *MasterStartContainerRequest) GetNamespace() string

func (*MasterStartContainerRequest) GetParameters 

func (x *MasterStartContainerRequest) GetParameters() string

func (*MasterStartContainerRequest) GetScheduleTime 

func (x *MasterStartContainerRequest) GetScheduleTime() int64

func (*MasterStartContainerRequest) GetSerialNum 

func (x *MasterStartContainerRequest) GetSerialNum() int64

func (*MasterStartContainerRequest) GetShardingNum 

func (x *MasterStartContainerRequest) GetShardingNum() int32

func (*MasterStartContainerRequest) GetTask 

func (x *MasterStartContainerRequest) GetTask() []byte

func (*MasterStartContainerRequest) GetTaskAttemptInterval 

func (x *MasterStartContainerRequest) GetTaskAttemptInterval() int32

func (*MasterStartContainerRequest) GetTaskId 

func (x *MasterStartContainerRequest) GetTaskId() int64

func (*MasterStartContainerRequest) GetTaskMaxAttempt 

func (x *MasterStartContainerRequest) GetTaskMaxAttempt() int32

func (*MasterStartContainerRequest) GetTaskName 

func (x *MasterStartContainerRequest) GetTaskName() string

func (*MasterStartContainerRequest) GetTemplate 

func (x *MasterStartContainerRequest) GetTemplate() string

func (*MasterStartContainerRequest) GetTimeExpression 

func (x *MasterStartContainerRequest) GetTimeExpression() string

func (*MasterStartContainerRequest) GetTimeType 

func (x *MasterStartContainerRequest) GetTimeType() int32

func (*MasterStartContainerRequest) GetTriggerType 

func (x *MasterStartContainerRequest) GetTriggerType() int32

func (*MasterStartContainerRequest) GetUpstreamData 

func (x *MasterStartContainerRequest) GetUpstreamData() []*UpstreamData

func (*MasterStartContainerRequest) GetUser 

func (x *MasterStartContainerRequest) GetUser() string

func (*MasterStartContainerRequest) GetWfInstanceId 

func (x *MasterStartContainerRequest) GetWfInstanceId() int64

func (*MasterStartContainerRequest) GetXattrs 

func (x *MasterStartContainerRequest) GetXattrs() string

func (*MasterStartContainerRequest) ProtoMessage 

func (*MasterStartContainerRequest) ProtoMessage()

func (*MasterStartContainerRequest) ProtoReflect 

func (x *MasterStartContainerRequest) ProtoReflect() protoreflect.Message

func (*MasterStartContainerRequest) Reset 

func (x *MasterStartContainerRequest) Reset()

func (*MasterStartContainerRequest) String 

func (x *MasterStartContainerRequest) String() string

type MasterStartContainerResponse 

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
}

func (*MasterStartContainerResponse) Descriptor deprecated 

func (*MasterStartContainerResponse) Descriptor() ([]byte, []int)

Deprecated: Use MasterStartContainerResponse.ProtoReflect.Descriptor instead.

func (*MasterStartContainerResponse) GetMessage 

func (x *MasterStartContainerResponse) GetMessage() string

func (*MasterStartContainerResponse) GetSuccess 

func (x *MasterStartContainerResponse) GetSuccess() bool

func (*MasterStartContainerResponse) ProtoMessage 

func (*MasterStartContainerResponse) ProtoMessage()

func (*MasterStartContainerResponse) ProtoReflect 

func (x *MasterStartContainerResponse) ProtoReflect() protoreflect.Message

func (*MasterStartContainerResponse) Reset 

func (x *MasterStartContainerResponse) Reset()

func (*MasterStartContainerResponse) String 

func (x *MasterStartContainerResponse) String() string

type PullTaskFromMasterRequest 

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
}

PullThread pull container requests from TaskMaster

func (*PullTaskFromMasterRequest) Descriptor deprecated 

func (*PullTaskFromMasterRequest) Descriptor() ([]byte, []int)

Deprecated: Use PullTaskFromMasterRequest.ProtoReflect.Descriptor instead.

func (*PullTaskFromMasterRequest) GetJobInstanceId 

func (x *PullTaskFromMasterRequest) GetJobInstanceId() int64

func (*PullTaskFromMasterRequest) GetPageSize 

func (x *PullTaskFromMasterRequest) GetPageSize() int32

func (*PullTaskFromMasterRequest) GetSerialNum 

func (x *PullTaskFromMasterRequest) GetSerialNum() int64

func (*PullTaskFromMasterRequest) GetWorkerIdAddr 

func (x *PullTaskFromMasterRequest) GetWorkerIdAddr() string

func (*PullTaskFromMasterRequest) ProtoMessage 

func (*PullTaskFromMasterRequest) ProtoMessage()

func (*PullTaskFromMasterRequest) ProtoReflect 

func (x *PullTaskFromMasterRequest) ProtoReflect() protoreflect.Message

func (*PullTaskFromMasterRequest) Reset 

func (x *PullTaskFromMasterRequest) Reset()

func (*PullTaskFromMasterRequest) String 

func (x *PullTaskFromMasterRequest) String() string

type PullTaskFromMasterResponse 

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
}

func (*PullTaskFromMasterResponse) Descriptor deprecated 

func (*PullTaskFromMasterResponse) Descriptor() ([]byte, []int)

Deprecated: Use PullTaskFromMasterResponse.ProtoReflect.Descriptor instead.

func (*PullTaskFromMasterResponse) GetMessage 

func (x *PullTaskFromMasterResponse) GetMessage() string

func (*PullTaskFromMasterResponse) GetRequest 

func (x *PullTaskFromMasterResponse) GetRequest() []*MasterStartContainerRequest

func (*PullTaskFromMasterResponse) GetSuccess 

func (x *PullTaskFromMasterResponse) GetSuccess() bool

func (*PullTaskFromMasterResponse) ProtoMessage 

func (*PullTaskFromMasterResponse) ProtoMessage()

func (*PullTaskFromMasterResponse) ProtoReflect 

func (x *PullTaskFromMasterResponse) ProtoReflect() protoreflect.Message

func (*PullTaskFromMasterResponse) Reset 

func (x *PullTaskFromMasterResponse) Reset()

func (*PullTaskFromMasterResponse) String 

func (x *PullTaskFromMasterResponse) String() string

type RetryTaskEntity 

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
}

retry tasks

func (*RetryTaskEntity) Descriptor deprecated 

func (*RetryTaskEntity) Descriptor() ([]byte, []int)

Deprecated: Use RetryTaskEntity.ProtoReflect.Descriptor instead.

func (*RetryTaskEntity) GetOldStatus 

func (x *RetryTaskEntity) GetOldStatus() int32

func (*RetryTaskEntity) GetTaskId 

func (x *RetryTaskEntity) GetTaskId() int64

func (*RetryTaskEntity) GetTaskName 

func (x *RetryTaskEntity) GetTaskName() string

func (*RetryTaskEntity) GetWorkerAddr 

func (x *RetryTaskEntity) GetWorkerAddr() string

func (*RetryTaskEntity) ProtoMessage 

func (*RetryTaskEntity) ProtoMessage()

func (*RetryTaskEntity) ProtoReflect 

func (x *RetryTaskEntity) ProtoReflect() protoreflect.Message

func (*RetryTaskEntity) Reset 

func (x *RetryTaskEntity) Reset()

func (*RetryTaskEntity) String 

func (x *RetryTaskEntity) String() string

type ServerCallbackCalendarRequest 

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
}

Server Callback calendar

func (*ServerCallbackCalendarRequest) Descriptor deprecated 

func (*ServerCallbackCalendarRequest) Descriptor() ([]byte, []int)

Deprecated: Use ServerCallbackCalendarRequest.ProtoReflect.Descriptor instead.

func (*ServerCallbackCalendarRequest) GetJobInstanceId 

func (x *ServerCallbackCalendarRequest) GetJobInstanceId() int64

func (*ServerCallbackCalendarRequest) GetProcessor 

func (x *ServerCallbackCalendarRequest) GetProcessor() string

func (*ServerCallbackCalendarRequest) GetTimestamp 

func (x *ServerCallbackCalendarRequest) GetTimestamp() int64

func (*ServerCallbackCalendarRequest) ProtoMessage 

func (*ServerCallbackCalendarRequest) ProtoMessage()

func (*ServerCallbackCalendarRequest) ProtoReflect 

func (x *ServerCallbackCalendarRequest) ProtoReflect() protoreflect.Message

func (*ServerCallbackCalendarRequest) Reset 

func (x *ServerCallbackCalendarRequest) Reset()

func (*ServerCallbackCalendarRequest) String 

func (x *ServerCallbackCalendarRequest) String() string

type ServerCallbackCalendarResponse 

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
}

func (*ServerCallbackCalendarResponse) Descriptor deprecated 

func (*ServerCallbackCalendarResponse) Descriptor() ([]byte, []int)

Deprecated: Use ServerCallbackCalendarResponse.ProtoReflect.Descriptor instead.

func (*ServerCallbackCalendarResponse) GetMessage 

func (x *ServerCallbackCalendarResponse) GetMessage() string

func (*ServerCallbackCalendarResponse) GetResult 

func (x *ServerCallbackCalendarResponse) GetResult() bool

func (*ServerCallbackCalendarResponse) GetSuccess 

func (x *ServerCallbackCalendarResponse) GetSuccess() bool

func (*ServerCallbackCalendarResponse) ProtoMessage 

func (*ServerCallbackCalendarResponse) ProtoMessage()

func (*ServerCallbackCalendarResponse) ProtoReflect 

func (x *ServerCallbackCalendarResponse) ProtoReflect() protoreflect.Message

func (*ServerCallbackCalendarResponse) Reset 

func (x *ServerCallbackCalendarResponse) Reset()

func (*ServerCallbackCalendarResponse) String 

func (x *ServerCallbackCalendarResponse) String() string

type ServerCheckTaskMasterRequest 

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
}

server check if worker is alive

func (*ServerCheckTaskMasterRequest) Descriptor deprecated 

func (*ServerCheckTaskMasterRequest) Descriptor() ([]byte, []int)

Deprecated: Use ServerCheckTaskMasterRequest.ProtoReflect.Descriptor instead.

func (*ServerCheckTaskMasterRequest) GetJobInstanceId 

func (x *ServerCheckTaskMasterRequest) GetJobInstanceId() int64

func (*ServerCheckTaskMasterRequest) ProtoMessage 

func (*ServerCheckTaskMasterRequest) ProtoMessage()

func (*ServerCheckTaskMasterRequest) ProtoReflect 

func (x *ServerCheckTaskMasterRequest) ProtoReflect() protoreflect.Message

func (*ServerCheckTaskMasterRequest) Reset 

func (x *ServerCheckTaskMasterRequest) Reset()

func (*ServerCheckTaskMasterRequest) String 

func (x *ServerCheckTaskMasterRequest) String() string

type ServerCheckTaskMasterResponse 

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
}

func (*ServerCheckTaskMasterResponse) Descriptor deprecated 

func (*ServerCheckTaskMasterResponse) Descriptor() ([]byte, []int)

Deprecated: Use ServerCheckTaskMasterResponse.ProtoReflect.Descriptor instead.

func (*ServerCheckTaskMasterResponse) GetMessage 

func (x *ServerCheckTaskMasterResponse) GetMessage() string

func (*ServerCheckTaskMasterResponse) GetSuccess 

func (x *ServerCheckTaskMasterResponse) GetSuccess() bool

func (*ServerCheckTaskMasterResponse) ProtoMessage 

func (*ServerCheckTaskMasterResponse) ProtoMessage()

func (*ServerCheckTaskMasterResponse) ProtoReflect 

func (x *ServerCheckTaskMasterResponse) ProtoReflect() protoreflect.Message

func (*ServerCheckTaskMasterResponse) Reset 

func (x *ServerCheckTaskMasterResponse) Reset()

func (*ServerCheckTaskMasterResponse) String 

func (x *ServerCheckTaskMasterResponse) String() string

type ServerCreateAppRequest 

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
}

create app

func (*ServerCreateAppRequest) Descriptor deprecated 

func (*ServerCreateAppRequest) Descriptor() ([]byte, []int)

Deprecated: Use ServerCreateAppRequest.ProtoReflect.Descriptor instead.

func (*ServerCreateAppRequest) GetCreator 

func (x *ServerCreateAppRequest) GetCreator() string

func (*ServerCreateAppRequest) GetDescription 

func (x *ServerCreateAppRequest) GetDescription() string

func (*ServerCreateAppRequest) GetName 

func (x *ServerCreateAppRequest) GetName() string

func (*ServerCreateAppRequest) GetRegionId 

func (x *ServerCreateAppRequest) GetRegionId() int32

func (*ServerCreateAppRequest) ProtoMessage 

func (*ServerCreateAppRequest) ProtoMessage()

func (*ServerCreateAppRequest) ProtoReflect 

func (x *ServerCreateAppRequest) ProtoReflect() protoreflect.Message

func (*ServerCreateAppRequest) Reset 

func (x *ServerCreateAppRequest) Reset()

func (*ServerCreateAppRequest) String 

func (x *ServerCreateAppRequest) String() string

type ServerCreateAppResponse 

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
}

func (*ServerCreateAppResponse) Descriptor deprecated 

func (*ServerCreateAppResponse) Descriptor() ([]byte, []int)

Deprecated: Use ServerCreateAppResponse.ProtoReflect.Descriptor instead.

func (*ServerCreateAppResponse) GetMessage 

func (x *ServerCreateAppResponse) GetMessage() string

func (*ServerCreateAppResponse) GetSuccess 

func (x *ServerCreateAppResponse) GetSuccess() bool

func (*ServerCreateAppResponse) ProtoMessage 

func (*ServerCreateAppResponse) ProtoMessage()

func (*ServerCreateAppResponse) ProtoReflect 

func (x *ServerCreateAppResponse) ProtoReflect() protoreflect.Message

func (*ServerCreateAppResponse) Reset 

func (x *ServerCreateAppResponse) Reset()

func (*ServerCreateAppResponse) String 

func (x *ServerCreateAppResponse) String() string

type ServerCreateRegionRequest 

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
}

create region

func (*ServerCreateRegionRequest) Descriptor deprecated 

func (*ServerCreateRegionRequest) Descriptor() ([]byte, []int)

Deprecated: Use ServerCreateRegionRequest.ProtoReflect.Descriptor instead.

func (*ServerCreateRegionRequest) GetDescription 

func (x *ServerCreateRegionRequest) GetDescription() string

func (*ServerCreateRegionRequest) GetName 

func (x *ServerCreateRegionRequest) GetName() string

func (*ServerCreateRegionRequest) GetUser 

func (x *ServerCreateRegionRequest) GetUser() string

func (*ServerCreateRegionRequest) ProtoMessage 

func (*ServerCreateRegionRequest) ProtoMessage()

func (*ServerCreateRegionRequest) ProtoReflect 

func (x *ServerCreateRegionRequest) ProtoReflect() protoreflect.Message

func (*ServerCreateRegionRequest) Reset 

func (x *ServerCreateRegionRequest) Reset()

func (*ServerCreateRegionRequest) String 

func (x *ServerCreateRegionRequest) String() string

type ServerCreateRegionResponse 

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
}

func (*ServerCreateRegionResponse) Descriptor deprecated 

func (*ServerCreateRegionResponse) Descriptor() ([]byte, []int)

Deprecated: Use ServerCreateRegionResponse.ProtoReflect.Descriptor instead.

func (*ServerCreateRegionResponse) GetMessage 

func (x *ServerCreateRegionResponse) GetMessage() string

func (*ServerCreateRegionResponse) GetSuccess 

func (x *ServerCreateRegionResponse) GetSuccess() bool

func (*ServerCreateRegionResponse) ProtoMessage 

func (*ServerCreateRegionResponse) ProtoMessage()

func (*ServerCreateRegionResponse) ProtoReflect 

func (x *ServerCreateRegionResponse) ProtoReflect() protoreflect.Message

func (*ServerCreateRegionResponse) Reset 

func (x *ServerCreateRegionResponse) Reset()

func (*ServerCreateRegionResponse) String 

func (x *ServerCreateRegionResponse) String() string

type ServerKillJobInstanceRequest 

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
}

Server kill job instance to Worker

func (*ServerKillJobInstanceRequest) Descriptor deprecated 

func (*ServerKillJobInstanceRequest) Descriptor() ([]byte, []int)

Deprecated: Use ServerKillJobInstanceRequest.ProtoReflect.Descriptor instead.

func (*ServerKillJobInstanceRequest) GetAppGroupId 

func (x *ServerKillJobInstanceRequest) GetAppGroupId() int64

func (*ServerKillJobInstanceRequest) GetContent 

func (x *ServerKillJobInstanceRequest) GetContent() string

func (*ServerKillJobInstanceRequest) GetDestoryJob 

func (x *ServerKillJobInstanceRequest) GetDestoryJob() bool

func (*ServerKillJobInstanceRequest) GetExecuteMode 

func (x *ServerKillJobInstanceRequest) GetExecuteMode() string

func (*ServerKillJobInstanceRequest) GetJobId 

func (x *ServerKillJobInstanceRequest) GetJobId() int64

func (*ServerKillJobInstanceRequest) GetJobInstanceId 

func (x *ServerKillJobInstanceRequest) GetJobInstanceId() int64

func (*ServerKillJobInstanceRequest) GetJobType 

func (x *ServerKillJobInstanceRequest) GetJobType() string

func (*ServerKillJobInstanceRequest) GetNamespace 

func (x *ServerKillJobInstanceRequest) GetNamespace() string

func (*ServerKillJobInstanceRequest) GetUser 

func (x *ServerKillJobInstanceRequest) GetUser() string

func (*ServerKillJobInstanceRequest) GetXattrs 

func (x *ServerKillJobInstanceRequest) GetXattrs() string

func (*ServerKillJobInstanceRequest) ProtoMessage 

func (*ServerKillJobInstanceRequest) ProtoMessage()

func (*ServerKillJobInstanceRequest) ProtoReflect 

func (x *ServerKillJobInstanceRequest) ProtoReflect() protoreflect.Message

func (*ServerKillJobInstanceRequest) Reset 

func (x *ServerKillJobInstanceRequest) Reset()

func (*ServerKillJobInstanceRequest) String 

func (x *ServerKillJobInstanceRequest) String() string

type ServerKillJobInstanceResponse 

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
}

func (*ServerKillJobInstanceResponse) Descriptor deprecated 

func (*ServerKillJobInstanceResponse) Descriptor() ([]byte, []int)

Deprecated: Use ServerKillJobInstanceResponse.ProtoReflect.Descriptor instead.

func (*ServerKillJobInstanceResponse) GetMessage 

func (x *ServerKillJobInstanceResponse) GetMessage() string

func (*ServerKillJobInstanceResponse) GetSuccess 

func (x *ServerKillJobInstanceResponse) GetSuccess() bool

func (*ServerKillJobInstanceResponse) ProtoMessage 

func (*ServerKillJobInstanceResponse) ProtoMessage()

func (*ServerKillJobInstanceResponse) ProtoReflect 

func (x *ServerKillJobInstanceResponse) ProtoReflect() protoreflect.Message

func (*ServerKillJobInstanceResponse) Reset 

func (x *ServerKillJobInstanceResponse) Reset()

func (*ServerKillJobInstanceResponse) String 

func (x *ServerKillJobInstanceResponse) String() string

type ServerKillTaskRequest 

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
}

Server kill task intance to Worker

func (*ServerKillTaskRequest) Descriptor deprecated 

func (*ServerKillTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use ServerKillTaskRequest.ProtoReflect.Descriptor instead.

func (*ServerKillTaskRequest) GetJobId 

func (x *ServerKillTaskRequest) GetJobId() int64

func (*ServerKillTaskRequest) GetJobInstanceId 

func (x *ServerKillTaskRequest) GetJobInstanceId() int64

func (*ServerKillTaskRequest) GetTaskId 

func (x *ServerKillTaskRequest) GetTaskId() int64

func (*ServerKillTaskRequest) GetUser 

func (x *ServerKillTaskRequest) GetUser() string

func (*ServerKillTaskRequest) GetWorkerAddr 

func (x *ServerKillTaskRequest) GetWorkerAddr() string

func (*ServerKillTaskRequest) GetWorkerId 

func (x *ServerKillTaskRequest) GetWorkerId() string

func (*ServerKillTaskRequest) ProtoMessage 

func (*ServerKillTaskRequest) ProtoMessage()

func (*ServerKillTaskRequest) ProtoReflect 

func (x *ServerKillTaskRequest) ProtoReflect() protoreflect.Message

func (*ServerKillTaskRequest) Reset 

func (x *ServerKillTaskRequest) Reset()

func (*ServerKillTaskRequest) String 

func (x *ServerKillTaskRequest) String() string

type ServerKillTaskResponse 

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
}

func (*ServerKillTaskResponse) Descriptor deprecated 

func (*ServerKillTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use ServerKillTaskResponse.ProtoReflect.Descriptor instead.

func (*ServerKillTaskResponse) GetMessage 

func (x *ServerKillTaskResponse) GetMessage() string

func (*ServerKillTaskResponse) GetSuccess 

func (x *ServerKillTaskResponse) GetSuccess() bool

func (*ServerKillTaskResponse) ProtoMessage 

func (*ServerKillTaskResponse) ProtoMessage()

func (*ServerKillTaskResponse) ProtoReflect 

func (x *ServerKillTaskResponse) ProtoReflect() protoreflect.Message

func (*ServerKillTaskResponse) Reset 

func (x *ServerKillTaskResponse) Reset()

func (*ServerKillTaskResponse) String 

func (x *ServerKillTaskResponse) String() string

type ServerPushLogConfigRequest 

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
}

push log config

func (*ServerPushLogConfigRequest) Descriptor deprecated 

func (*ServerPushLogConfigRequest) Descriptor() ([]byte, []int)

Deprecated: Use ServerPushLogConfigRequest.ProtoReflect.Descriptor instead.

func (*ServerPushLogConfigRequest) GetConfig 

func (x *ServerPushLogConfigRequest) GetConfig() string

func (*ServerPushLogConfigRequest) GetEnable 

func (x *ServerPushLogConfigRequest) GetEnable() bool

func (*ServerPushLogConfigRequest) GetLevel 

func (x *ServerPushLogConfigRequest) GetLevel() string

func (*ServerPushLogConfigRequest) GetSlsAk 

func (x *ServerPushLogConfigRequest) GetSlsAk() string

func (*ServerPushLogConfigRequest) GetSlsSk 

func (x *ServerPushLogConfigRequest) GetSlsSk() string

func (*ServerPushLogConfigRequest) GetType 

func (x *ServerPushLogConfigRequest) GetType() string

func (*ServerPushLogConfigRequest) ProtoMessage 

func (*ServerPushLogConfigRequest) ProtoMessage()

func (*ServerPushLogConfigRequest) ProtoReflect 

func (x *ServerPushLogConfigRequest) ProtoReflect() protoreflect.Message

func (*ServerPushLogConfigRequest) Reset 

func (x *ServerPushLogConfigRequest) Reset()

func (*ServerPushLogConfigRequest) String 

func (x *ServerPushLogConfigRequest) String() string

type ServerPushLogConfigResponse 

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
}

func (*ServerPushLogConfigResponse) Descriptor deprecated 

func (*ServerPushLogConfigResponse) Descriptor() ([]byte, []int)

Deprecated: Use ServerPushLogConfigResponse.ProtoReflect.Descriptor instead.

func (*ServerPushLogConfigResponse) GetMessage 

func (x *ServerPushLogConfigResponse) GetMessage() string

func (*ServerPushLogConfigResponse) GetSuccess 

func (x *ServerPushLogConfigResponse) GetSuccess() bool

func (*ServerPushLogConfigResponse) ProtoMessage 

func (*ServerPushLogConfigResponse) ProtoMessage()

func (*ServerPushLogConfigResponse) ProtoReflect 

func (x *ServerPushLogConfigResponse) ProtoReflect() protoreflect.Message

func (*ServerPushLogConfigResponse) Reset 

func (x *ServerPushLogConfigResponse) Reset()

func (*ServerPushLogConfigResponse) String 

func (x *ServerPushLogConfigResponse) String() string

type ServerReadLogCharsRequest 

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
}

read log by chars

func (*ServerReadLogCharsRequest) Descriptor deprecated 

func (*ServerReadLogCharsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ServerReadLogCharsRequest.ProtoReflect.Descriptor instead.

func (*ServerReadLogCharsRequest) GetJobId 

func (x *ServerReadLogCharsRequest) GetJobId() int64

func (*ServerReadLogCharsRequest) GetJobInstanceId 

func (x *ServerReadLogCharsRequest) GetJobInstanceId() int64

func (*ServerReadLogCharsRequest) GetOffset 

func (x *ServerReadLogCharsRequest) GetOffset() int64

func (*ServerReadLogCharsRequest) GetScheduleTime 

func (x *ServerReadLogCharsRequest) GetScheduleTime() int64

func (*ServerReadLogCharsRequest) GetSize 

func (x *ServerReadLogCharsRequest) GetSize() int32

func (*ServerReadLogCharsRequest) GetTaskId 

func (x *ServerReadLogCharsRequest) GetTaskId() int64

func (*ServerReadLogCharsRequest) ProtoMessage 

func (*ServerReadLogCharsRequest) ProtoMessage()

func (*ServerReadLogCharsRequest) ProtoReflect 

func (x *ServerReadLogCharsRequest) ProtoReflect() protoreflect.Message

func (*ServerReadLogCharsRequest) Reset 

func (x *ServerReadLogCharsRequest) Reset()

func (*ServerReadLogCharsRequest) String 

func (x *ServerReadLogCharsRequest) String() string

type ServerReadLogCharsResponse 

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
}

func (*ServerReadLogCharsResponse) Descriptor deprecated 

func (*ServerReadLogCharsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ServerReadLogCharsResponse.ProtoReflect.Descriptor instead.

func (*ServerReadLogCharsResponse) GetIsEnd 

func (x *ServerReadLogCharsResponse) GetIsEnd() bool

func (*ServerReadLogCharsResponse) GetLog 

func (x *ServerReadLogCharsResponse) GetLog() string

func (*ServerReadLogCharsResponse) GetMessage 

func (x *ServerReadLogCharsResponse) GetMessage() string

func (*ServerReadLogCharsResponse) GetOffset 

func (x *ServerReadLogCharsResponse) GetOffset() int64

func (*ServerReadLogCharsResponse) GetSuccess 

func (x *ServerReadLogCharsResponse) GetSuccess() bool

func (*ServerReadLogCharsResponse) ProtoMessage 

func (*ServerReadLogCharsResponse) ProtoMessage()

func (*ServerReadLogCharsResponse) ProtoReflect 

func (x *ServerReadLogCharsResponse) ProtoReflect() protoreflect.Message

func (*ServerReadLogCharsResponse) Reset 

func (x *ServerReadLogCharsResponse) Reset()

func (*ServerReadLogCharsResponse) String 

func (x *ServerReadLogCharsResponse) String() string

type ServerReadLogRequest 

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
}

read log by lines

func (*ServerReadLogRequest) Descriptor deprecated 

func (*ServerReadLogRequest) Descriptor() ([]byte, []int)

Deprecated: Use ServerReadLogRequest.ProtoReflect.Descriptor instead.

func (*ServerReadLogRequest) GetJobId 

func (x *ServerReadLogRequest) GetJobId() int64

func (*ServerReadLogRequest) GetJobInstanceId 

func (x *ServerReadLogRequest) GetJobInstanceId() int64

func (*ServerReadLogRequest) GetOffset 

func (x *ServerReadLogRequest) GetOffset() int64

func (*ServerReadLogRequest) GetScheduleTime 

func (x *ServerReadLogRequest) GetScheduleTime() int64

func (*ServerReadLogRequest) GetSize 

func (x *ServerReadLogRequest) GetSize() int32

func (*ServerReadLogRequest) GetTaskId 

func (x *ServerReadLogRequest) GetTaskId() int64

func (*ServerReadLogRequest) ProtoMessage 

func (*ServerReadLogRequest) ProtoMessage()

func (*ServerReadLogRequest) ProtoReflect 

func (x *ServerReadLogRequest) ProtoReflect() protoreflect.Message

func (*ServerReadLogRequest) Reset 

func (x *ServerReadLogRequest) Reset()

func (*ServerReadLogRequest) String 

func (x *ServerReadLogRequest) String() string

type ServerReadLogResponse 

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
}

func (*ServerReadLogResponse) Descriptor deprecated 

func (*ServerReadLogResponse) Descriptor() ([]byte, []int)

Deprecated: Use ServerReadLogResponse.ProtoReflect.Descriptor instead.

func (*ServerReadLogResponse) GetIsEnd 

func (x *ServerReadLogResponse) GetIsEnd() bool

func (*ServerReadLogResponse) GetLine 

func (x *ServerReadLogResponse) GetLine() []string

func (*ServerReadLogResponse) GetMessage 

func (x *ServerReadLogResponse) GetMessage() string

func (*ServerReadLogResponse) GetOffset 

func (x *ServerReadLogResponse) GetOffset() int64

func (*ServerReadLogResponse) GetSuccess 

func (x *ServerReadLogResponse) GetSuccess() bool

func (*ServerReadLogResponse) ProtoMessage 

func (*ServerReadLogResponse) ProtoMessage()

func (*ServerReadLogResponse) ProtoReflect 

func (x *ServerReadLogResponse) ProtoReflect() protoreflect.Message

func (*ServerReadLogResponse) Reset 

func (x *ServerReadLogResponse) Reset()

func (*ServerReadLogResponse) String 

func (x *ServerReadLogResponse) String() string

type ServerRetryTasksRequest 

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
}

func (*ServerRetryTasksRequest) Descriptor deprecated 

func (*ServerRetryTasksRequest) Descriptor() ([]byte, []int)

Deprecated: Use ServerRetryTasksRequest.ProtoReflect.Descriptor instead.

func (*ServerRetryTasksRequest) GetAppGroupId 

func (x *ServerRetryTasksRequest) GetAppGroupId() int64

func (*ServerRetryTasksRequest) GetAttempt 

func (x *ServerRetryTasksRequest) GetAttempt() int32

func (*ServerRetryTasksRequest) GetContent 

func (x *ServerRetryTasksRequest) GetContent() string

func (*ServerRetryTasksRequest) GetDataTime 

func (x *ServerRetryTasksRequest) GetDataTime() int64

func (*ServerRetryTasksRequest) GetExecuteMode 

func (x *ServerRetryTasksRequest) GetExecuteMode() string

func (*ServerRetryTasksRequest) GetGroupId 

func (x *ServerRetryTasksRequest) GetGroupId() string

func (*ServerRetryTasksRequest) GetInstanceParameters 

func (x *ServerRetryTasksRequest) GetInstanceParameters() string

func (*ServerRetryTasksRequest) GetJobConcurrency 

func (x *ServerRetryTasksRequest) GetJobConcurrency() int32

func (*ServerRetryTasksRequest) GetJobId 

func (x *ServerRetryTasksRequest) GetJobId() int64

func (*ServerRetryTasksRequest) GetJobInstanceId 

func (x *ServerRetryTasksRequest) GetJobInstanceId() int64

func (*ServerRetryTasksRequest) GetJobName 

func (x *ServerRetryTasksRequest) GetJobName() string

func (*ServerRetryTasksRequest) GetJobType 

func (x *ServerRetryTasksRequest) GetJobType() string

func (*ServerRetryTasksRequest) GetMaxAttempt 

func (x *ServerRetryTasksRequest) GetMaxAttempt() int32

func (*ServerRetryTasksRequest) GetParameters 

func (x *ServerRetryTasksRequest) GetParameters() string

func (*ServerRetryTasksRequest) GetRegionId 

func (x *ServerRetryTasksRequest) GetRegionId() int32

func (*ServerRetryTasksRequest) GetRetryTaskEntity 

func (x *ServerRetryTasksRequest) GetRetryTaskEntity() []*RetryTaskEntity

func (*ServerRetryTasksRequest) GetScheduleTime 

func (x *ServerRetryTasksRequest) GetScheduleTime() int64

func (*ServerRetryTasksRequest) GetTimeExpression 

func (x *ServerRetryTasksRequest) GetTimeExpression() string

func (*ServerRetryTasksRequest) GetTimeType 

func (x *ServerRetryTasksRequest) GetTimeType() int32

func (*ServerRetryTasksRequest) GetUpstreamData 

func (x *ServerRetryTasksRequest) GetUpstreamData() []*UpstreamData

func (*ServerRetryTasksRequest) GetUser 

func (x *ServerRetryTasksRequest) GetUser() string

func (*ServerRetryTasksRequest) GetWfInstanceId 

func (x *ServerRetryTasksRequest) GetWfInstanceId() int64

func (*ServerRetryTasksRequest) GetWorkers 

func (x *ServerRetryTasksRequest) GetWorkers() []string

func (*ServerRetryTasksRequest) GetXattrs 

func (x *ServerRetryTasksRequest) GetXattrs() string

func (*ServerRetryTasksRequest) ProtoMessage 

func (*ServerRetryTasksRequest) ProtoMessage()

func (*ServerRetryTasksRequest) ProtoReflect 

func (x *ServerRetryTasksRequest) ProtoReflect() protoreflect.Message

func (*ServerRetryTasksRequest) Reset 

func (x *ServerRetryTasksRequest) Reset()

func (*ServerRetryTasksRequest) String 

func (x *ServerRetryTasksRequest) String() string

type ServerRetryTasksResponse 

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
}

func (*ServerRetryTasksResponse) Descriptor deprecated 

func (*ServerRetryTasksResponse) Descriptor() ([]byte, []int)

Deprecated: Use ServerRetryTasksResponse.ProtoReflect.Descriptor instead.

func (*ServerRetryTasksResponse) GetMessage 

func (x *ServerRetryTasksResponse) GetMessage() string

func (*ServerRetryTasksResponse) GetSuccess 

func (x *ServerRetryTasksResponse) GetSuccess() bool

func (*ServerRetryTasksResponse) ProtoMessage 

func (*ServerRetryTasksResponse) ProtoMessage()

func (*ServerRetryTasksResponse) ProtoReflect 

func (x *ServerRetryTasksResponse) ProtoReflect() protoreflect.Message

func (*ServerRetryTasksResponse) Reset 

func (x *ServerRetryTasksResponse) Reset()

func (*ServerRetryTasksResponse) String 

func (x *ServerRetryTasksResponse) String() string

type ServerSubmitJobInstanceRequest 

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
}

Server submit job instance to Worker

func (*ServerSubmitJobInstanceRequest) Descriptor deprecated 

func (*ServerSubmitJobInstanceRequest) Descriptor() ([]byte, []int)

Deprecated: Use ServerSubmitJobInstanceRequest.ProtoReflect.Descriptor instead.

func (*ServerSubmitJobInstanceRequest) GetAppGroupId 

func (x *ServerSubmitJobInstanceRequest) GetAppGroupId() int64

func (*ServerSubmitJobInstanceRequest) GetAttempt 

func (x *ServerSubmitJobInstanceRequest) GetAttempt() int32

func (*ServerSubmitJobInstanceRequest) GetContent 

func (x *ServerSubmitJobInstanceRequest) GetContent() string

func (*ServerSubmitJobInstanceRequest) GetDataTime 

func (x *ServerSubmitJobInstanceRequest) GetDataTime() int64

func (*ServerSubmitJobInstanceRequest) GetExecuteMode 

func (x *ServerSubmitJobInstanceRequest) GetExecuteMode() string

func (*ServerSubmitJobInstanceRequest) GetGroupId 

func (x *ServerSubmitJobInstanceRequest) GetGroupId() string

func (*ServerSubmitJobInstanceRequest) GetInstanceParameters 

func (x *ServerSubmitJobInstanceRequest) GetInstanceParameters() string

func (*ServerSubmitJobInstanceRequest) GetJobConcurrency 

func (x *ServerSubmitJobInstanceRequest) GetJobConcurrency() int32

func (*ServerSubmitJobInstanceRequest) GetJobId 

func (x *ServerSubmitJobInstanceRequest) GetJobId() int64

func (*ServerSubmitJobInstanceRequest) GetJobInstanceId 

func (x *ServerSubmitJobInstanceRequest) GetJobInstanceId() int64

func (*ServerSubmitJobInstanceRequest) GetJobName 

func (x *ServerSubmitJobInstanceRequest) GetJobName() string

func (*ServerSubmitJobInstanceRequest) GetJobType 

func (x *ServerSubmitJobInstanceRequest) GetJobType() string

func (*ServerSubmitJobInstanceRequest) GetLabelWorkerAddrsMap 

func (x *ServerSubmitJobInstanceRequest) GetLabelWorkerAddrsMap() []*LabelWorkerAddrsEntry

func (*ServerSubmitJobInstanceRequest) GetMaxAttempt 

func (x *ServerSubmitJobInstanceRequest) GetMaxAttempt() int32

func (*ServerSubmitJobInstanceRequest) GetNamespace 

func (x *ServerSubmitJobInstanceRequest) GetNamespace() string

func (*ServerSubmitJobInstanceRequest) GetParameters 

func (x *ServerSubmitJobInstanceRequest) GetParameters() string

func (*ServerSubmitJobInstanceRequest) GetRegionId 

func (x *ServerSubmitJobInstanceRequest) GetRegionId() int32

func (*ServerSubmitJobInstanceRequest) GetRouteStrategyContent 

func (x *ServerSubmitJobInstanceRequest) GetRouteStrategyContent() string

func (*ServerSubmitJobInstanceRequest) GetRouteStrategyType 

func (x *ServerSubmitJobInstanceRequest) GetRouteStrategyType() int32

func (*ServerSubmitJobInstanceRequest) GetScheduleTime 

func (x *ServerSubmitJobInstanceRequest) GetScheduleTime() int64

func (*ServerSubmitJobInstanceRequest) GetTemplate 

func (x *ServerSubmitJobInstanceRequest) GetTemplate() string

func (*ServerSubmitJobInstanceRequest) GetTimeExpression 

func (x *ServerSubmitJobInstanceRequest) GetTimeExpression() string

func (*ServerSubmitJobInstanceRequest) GetTimeType 

func (x *ServerSubmitJobInstanceRequest) GetTimeType() int32

func (*ServerSubmitJobInstanceRequest) GetTriggerType 

func (x *ServerSubmitJobInstanceRequest) GetTriggerType() int32

func (*ServerSubmitJobInstanceRequest) GetUpstreamData 

func (x *ServerSubmitJobInstanceRequest) GetUpstreamData() []*UpstreamData

func (*ServerSubmitJobInstanceRequest) GetUser 

func (x *ServerSubmitJobInstanceRequest) GetUser() string

func (*ServerSubmitJobInstanceRequest) GetWfInstanceId 

func (x *ServerSubmitJobInstanceRequest) GetWfInstanceId() int64

func (*ServerSubmitJobInstanceRequest) GetWorkers 

func (x *ServerSubmitJobInstanceRequest) GetWorkers() []string

func (*ServerSubmitJobInstanceRequest) GetXattrs 

func (x *ServerSubmitJobInstanceRequest) GetXattrs() string

func (*ServerSubmitJobInstanceRequest) ProtoMessage 

func (*ServerSubmitJobInstanceRequest) ProtoMessage()

func (*ServerSubmitJobInstanceRequest) ProtoReflect 

func (x *ServerSubmitJobInstanceRequest) ProtoReflect() protoreflect.Message

func (*ServerSubmitJobInstanceRequest) Reset 

func (x *ServerSubmitJobInstanceRequest) Reset()

func (*ServerSubmitJobInstanceRequest) String 

func (x *ServerSubmitJobInstanceRequest) String() string

type ServerSubmitJobInstanceResponse 

type ServerSubmitJobInstanceResponse 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
}

func (*ServerSubmitJobInstanceResponse) Descriptor deprecated 

func (*ServerSubmitJobInstanceResponse) Descriptor() ([]byte, []int)

Deprecated: Use ServerSubmitJobInstanceResponse.ProtoReflect.Descriptor instead.

func (*ServerSubmitJobInstanceResponse) GetMessage 

func (x *ServerSubmitJobInstanceResponse) GetMessage() string

func (*ServerSubmitJobInstanceResponse) GetSuccess 

func (x *ServerSubmitJobInstanceResponse) GetSuccess() bool

func (*ServerSubmitJobInstanceResponse) ProtoMessage 

func (*ServerSubmitJobInstanceResponse) ProtoMessage()

func (*ServerSubmitJobInstanceResponse) ProtoReflect 

func (x *ServerSubmitJobInstanceResponse) ProtoReflect() protoreflect.Message

func (*ServerSubmitJobInstanceResponse) Reset 

func (x *ServerSubmitJobInstanceResponse) Reset()

func (*ServerSubmitJobInstanceResponse) String 

func (x *ServerSubmitJobInstanceResponse) String() string

type ServerSyncK8SCronJobRequest 

type ServerSyncK8SCronJobRequest struct {
	AppGroupId *int64 `protobuf:"varint,1,opt,name=app_group_id,json=appGroupId" json:"app_group_id,omitempty"`
	// contains filtered or unexported fields
}

Sync worker k8s cron job

func (*ServerSyncK8SCronJobRequest) Descriptor deprecated 

func (*ServerSyncK8SCronJobRequest) Descriptor() ([]byte, []int)

Deprecated: Use ServerSyncK8SCronJobRequest.ProtoReflect.Descriptor instead.

func (*ServerSyncK8SCronJobRequest) GetAppGroupId 

func (x *ServerSyncK8SCronJobRequest) GetAppGroupId() int64

func (*ServerSyncK8SCronJobRequest) ProtoMessage 

func (*ServerSyncK8SCronJobRequest) ProtoMessage()

func (*ServerSyncK8SCronJobRequest) ProtoReflect 

func (x *ServerSyncK8SCronJobRequest) ProtoReflect() protoreflect.Message

func (*ServerSyncK8SCronJobRequest) Reset 

func (x *ServerSyncK8SCronJobRequest) Reset()

func (*ServerSyncK8SCronJobRequest) String 

func (x *ServerSyncK8SCronJobRequest) String() string

type ServerSyncK8SCronJobResponse 

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

func (*ServerSyncK8SCronJobResponse) Descriptor deprecated 

func (*ServerSyncK8SCronJobResponse) Descriptor() ([]byte, []int)

Deprecated: Use ServerSyncK8SCronJobResponse.ProtoReflect.Descriptor instead.

func (*ServerSyncK8SCronJobResponse) GetCronJobYaml 

func (x *ServerSyncK8SCronJobResponse) GetCronJobYaml() []string

func (*ServerSyncK8SCronJobResponse) GetMessage 

func (x *ServerSyncK8SCronJobResponse) GetMessage() string

func (*ServerSyncK8SCronJobResponse) GetSuccess 

func (x *ServerSyncK8SCronJobResponse) GetSuccess() bool

func (*ServerSyncK8SCronJobResponse) ProtoMessage 

func (*ServerSyncK8SCronJobResponse) ProtoMessage()

func (*ServerSyncK8SCronJobResponse) ProtoReflect 

func (x *ServerSyncK8SCronJobResponse) ProtoReflect() protoreflect.Message

func (*ServerSyncK8SCronJobResponse) Reset 

func (x *ServerSyncK8SCronJobResponse) Reset()

func (*ServerSyncK8SCronJobResponse) String 

func (x *ServerSyncK8SCronJobResponse) String() string

type ServerSyncK8SJobRequest 

type ServerSyncK8SJobRequest struct {
	AppGroupId *int64 `protobuf:"varint,1,opt,name=app_group_id,json=appGroupId" json:"app_group_id,omitempty"`
	// contains filtered or unexported fields
}

Sync worker k8s job

func (*ServerSyncK8SJobRequest) Descriptor deprecated 

func (*ServerSyncK8SJobRequest) Descriptor() ([]byte, []int)

Deprecated: Use ServerSyncK8SJobRequest.ProtoReflect.Descriptor instead.

func (*ServerSyncK8SJobRequest) GetAppGroupId 

func (x *ServerSyncK8SJobRequest) GetAppGroupId() int64

func (*ServerSyncK8SJobRequest) ProtoMessage 

func (*ServerSyncK8SJobRequest) ProtoMessage()

func (*ServerSyncK8SJobRequest) ProtoReflect 

func (x *ServerSyncK8SJobRequest) ProtoReflect() protoreflect.Message

func (*ServerSyncK8SJobRequest) Reset 

func (x *ServerSyncK8SJobRequest) Reset()

func (*ServerSyncK8SJobRequest) String 

func (x *ServerSyncK8SJobRequest) String() string

type ServerSyncK8SJobResponse 

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

func (*ServerSyncK8SJobResponse) Descriptor deprecated 

func (*ServerSyncK8SJobResponse) Descriptor() ([]byte, []int)

Deprecated: Use ServerSyncK8SJobResponse.ProtoReflect.Descriptor instead.

func (*ServerSyncK8SJobResponse) GetJobYaml 

func (x *ServerSyncK8SJobResponse) GetJobYaml() []string

func (*ServerSyncK8SJobResponse) GetMessage 

func (x *ServerSyncK8SJobResponse) GetMessage() string

func (*ServerSyncK8SJobResponse) GetSuccess 

func (x *ServerSyncK8SJobResponse) GetSuccess() bool

func (*ServerSyncK8SJobResponse) ProtoMessage 

func (*ServerSyncK8SJobResponse) ProtoMessage()

func (*ServerSyncK8SJobResponse) ProtoReflect 

func (x *ServerSyncK8SJobResponse) ProtoReflect() protoreflect.Message

func (*ServerSyncK8SJobResponse) Reset 

func (x *ServerSyncK8SJobResponse) Reset()

func (*ServerSyncK8SJobResponse) String 

func (x *ServerSyncK8SJobResponse) String() string

type ServerTailLogRequest 

type ServerTailLogRequest 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"`
	Num           *int32 `protobuf:"varint,4,req,name=num" json:"num,omitempty"`
	ScheduleTime  *int64 `protobuf:"varint,5,req,name=schedule_time,json=scheduleTime" json:"schedule_time,omitempty"`
	// contains filtered or unexported fields
}

tail log

func (*ServerTailLogRequest) Descriptor deprecated 

func (*ServerTailLogRequest) Descriptor() ([]byte, []int)

Deprecated: Use ServerTailLogRequest.ProtoReflect.Descriptor instead.

func (*ServerTailLogRequest) GetJobId 

func (x *ServerTailLogRequest) GetJobId() int64

func (*ServerTailLogRequest) GetJobInstanceId 

func (x *ServerTailLogRequest) GetJobInstanceId() int64

func (*ServerTailLogRequest) GetNum 

func (x *ServerTailLogRequest) GetNum() int32

func (*ServerTailLogRequest) GetScheduleTime 

func (x *ServerTailLogRequest) GetScheduleTime() int64

func (*ServerTailLogRequest) GetTaskId 

func (x *ServerTailLogRequest) GetTaskId() int64

func (*ServerTailLogRequest) ProtoMessage 

func (*ServerTailLogRequest) ProtoMessage()

func (*ServerTailLogRequest) ProtoReflect 

func (x *ServerTailLogRequest) ProtoReflect() protoreflect.Message

func (*ServerTailLogRequest) Reset 

func (x *ServerTailLogRequest) Reset()

func (*ServerTailLogRequest) String 

func (x *ServerTailLogRequest) String() string

type ServerTailLogResponse 

type ServerTailLogResponse 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"`
	// contains filtered or unexported fields
}

func (*ServerTailLogResponse) Descriptor deprecated 

func (*ServerTailLogResponse) Descriptor() ([]byte, []int)

Deprecated: Use ServerTailLogResponse.ProtoReflect.Descriptor instead.

func (*ServerTailLogResponse) GetLine 

func (x *ServerTailLogResponse) GetLine() []string

func (*ServerTailLogResponse) GetMessage 

func (x *ServerTailLogResponse) GetMessage() string

func (*ServerTailLogResponse) GetSuccess 

func (x *ServerTailLogResponse) GetSuccess() bool

func (*ServerTailLogResponse) ProtoMessage 

func (*ServerTailLogResponse) ProtoMessage()

func (*ServerTailLogResponse) ProtoReflect 

func (x *ServerTailLogResponse) ProtoReflect() protoreflect.Message

func (*ServerTailLogResponse) Reset 

func (x *ServerTailLogResponse) Reset()

func (*ServerTailLogResponse) String 

func (x *ServerTailLogResponse) String() string

type ServerThreadDumpRequest 

type ServerThreadDumpRequest 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"`
	Line          *int32 `protobuf:"varint,4,opt,name=line,def=20" json:"line,omitempty"`
	// contains filtered or unexported fields
}

thread dump

func (*ServerThreadDumpRequest) Descriptor deprecated 

func (*ServerThreadDumpRequest) Descriptor() ([]byte, []int)

Deprecated: Use ServerThreadDumpRequest.ProtoReflect.Descriptor instead.

func (*ServerThreadDumpRequest) GetJobId 

func (x *ServerThreadDumpRequest) GetJobId() int64

func (*ServerThreadDumpRequest) GetJobInstanceId 

func (x *ServerThreadDumpRequest) GetJobInstanceId() int64

func (*ServerThreadDumpRequest) GetLine 

func (x *ServerThreadDumpRequest) GetLine() int32

func (*ServerThreadDumpRequest) GetTaskId 

func (x *ServerThreadDumpRequest) GetTaskId() int64

func (*ServerThreadDumpRequest) ProtoMessage 

func (*ServerThreadDumpRequest) ProtoMessage()

func (*ServerThreadDumpRequest) ProtoReflect 

func (x *ServerThreadDumpRequest) ProtoReflect() protoreflect.Message

func (*ServerThreadDumpRequest) Reset 

func (x *ServerThreadDumpRequest) Reset()

func (*ServerThreadDumpRequest) String 

func (x *ServerThreadDumpRequest) String() string

type ServerThreadDumpResponse 

type ServerThreadDumpResponse 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"`
	// contains filtered or unexported fields
}

func (*ServerThreadDumpResponse) Descriptor deprecated 

func (*ServerThreadDumpResponse) Descriptor() ([]byte, []int)

Deprecated: Use ServerThreadDumpResponse.ProtoReflect.Descriptor instead.

func (*ServerThreadDumpResponse) GetLine 

func (x *ServerThreadDumpResponse) GetLine() []string

func (*ServerThreadDumpResponse) GetMessage 

func (x *ServerThreadDumpResponse) GetMessage() string

func (*ServerThreadDumpResponse) GetSuccess 

func (x *ServerThreadDumpResponse) GetSuccess() bool

func (*ServerThreadDumpResponse) ProtoMessage 

func (*ServerThreadDumpResponse) ProtoMessage()

func (*ServerThreadDumpResponse) ProtoReflect 

func (x *ServerThreadDumpResponse) ProtoReflect() protoreflect.Message

func (*ServerThreadDumpResponse) Reset 

func (x *ServerThreadDumpResponse) Reset()

func (*ServerThreadDumpResponse) String 

func (x *ServerThreadDumpResponse) String() string

type TaskMessage 

type TaskMessage 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"`
	TaskBody []byte  `protobuf:"bytes,3,req,name=task_body,json=taskBody" json:"task_body,omitempty"`
	// contains filtered or unexported fields
}

Worker pull tasks from Server

func (*TaskMessage) Descriptor deprecated 

func (*TaskMessage) Descriptor() ([]byte, []int)

Deprecated: Use TaskMessage.ProtoReflect.Descriptor instead.

func (*TaskMessage) GetTaskBody 

func (x *TaskMessage) GetTaskBody() []byte

func (*TaskMessage) GetTaskId 

func (x *TaskMessage) GetTaskId() int64

func (*TaskMessage) GetTaskName 

func (x *TaskMessage) GetTaskName() string

func (*TaskMessage) ProtoMessage 

func (*TaskMessage) ProtoMessage()

func (*TaskMessage) ProtoReflect 

func (x *TaskMessage) ProtoReflect() protoreflect.Message

func (*TaskMessage) Reset 

func (x *TaskMessage) Reset()

func (*TaskMessage) String 

func (x *TaskMessage) String() string

type TaskStatusInfo 

type TaskStatusInfo struct {
	TaskId   *int64  `protobuf:"varint,1,req,name=task_id,json=taskId" json:"task_id,omitempty"`
	Status   *int32  `protobuf:"varint,2,req,name=status" json:"status,omitempty"`
	Result   *string `protobuf:"bytes,3,opt,name=result" json:"result,omitempty"`
	TaskName *string `protobuf:"bytes,4,opt,name=task_name,json=taskName" json:"task_name,omitempty"`
	Progress *string `protobuf:"bytes,5,opt,name=progress" json:"progress,omitempty"`
	TraceId  *string `protobuf:"bytes,6,opt,name=traceId" json:"traceId,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskStatusInfo) Descriptor deprecated 

func (*TaskStatusInfo) Descriptor() ([]byte, []int)

Deprecated: Use TaskStatusInfo.ProtoReflect.Descriptor instead.

func (*TaskStatusInfo) GetProgress 

func (x *TaskStatusInfo) GetProgress() string

func (*TaskStatusInfo) GetResult 

func (x *TaskStatusInfo) GetResult() string

func (*TaskStatusInfo) GetStatus 

func (x *TaskStatusInfo) GetStatus() int32

func (*TaskStatusInfo) GetTaskId 

func (x *TaskStatusInfo) GetTaskId() int64

func (*TaskStatusInfo) GetTaskName 

func (x *TaskStatusInfo) GetTaskName() string

func (*TaskStatusInfo) GetTraceId 

func (x *TaskStatusInfo) GetTraceId() string

func (*TaskStatusInfo) ProtoMessage 

func (*TaskStatusInfo) ProtoMessage()

func (*TaskStatusInfo) ProtoReflect 

func (x *TaskStatusInfo) ProtoReflect() protoreflect.Message

func (*TaskStatusInfo) Reset 

func (x *TaskStatusInfo) Reset()

func (*TaskStatusInfo) String 

func (x *TaskStatusInfo) String() string

type UpstreamData 

type UpstreamData struct {
	JobName *string `protobuf:"bytes,1,req,name=job_name,json=jobName" json:"job_name,omitempty"`
	Data    *string `protobuf:"bytes,2,req,name=data" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*UpstreamData) Descriptor deprecated 

func (*UpstreamData) Descriptor() ([]byte, []int)

Deprecated: Use UpstreamData.ProtoReflect.Descriptor instead.

func (*UpstreamData) GetData 

func (x *UpstreamData) GetData() string

func (*UpstreamData) GetJobName 

func (x *UpstreamData) GetJobName() string

func (*UpstreamData) ProtoMessage 

func (*UpstreamData) ProtoMessage()

func (*UpstreamData) ProtoReflect 

func (x *UpstreamData) ProtoReflect() protoreflect.Message

func (*UpstreamData) Reset 

func (x *UpstreamData) Reset()

func (*UpstreamData) String 

func (x *UpstreamData) String() string

type WorkerBatchCreateTasksRequest 

type WorkerBatchCreateTasksRequest struct {
	JobInstanceId *int64                     `protobuf:"varint,1,req,name=job_instance_id,json=jobInstanceId" json:"job_instance_id,omitempty"`
	Task          []*WorkerCreateTaskRequest `protobuf:"bytes,2,rep,name=task" json:"task,omitempty"`
	DeliveryId    *int64                     `protobuf:"varint,3,opt,name=delivery_id,json=deliveryId" json:"delivery_id,omitempty"`
	WorkerId      *string                    `protobuf:"bytes,4,opt,name=worker_id,json=workerId" json:"worker_id,omitempty"`
	WorkerAddr    *string                    `protobuf:"bytes,5,opt,name=worker_addr,json=workerAddr" json:"worker_addr,omitempty"`
	// contains filtered or unexported fields
}

Worker batch create tasks to Server

func (*WorkerBatchCreateTasksRequest) Descriptor deprecated 

func (*WorkerBatchCreateTasksRequest) Descriptor() ([]byte, []int)

Deprecated: Use WorkerBatchCreateTasksRequest.ProtoReflect.Descriptor instead.

func (*WorkerBatchCreateTasksRequest) GetDeliveryId 

func (x *WorkerBatchCreateTasksRequest) GetDeliveryId() int64

func (*WorkerBatchCreateTasksRequest) GetJobInstanceId 

func (x *WorkerBatchCreateTasksRequest) GetJobInstanceId() int64

func (*WorkerBatchCreateTasksRequest) GetTask 

func (x *WorkerBatchCreateTasksRequest) GetTask() []*WorkerCreateTaskRequest

func (*WorkerBatchCreateTasksRequest) GetWorkerAddr 

func (x *WorkerBatchCreateTasksRequest) GetWorkerAddr() string

func (*WorkerBatchCreateTasksRequest) GetWorkerId 

func (x *WorkerBatchCreateTasksRequest) GetWorkerId() string

func (*WorkerBatchCreateTasksRequest) ProtoMessage 

func (*WorkerBatchCreateTasksRequest) ProtoMessage()

func (*WorkerBatchCreateTasksRequest) ProtoReflect 

func (x *WorkerBatchCreateTasksRequest) ProtoReflect() protoreflect.Message

func (*WorkerBatchCreateTasksRequest) Reset 

func (x *WorkerBatchCreateTasksRequest) Reset()

func (*WorkerBatchCreateTasksRequest) String 

func (x *WorkerBatchCreateTasksRequest) String() string

type WorkerBatchCreateTasksResponse 

type WorkerBatchCreateTasksResponse 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
}

func (*WorkerBatchCreateTasksResponse) Descriptor deprecated 

func (*WorkerBatchCreateTasksResponse) Descriptor() ([]byte, []int)

Deprecated: Use WorkerBatchCreateTasksResponse.ProtoReflect.Descriptor instead.

func (*WorkerBatchCreateTasksResponse) GetDeliveryId 

func (x *WorkerBatchCreateTasksResponse) GetDeliveryId() int64

func (*WorkerBatchCreateTasksResponse) GetMessage 

func (x *WorkerBatchCreateTasksResponse) GetMessage() string

func (*WorkerBatchCreateTasksResponse) GetSuccess 

func (x *WorkerBatchCreateTasksResponse) GetSuccess() bool

func (*WorkerBatchCreateTasksResponse) ProtoMessage 

func (*WorkerBatchCreateTasksResponse) ProtoMessage()

func (*WorkerBatchCreateTasksResponse) ProtoReflect 

func (x *WorkerBatchCreateTasksResponse) ProtoReflect() protoreflect.Message

func (*WorkerBatchCreateTasksResponse) Reset 

func (x *WorkerBatchCreateTasksResponse) Reset()

func (*WorkerBatchCreateTasksResponse) String 

func (x *WorkerBatchCreateTasksResponse) String() string

type WorkerBatchReportTaskStatuesRequest 

type WorkerBatchReportTaskStatuesRequest struct {
	JobInstanceId         *int64              `protobuf:"varint,1,req,name=job_instance_id,json=jobInstanceId" json:"job_instance_id,omitempty"`
	TaskStatues           []*BatchTaskStatues `protobuf:"bytes,2,rep,name=task_statues,json=taskStatues" json:"task_statues,omitempty"`
	DeliveryId            *int64              `protobuf:"varint,3,opt,name=delivery_id,json=deliveryId" json:"delivery_id,omitempty"`
	AlreadyUnConfirmRetry *bool               `protobuf:"varint,4,opt,name=already_unConfirm_retry,json=alreadyUnConfirmRetry" json:"already_unConfirm_retry,omitempty"`
	GroupId               *string             `protobuf:"bytes,5,opt,name=group_id,json=groupId" json:"group_id,omitempty"`
	// contains filtered or unexported fields
}

Worker batch report task statuses to Server

func (*WorkerBatchReportTaskStatuesRequest) Descriptor deprecated 

func (*WorkerBatchReportTaskStatuesRequest) Descriptor() ([]byte, []int)

Deprecated: Use WorkerBatchReportTaskStatuesRequest.ProtoReflect.Descriptor instead.

func (*WorkerBatchReportTaskStatuesRequest) GetAlreadyUnConfirmRetry 

func (x *WorkerBatchReportTaskStatuesRequest) GetAlreadyUnConfirmRetry() bool

func (*WorkerBatchReportTaskStatuesRequest) GetDeliveryId 

func (x *WorkerBatchReportTaskStatuesRequest) GetDeliveryId() int64

func (*WorkerBatchReportTaskStatuesRequest) GetGroupId 

func (x *WorkerBatchReportTaskStatuesRequest) GetGroupId() string

func (*WorkerBatchReportTaskStatuesRequest) GetJobInstanceId 

func (x *WorkerBatchReportTaskStatuesRequest) GetJobInstanceId() int64

func (*WorkerBatchReportTaskStatuesRequest) GetTaskStatues 

func (x *WorkerBatchReportTaskStatuesRequest) GetTaskStatues() []*BatchTaskStatues

func (*WorkerBatchReportTaskStatuesRequest) ProtoMessage 

func (*WorkerBatchReportTaskStatuesRequest) ProtoMessage()

func (*WorkerBatchReportTaskStatuesRequest) ProtoReflect 

func (x *WorkerBatchReportTaskStatuesRequest) ProtoReflect() protoreflect.Message

func (*WorkerBatchReportTaskStatuesRequest) Reset 

func (x *WorkerBatchReportTaskStatuesRequest) Reset()

func (*WorkerBatchReportTaskStatuesRequest) String 

func (x *WorkerBatchReportTaskStatuesRequest) String() string

type WorkerBatchReportTaskStatuesResponse 

type WorkerBatchReportTaskStatuesResponse 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"`
	AffectCnt  *int32  `protobuf:"varint,4,opt,name=affect_cnt,json=affectCnt" json:"affect_cnt,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerBatchReportTaskStatuesResponse) Descriptor deprecated 

func (*WorkerBatchReportTaskStatuesResponse) Descriptor() ([]byte, []int)

Deprecated: Use WorkerBatchReportTaskStatuesResponse.ProtoReflect.Descriptor instead.

func (*WorkerBatchReportTaskStatuesResponse) GetAffectCnt 

func (x *WorkerBatchReportTaskStatuesResponse) GetAffectCnt() int32

func (*WorkerBatchReportTaskStatuesResponse) GetDeliveryId 

func (x *WorkerBatchReportTaskStatuesResponse) GetDeliveryId() int64

func (*WorkerBatchReportTaskStatuesResponse) GetMessage 

func (x *WorkerBatchReportTaskStatuesResponse) GetMessage() string

func (*WorkerBatchReportTaskStatuesResponse) GetSuccess 

func (x *WorkerBatchReportTaskStatuesResponse) GetSuccess() bool

func (*WorkerBatchReportTaskStatuesResponse) ProtoMessage 

func (*WorkerBatchReportTaskStatuesResponse) ProtoMessage()

func (*WorkerBatchReportTaskStatuesResponse) ProtoReflect 

func (x *WorkerBatchReportTaskStatuesResponse) ProtoReflect() protoreflect.Message

func (*WorkerBatchReportTaskStatuesResponse) Reset 

func (x *WorkerBatchReportTaskStatuesResponse) Reset()

func (*WorkerBatchReportTaskStatuesResponse) String 

func (x *WorkerBatchReportTaskStatuesResponse) String() string

type WorkerBatchUpdateTaskStatusRequest 

type WorkerBatchUpdateTaskStatusRequest struct {
	JobInstanceId *int64  `protobuf:"varint,1,req,name=job_instance_id,json=jobInstanceId" json:"job_instance_id,omitempty"`
	Status        *int32  `protobuf:"varint,2,req,name=status" json:"status,omitempty"`
	WorkerAddr    *string `protobuf:"bytes,3,opt,name=worker_addr,json=workerAddr" json:"worker_addr,omitempty"`
	WorkerId      *string `protobuf:"bytes,4,opt,name=worker_id,json=workerId" json:"worker_id,omitempty"`
	// contains filtered or unexported fields
}

ServerPersistence batch update task status, e.g. worker is down

func (*WorkerBatchUpdateTaskStatusRequest) Descriptor deprecated 

func (*WorkerBatchUpdateTaskStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use WorkerBatchUpdateTaskStatusRequest.ProtoReflect.Descriptor instead.

func (*WorkerBatchUpdateTaskStatusRequest) GetJobInstanceId 

func (x *WorkerBatchUpdateTaskStatusRequest) GetJobInstanceId() int64

func (*WorkerBatchUpdateTaskStatusRequest) GetStatus 

func (x *WorkerBatchUpdateTaskStatusRequest) GetStatus() int32

func (*WorkerBatchUpdateTaskStatusRequest) GetWorkerAddr 

func (x *WorkerBatchUpdateTaskStatusRequest) GetWorkerAddr() string

func (*WorkerBatchUpdateTaskStatusRequest) GetWorkerId 

func (x *WorkerBatchUpdateTaskStatusRequest) GetWorkerId() string

func (*WorkerBatchUpdateTaskStatusRequest) ProtoMessage 

func (*WorkerBatchUpdateTaskStatusRequest) ProtoMessage()

func (*WorkerBatchUpdateTaskStatusRequest) ProtoReflect 

func (x *WorkerBatchUpdateTaskStatusRequest) ProtoReflect() protoreflect.Message

func (*WorkerBatchUpdateTaskStatusRequest) Reset 

func (x *WorkerBatchUpdateTaskStatusRequest) Reset()

func (*WorkerBatchUpdateTaskStatusRequest) String 

func (x *WorkerBatchUpdateTaskStatusRequest) String() string

type WorkerBatchUpdateTaskStatusResponse 

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

func (*WorkerBatchUpdateTaskStatusResponse) Descriptor deprecated 

func (*WorkerBatchUpdateTaskStatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use WorkerBatchUpdateTaskStatusResponse.ProtoReflect.Descriptor instead.

func (*WorkerBatchUpdateTaskStatusResponse) GetAffectCnt 

func (x *WorkerBatchUpdateTaskStatusResponse) GetAffectCnt() int32

func (*WorkerBatchUpdateTaskStatusResponse) GetMessage 

func (x *WorkerBatchUpdateTaskStatusResponse) GetMessage() string

func (*WorkerBatchUpdateTaskStatusResponse) GetSuccess 

func (x *WorkerBatchUpdateTaskStatusResponse) GetSuccess() bool

func (*WorkerBatchUpdateTaskStatusResponse) ProtoMessage 

func (*WorkerBatchUpdateTaskStatusResponse) ProtoMessage()

func (*WorkerBatchUpdateTaskStatusResponse) ProtoReflect 

func (x *WorkerBatchUpdateTaskStatusResponse) ProtoReflect() protoreflect.Message

func (*WorkerBatchUpdateTaskStatusResponse) Reset 

func (x *WorkerBatchUpdateTaskStatusResponse) Reset()

func (*WorkerBatchUpdateTaskStatusResponse) String 

func (x *WorkerBatchUpdateTaskStatusResponse) String() string

type WorkerClearTasksRequest 

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

Worker clear tasks by jobInstanceId to Server

func (*WorkerClearTasksRequest) Descriptor deprecated 

func (*WorkerClearTasksRequest) Descriptor() ([]byte, []int)

Deprecated: Use WorkerClearTasksRequest.ProtoReflect.Descriptor instead.

func (*WorkerClearTasksRequest) GetJobInstanceId 

func (x *WorkerClearTasksRequest) GetJobInstanceId() int64

func (*WorkerClearTasksRequest) ProtoMessage 

func (*WorkerClearTasksRequest) ProtoMessage()

func (*WorkerClearTasksRequest) ProtoReflect 

func (x *WorkerClearTasksRequest) ProtoReflect() protoreflect.Message

func (*WorkerClearTasksRequest) Reset 

func (x *WorkerClearTasksRequest) Reset()

func (*WorkerClearTasksRequest) String 

func (x *WorkerClearTasksRequest) String() string

type WorkerClearTasksResponse 

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

func (*WorkerClearTasksResponse) Descriptor deprecated 

func (*WorkerClearTasksResponse) Descriptor() ([]byte, []int)

Deprecated: Use WorkerClearTasksResponse.ProtoReflect.Descriptor instead.

func (*WorkerClearTasksResponse) GetCount 

func (x *WorkerClearTasksResponse) GetCount() int32

func (*WorkerClearTasksResponse) GetMessage 

func (x *WorkerClearTasksResponse) GetMessage() string

func (*WorkerClearTasksResponse) GetSuccess 

func (x *WorkerClearTasksResponse) GetSuccess() bool

func (*WorkerClearTasksResponse) ProtoMessage 

func (*WorkerClearTasksResponse) ProtoMessage()

func (*WorkerClearTasksResponse) ProtoReflect 

func (x *WorkerClearTasksResponse) ProtoReflect() protoreflect.Message

func (*WorkerClearTasksResponse) Reset 

func (x *WorkerClearTasksResponse) Reset()

func (*WorkerClearTasksResponse) String 

func (x *WorkerClearTasksResponse) String() string

type WorkerCreateTaskRequest 

type WorkerCreateTaskRequest 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"`
	TaskName      *string `protobuf:"bytes,4,req,name=task_name,json=taskName" json:"task_name,omitempty"`
	TaskBody      []byte  `protobuf:"bytes,5,req,name=task_body,json=taskBody" json:"task_body,omitempty"`
	DeliveryId    *int64  `protobuf:"varint,6,opt,name=delivery_id,json=deliveryId" json:"delivery_id,omitempty"`
	LabelMap      *string `protobuf:"bytes,7,opt,name=label_map,json=labelMap" json:"label_map,omitempty"`
	// contains filtered or unexported fields
}

Worker create a task to Server

func (*WorkerCreateTaskRequest) Descriptor deprecated 

func (*WorkerCreateTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use WorkerCreateTaskRequest.ProtoReflect.Descriptor instead.

func (*WorkerCreateTaskRequest) GetDeliveryId 

func (x *WorkerCreateTaskRequest) GetDeliveryId() int64

func (*WorkerCreateTaskRequest) GetJobId 

func (x *WorkerCreateTaskRequest) GetJobId() int64

func (*WorkerCreateTaskRequest) GetJobInstanceId 

func (x *WorkerCreateTaskRequest) GetJobInstanceId() int64

func (*WorkerCreateTaskRequest) GetLabelMap 

func (x *WorkerCreateTaskRequest) GetLabelMap() string

func (*WorkerCreateTaskRequest) GetTaskBody 

func (x *WorkerCreateTaskRequest) GetTaskBody() []byte

func (*WorkerCreateTaskRequest) GetTaskId 

func (x *WorkerCreateTaskRequest) GetTaskId() int64

func (*WorkerCreateTaskRequest) GetTaskName 

func (x *WorkerCreateTaskRequest) GetTaskName() string

func (*WorkerCreateTaskRequest) ProtoMessage 

func (*WorkerCreateTaskRequest) ProtoMessage()

func (*WorkerCreateTaskRequest) ProtoReflect 

func (x *WorkerCreateTaskRequest) ProtoReflect() protoreflect.Message

func (*WorkerCreateTaskRequest) Reset 

func (x *WorkerCreateTaskRequest) Reset()

func (*WorkerCreateTaskRequest) String 

func (x *WorkerCreateTaskRequest) String() string

type WorkerCreateTaskResponse 

type WorkerCreateTaskResponse 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
}

func (*WorkerCreateTaskResponse) Descriptor deprecated 

func (*WorkerCreateTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use WorkerCreateTaskResponse.ProtoReflect.Descriptor instead.

func (*WorkerCreateTaskResponse) GetDeliveryId 

func (x *WorkerCreateTaskResponse) GetDeliveryId() int64

func (*WorkerCreateTaskResponse) GetMessage 

func (x *WorkerCreateTaskResponse) GetMessage() string

func (*WorkerCreateTaskResponse) GetSuccess 

func (x *WorkerCreateTaskResponse) GetSuccess() bool

func (*WorkerCreateTaskResponse) ProtoMessage 

func (*WorkerCreateTaskResponse) ProtoMessage()

func (*WorkerCreateTaskResponse) ProtoReflect 

func (x *WorkerCreateTaskResponse) ProtoReflect() protoreflect.Message

func (*WorkerCreateTaskResponse) Reset 

func (x *WorkerCreateTaskResponse) Reset()

func (*WorkerCreateTaskResponse) String 

func (x *WorkerCreateTaskResponse) String() string

type WorkerHeartBeatRequest 

type WorkerHeartBeatRequest struct {
	GroupId       *string `protobuf:"bytes,1,req,name=group_id,json=groupId" json:"group_id,omitempty"`
	Version       *string `protobuf:"bytes,2,req,name=version" json:"version,omitempty"`
	WorkerId      *string `protobuf:"bytes,3,req,name=worker_id,json=workerId" json:"worker_id,omitempty"`
	MetricsJson   *string `protobuf:"bytes,4,opt,name=metrics_json,json=metricsJson" json:"metrics_json,omitempty"`
	JobInstanceId []int64 `protobuf:"varint,5,rep,name=job_instance_id,json=jobInstanceId" json:"job_instance_id,omitempty"`
	Starter       *string `protobuf:"bytes,6,opt,name=starter" json:"starter,omitempty"`
	AppGroupId    *int64  `protobuf:"varint,7,opt,name=app_group_id,json=appGroupId" json:"app_group_id,omitempty"`
	Source        *string `protobuf:"bytes,8,opt,name=source" json:"source,omitempty"`
	Label         *string `protobuf:"bytes,9,opt,name=label" json:"label,omitempty"`
	Online        *bool   `protobuf:"varint,10,opt,name=online" json:"online,omitempty"`
	AppKey        *string `protobuf:"bytes,11,opt,name=app_key,json=appKey" json:"app_key,omitempty"`
	RpcPort       *int32  `protobuf:"varint,12,opt,name=rpc_port,json=rpcPort" json:"rpc_port,omitempty"`
	// contains filtered or unexported fields
}

Worker report heartbeat to Server

func (*WorkerHeartBeatRequest) Descriptor deprecated 

func (*WorkerHeartBeatRequest) Descriptor() ([]byte, []int)

Deprecated: Use WorkerHeartBeatRequest.ProtoReflect.Descriptor instead.

func (*WorkerHeartBeatRequest) GetAppGroupId 

func (x *WorkerHeartBeatRequest) GetAppGroupId() int64

func (*WorkerHeartBeatRequest) GetAppKey 

func (x *WorkerHeartBeatRequest) GetAppKey() string

func (*WorkerHeartBeatRequest) GetGroupId 

func (x *WorkerHeartBeatRequest) GetGroupId() string

func (*WorkerHeartBeatRequest) GetJobInstanceId 

func (x *WorkerHeartBeatRequest) GetJobInstanceId() []int64

func (*WorkerHeartBeatRequest) GetLabel 

func (x *WorkerHeartBeatRequest) GetLabel() string

func (*WorkerHeartBeatRequest) GetMetricsJson 

func (x *WorkerHeartBeatRequest) GetMetricsJson() string

func (*WorkerHeartBeatRequest) GetOnline 

func (x *WorkerHeartBeatRequest) GetOnline() bool

func (*WorkerHeartBeatRequest) GetRpcPort added in v0.0.2 

func (x *WorkerHeartBeatRequest) GetRpcPort() int32

func (*WorkerHeartBeatRequest) GetSource 

func (x *WorkerHeartBeatRequest) GetSource() string

func (*WorkerHeartBeatRequest) GetStarter 

func (x *WorkerHeartBeatRequest) GetStarter() string

func (*WorkerHeartBeatRequest) GetVersion 

func (x *WorkerHeartBeatRequest) GetVersion() string

func (*WorkerHeartBeatRequest) GetWorkerId 

func (x *WorkerHeartBeatRequest) GetWorkerId() string

func (*WorkerHeartBeatRequest) ProtoMessage 

func (*WorkerHeartBeatRequest) ProtoMessage()

func (*WorkerHeartBeatRequest) ProtoReflect 

func (x *WorkerHeartBeatRequest) ProtoReflect() protoreflect.Message

func (*WorkerHeartBeatRequest) Reset 

func (x *WorkerHeartBeatRequest) Reset()

func (*WorkerHeartBeatRequest) String 

func (x *WorkerHeartBeatRequest) String() string

type WorkerHeartBeatResponse 

type WorkerHeartBeatResponse 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
}

func (*WorkerHeartBeatResponse) Descriptor deprecated 

func (*WorkerHeartBeatResponse) Descriptor() ([]byte, []int)

Deprecated: Use WorkerHeartBeatResponse.ProtoReflect.Descriptor instead.

func (*WorkerHeartBeatResponse) GetMessage 

func (x *WorkerHeartBeatResponse) GetMessage() string

func (*WorkerHeartBeatResponse) GetSuccess 

func (x *WorkerHeartBeatResponse) GetSuccess() bool

func (*WorkerHeartBeatResponse) ProtoMessage 

func (*WorkerHeartBeatResponse) ProtoMessage()

func (*WorkerHeartBeatResponse) ProtoReflect 

func (x *WorkerHeartBeatResponse) ProtoReflect() protoreflect.Message

func (*WorkerHeartBeatResponse) Reset 

func (x *WorkerHeartBeatResponse) Reset()

func (*WorkerHeartBeatResponse) String 

func (x *WorkerHeartBeatResponse) String() string

type WorkerMapTaskRequest 

type WorkerMapTaskRequest 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"`
	TaskName      *string  `protobuf:"bytes,4,req,name=task_name,json=taskName" json:"task_name,omitempty"`
	TaskBody      [][]byte `protobuf:"bytes,5,rep,name=task_body,json=taskBody" json:"task_body,omitempty"`
	// contains filtered or unexported fields
}

MapJobProcessor map tasks to MapTaskMaster

func (*WorkerMapTaskRequest) Descriptor deprecated 

func (*WorkerMapTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use WorkerMapTaskRequest.ProtoReflect.Descriptor instead.

func (*WorkerMapTaskRequest) GetJobId 

func (x *WorkerMapTaskRequest) GetJobId() int64

func (*WorkerMapTaskRequest) GetJobInstanceId 

func (x *WorkerMapTaskRequest) GetJobInstanceId() int64

func (*WorkerMapTaskRequest) GetTaskBody 

func (x *WorkerMapTaskRequest) GetTaskBody() [][]byte

func (*WorkerMapTaskRequest) GetTaskId 

func (x *WorkerMapTaskRequest) GetTaskId() int64

func (*WorkerMapTaskRequest) GetTaskName 

func (x *WorkerMapTaskRequest) GetTaskName() string

func (*WorkerMapTaskRequest) ProtoMessage 

func (*WorkerMapTaskRequest) ProtoMessage()

func (*WorkerMapTaskRequest) ProtoReflect 

func (x *WorkerMapTaskRequest) ProtoReflect() protoreflect.Message

func (*WorkerMapTaskRequest) Reset 

func (x *WorkerMapTaskRequest) Reset()

func (*WorkerMapTaskRequest) String 

func (x *WorkerMapTaskRequest) String() string

type WorkerMapTaskResponse 

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

func (*WorkerMapTaskResponse) Descriptor deprecated 

func (*WorkerMapTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use WorkerMapTaskResponse.ProtoReflect.Descriptor instead.

func (*WorkerMapTaskResponse) GetMessage 

func (x *WorkerMapTaskResponse) GetMessage() string

func (*WorkerMapTaskResponse) GetOverload 

func (x *WorkerMapTaskResponse) GetOverload() bool

func (*WorkerMapTaskResponse) GetSuccess 

func (x *WorkerMapTaskResponse) GetSuccess() bool

func (*WorkerMapTaskResponse) ProtoMessage 

func (*WorkerMapTaskResponse) ProtoMessage()

func (*WorkerMapTaskResponse) ProtoReflect 

func (x *WorkerMapTaskResponse) ProtoReflect() protoreflect.Message

func (*WorkerMapTaskResponse) Reset 

func (x *WorkerMapTaskResponse) Reset()

func (*WorkerMapTaskResponse) String 

func (x *WorkerMapTaskResponse) String() string

type WorkerOfflineRequest 

type WorkerOfflineRequest struct {
	JobInstanceId *int64  `protobuf:"varint,1,req,name=job_instance_id,json=jobInstanceId" json:"job_instance_id,omitempty"`
	WorkerIdAddr  *string `protobuf:"bytes,2,req,name=worker_id_addr,json=workerIdAddr" json:"worker_id_addr,omitempty"`
	Shutdown      *bool   `protobuf:"varint,3,req,name=shutdown" json:"shutdown,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerOfflineRequest) Descriptor deprecated 

func (*WorkerOfflineRequest) Descriptor() ([]byte, []int)

Deprecated: Use WorkerOfflineRequest.ProtoReflect.Descriptor instead.

func (*WorkerOfflineRequest) GetJobInstanceId 

func (x *WorkerOfflineRequest) GetJobInstanceId() int64

func (*WorkerOfflineRequest) GetShutdown 

func (x *WorkerOfflineRequest) GetShutdown() bool

func (*WorkerOfflineRequest) GetWorkerIdAddr 

func (x *WorkerOfflineRequest) GetWorkerIdAddr() string

func (*WorkerOfflineRequest) ProtoMessage 

func (*WorkerOfflineRequest) ProtoMessage()

func (*WorkerOfflineRequest) ProtoReflect 

func (x *WorkerOfflineRequest) ProtoReflect() protoreflect.Message

func (*WorkerOfflineRequest) Reset 

func (x *WorkerOfflineRequest) Reset()

func (*WorkerOfflineRequest) String 

func (x *WorkerOfflineRequest) String() string

type WorkerOfflineResponse 

type WorkerOfflineResponse 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
}

func (*WorkerOfflineResponse) Descriptor deprecated 

func (*WorkerOfflineResponse) Descriptor() ([]byte, []int)

Deprecated: Use WorkerOfflineResponse.ProtoReflect.Descriptor instead.

func (*WorkerOfflineResponse) GetMessage 

func (x *WorkerOfflineResponse) GetMessage() string

func (*WorkerOfflineResponse) GetSuccess 

func (x *WorkerOfflineResponse) GetSuccess() bool

func (*WorkerOfflineResponse) ProtoMessage 

func (*WorkerOfflineResponse) ProtoMessage()

func (*WorkerOfflineResponse) ProtoReflect 

func (x *WorkerOfflineResponse) ProtoReflect() protoreflect.Message

func (*WorkerOfflineResponse) Reset 

func (x *WorkerOfflineResponse) Reset()

func (*WorkerOfflineResponse) String 

func (x *WorkerOfflineResponse) String() string

type WorkerPullTasksRequest 

type WorkerPullTasksRequest 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"`
	// contains filtered or unexported fields
}

func (*WorkerPullTasksRequest) Descriptor deprecated 

func (*WorkerPullTasksRequest) Descriptor() ([]byte, []int)

Deprecated: Use WorkerPullTasksRequest.ProtoReflect.Descriptor instead.

func (*WorkerPullTasksRequest) GetJobInstanceId 

func (x *WorkerPullTasksRequest) GetJobInstanceId() int64

func (*WorkerPullTasksRequest) GetPageSize 

func (x *WorkerPullTasksRequest) GetPageSize() int32

func (*WorkerPullTasksRequest) ProtoMessage 

func (*WorkerPullTasksRequest) ProtoMessage()

func (*WorkerPullTasksRequest) ProtoReflect 

func (x *WorkerPullTasksRequest) ProtoReflect() protoreflect.Message

func (*WorkerPullTasksRequest) Reset 

func (x *WorkerPullTasksRequest) Reset()

func (*WorkerPullTasksRequest) String 

func (x *WorkerPullTasksRequest) String() string

type WorkerPullTasksResponse 

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

func (*WorkerPullTasksResponse) Descriptor deprecated 

func (*WorkerPullTasksResponse) Descriptor() ([]byte, []int)

Deprecated: Use WorkerPullTasksResponse.ProtoReflect.Descriptor instead.

func (*WorkerPullTasksResponse) GetMessage 

func (x *WorkerPullTasksResponse) GetMessage() string

func (*WorkerPullTasksResponse) GetSuccess 

func (x *WorkerPullTasksResponse) GetSuccess() bool

func (*WorkerPullTasksResponse) GetTaskMessage 

func (x *WorkerPullTasksResponse) GetTaskMessage() []*TaskMessage

func (*WorkerPullTasksResponse) ProtoMessage 

func (*WorkerPullTasksResponse) ProtoMessage()

func (*WorkerPullTasksResponse) ProtoReflect 

func (x *WorkerPullTasksResponse) ProtoReflect() protoreflect.Message

func (*WorkerPullTasksResponse) Reset 

func (x *WorkerPullTasksResponse) Reset()

func (*WorkerPullTasksResponse) String 

func (x *WorkerPullTasksResponse) String() string

type WorkerQueryJobInstanceStatusRequest 

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

Worker query jobInstance status

func (*WorkerQueryJobInstanceStatusRequest) Descriptor deprecated 

func (*WorkerQueryJobInstanceStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use WorkerQueryJobInstanceStatusRequest.ProtoReflect.Descriptor instead.

func (*WorkerQueryJobInstanceStatusRequest) GetJobInstanceId 

func (x *WorkerQueryJobInstanceStatusRequest) GetJobInstanceId() int64

func (*WorkerQueryJobInstanceStatusRequest) ProtoMessage 

func (*WorkerQueryJobInstanceStatusRequest) ProtoMessage()

func (*WorkerQueryJobInstanceStatusRequest) ProtoReflect 

func (x *WorkerQueryJobInstanceStatusRequest) ProtoReflect() protoreflect.Message

func (*WorkerQueryJobInstanceStatusRequest) Reset 

func (x *WorkerQueryJobInstanceStatusRequest) Reset()

func (*WorkerQueryJobInstanceStatusRequest) String 

func (x *WorkerQueryJobInstanceStatusRequest) String() string

type WorkerQueryJobInstanceStatusResponse 

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

func (*WorkerQueryJobInstanceStatusResponse) Descriptor deprecated 

func (*WorkerQueryJobInstanceStatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use WorkerQueryJobInstanceStatusResponse.ProtoReflect.Descriptor instead.

func (*WorkerQueryJobInstanceStatusResponse) GetMessage 

func (x *WorkerQueryJobInstanceStatusResponse) GetMessage() string

func (*WorkerQueryJobInstanceStatusResponse) GetStatus 

func (x *WorkerQueryJobInstanceStatusResponse) GetStatus() int32

func (*WorkerQueryJobInstanceStatusResponse) GetSuccess 

func (x *WorkerQueryJobInstanceStatusResponse) GetSuccess() bool

func (*WorkerQueryJobInstanceStatusResponse) ProtoMessage 

func (*WorkerQueryJobInstanceStatusResponse) ProtoMessage()

func (*WorkerQueryJobInstanceStatusResponse) ProtoReflect 

func (x *WorkerQueryJobInstanceStatusResponse) ProtoReflect() protoreflect.Message

func (*WorkerQueryJobInstanceStatusResponse) Reset 

func (x *WorkerQueryJobInstanceStatusResponse) Reset()

func (*WorkerQueryJobInstanceStatusResponse) String 

func (x *WorkerQueryJobInstanceStatusResponse) String() string

type WorkerReportJobInstanceProgressRequest 

type WorkerReportJobInstanceProgressRequest 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"`
	Progress      *string `protobuf:"bytes,3,req,name=progress" json:"progress,omitempty"`
	TriggerTimes  *int32  `protobuf:"varint,4,opt,name=trigger_times,json=triggerTimes" json:"trigger_times,omitempty"`
	// contains filtered or unexported fields
}

TaskMaster report progress to Server

func (*WorkerReportJobInstanceProgressRequest) Descriptor deprecated 

func (*WorkerReportJobInstanceProgressRequest) Descriptor() ([]byte, []int)

Deprecated: Use WorkerReportJobInstanceProgressRequest.ProtoReflect.Descriptor instead.

func (*WorkerReportJobInstanceProgressRequest) GetJobId 

func (x *WorkerReportJobInstanceProgressRequest) GetJobId() int64

func (*WorkerReportJobInstanceProgressRequest) GetJobInstanceId 

func (x *WorkerReportJobInstanceProgressRequest) GetJobInstanceId() int64

func (*WorkerReportJobInstanceProgressRequest) GetProgress 

func (x *WorkerReportJobInstanceProgressRequest) GetProgress() string

func (*WorkerReportJobInstanceProgressRequest) GetTriggerTimes 

func (x *WorkerReportJobInstanceProgressRequest) GetTriggerTimes() int32

func (*WorkerReportJobInstanceProgressRequest) ProtoMessage 

func (*WorkerReportJobInstanceProgressRequest) ProtoMessage()

func (*WorkerReportJobInstanceProgressRequest) ProtoReflect 

func (x *WorkerReportJobInstanceProgressRequest) ProtoReflect() protoreflect.Message

func (*WorkerReportJobInstanceProgressRequest) Reset 

func (x *WorkerReportJobInstanceProgressRequest) Reset()

func (*WorkerReportJobInstanceProgressRequest) String 

func (x *WorkerReportJobInstanceProgressRequest) String() string

type WorkerReportJobInstanceProgressResponse 

type WorkerReportJobInstanceProgressResponse 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
}

func (*WorkerReportJobInstanceProgressResponse) Descriptor deprecated 

func (*WorkerReportJobInstanceProgressResponse) Descriptor() ([]byte, []int)

Deprecated: Use WorkerReportJobInstanceProgressResponse.ProtoReflect.Descriptor instead.

func (*WorkerReportJobInstanceProgressResponse) GetMessage 

func (x *WorkerReportJobInstanceProgressResponse) GetMessage() string

func (*WorkerReportJobInstanceProgressResponse) GetSuccess 

func (x *WorkerReportJobInstanceProgressResponse) GetSuccess() bool

func (*WorkerReportJobInstanceProgressResponse) ProtoMessage 

func (*WorkerReportJobInstanceProgressResponse) ProtoMessage()

func (*WorkerReportJobInstanceProgressResponse) ProtoReflect 

func (x *WorkerReportJobInstanceProgressResponse) ProtoReflect() protoreflect.Message

func (*WorkerReportJobInstanceProgressResponse) Reset 

func (x *WorkerReportJobInstanceProgressResponse) Reset()

func (*WorkerReportJobInstanceProgressResponse) String 

func (x *WorkerReportJobInstanceProgressResponse) String() string

type WorkerReportJobInstanceStatusRequest 

type WorkerReportJobInstanceStatusRequest 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"`
	Status                *int32  `protobuf:"varint,3,req,name=status" json:"status,omitempty"`
	Result                *string `protobuf:"bytes,4,opt,name=result" json:"result,omitempty"`
	Progress              *string `protobuf:"bytes,5,opt,name=progress" json:"progress,omitempty"`
	DeliveryId            *int64  `protobuf:"varint,6,opt,name=delivery_id,json=deliveryId" json:"delivery_id,omitempty"`
	AlreadyUnConfirmRetry *bool   `protobuf:"varint,7,opt,name=already_unConfirm_retry,json=alreadyUnConfirmRetry" json:"already_unConfirm_retry,omitempty"`
	GroupId               *string `protobuf:"bytes,8,opt,name=group_id,json=groupId" json:"group_id,omitempty"`
	TraceId               *string `protobuf:"bytes,9,opt,name=traceId" json:"traceId,omitempty"`
	// contains filtered or unexported fields
}

TaskMaster report job instance status to Server

func (*WorkerReportJobInstanceStatusRequest) Descriptor deprecated 

func (*WorkerReportJobInstanceStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use WorkerReportJobInstanceStatusRequest.ProtoReflect.Descriptor instead.

func (*WorkerReportJobInstanceStatusRequest) GetAlreadyUnConfirmRetry 

func (x *WorkerReportJobInstanceStatusRequest) GetAlreadyUnConfirmRetry() bool

func (*WorkerReportJobInstanceStatusRequest) GetDeliveryId 

func (x *WorkerReportJobInstanceStatusRequest) GetDeliveryId() int64

func (*WorkerReportJobInstanceStatusRequest) GetGroupId 

func (x *WorkerReportJobInstanceStatusRequest) GetGroupId() string

func (*WorkerReportJobInstanceStatusRequest) GetJobId 

func (x *WorkerReportJobInstanceStatusRequest) GetJobId() int64

func (*WorkerReportJobInstanceStatusRequest) GetJobInstanceId 

func (x *WorkerReportJobInstanceStatusRequest) GetJobInstanceId() int64

func (*WorkerReportJobInstanceStatusRequest) GetProgress 

func (x *WorkerReportJobInstanceStatusRequest) GetProgress() string

func (*WorkerReportJobInstanceStatusRequest) GetResult 

func (x *WorkerReportJobInstanceStatusRequest) GetResult() string

func (*WorkerReportJobInstanceStatusRequest) GetStatus 

func (x *WorkerReportJobInstanceStatusRequest) GetStatus() int32

func (*WorkerReportJobInstanceStatusRequest) GetTraceId 

func (x *WorkerReportJobInstanceStatusRequest) GetTraceId() string

func (*WorkerReportJobInstanceStatusRequest) ProtoMessage 

func (*WorkerReportJobInstanceStatusRequest) ProtoMessage()

func (*WorkerReportJobInstanceStatusRequest) ProtoReflect 

func (x *WorkerReportJobInstanceStatusRequest) ProtoReflect() protoreflect.Message

func (*WorkerReportJobInstanceStatusRequest) Reset 

func (x *WorkerReportJobInstanceStatusRequest) Reset()

func (*WorkerReportJobInstanceStatusRequest) String 

func (x *WorkerReportJobInstanceStatusRequest) String() string

type WorkerReportJobInstanceStatusResponse 

type WorkerReportJobInstanceStatusResponse 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,req,name=delivery_id,json=deliveryId" json:"delivery_id,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerReportJobInstanceStatusResponse) Descriptor deprecated 

func (*WorkerReportJobInstanceStatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use WorkerReportJobInstanceStatusResponse.ProtoReflect.Descriptor instead.

func (*WorkerReportJobInstanceStatusResponse) GetDeliveryId 

func (x *WorkerReportJobInstanceStatusResponse) GetDeliveryId() int64

func (*WorkerReportJobInstanceStatusResponse) GetMessage 

func (x *WorkerReportJobInstanceStatusResponse) GetMessage() string

func (*WorkerReportJobInstanceStatusResponse) GetSuccess 

func (x *WorkerReportJobInstanceStatusResponse) GetSuccess() bool

func (*WorkerReportJobInstanceStatusResponse) ProtoMessage 

func (*WorkerReportJobInstanceStatusResponse) ProtoMessage()

func (*WorkerReportJobInstanceStatusResponse) ProtoReflect 

func (x *WorkerReportJobInstanceStatusResponse) ProtoReflect() protoreflect.Message

func (*WorkerReportJobInstanceStatusResponse) Reset 

func (x *WorkerReportJobInstanceStatusResponse) Reset()

func (*WorkerReportJobInstanceStatusResponse) String 

func (x *WorkerReportJobInstanceStatusResponse) String() string

type WorkerReportTaskListStatusRequest 

type WorkerReportTaskListStatusRequest struct {
	JobInstanceId *int64  `protobuf:"varint,1,req,name=job_instance_id,json=jobInstanceId" json:"job_instance_id,omitempty"`
	TaskId        []int64 `protobuf:"varint,2,rep,name=task_id,json=taskId" json:"task_id,omitempty"`
	Status        *int32  `protobuf:"varint,3,req,name=status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

Worker report task status to Server

func (*WorkerReportTaskListStatusRequest) Descriptor deprecated 

func (*WorkerReportTaskListStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use WorkerReportTaskListStatusRequest.ProtoReflect.Descriptor instead.

func (*WorkerReportTaskListStatusRequest) GetJobInstanceId 

func (x *WorkerReportTaskListStatusRequest) GetJobInstanceId() int64

func (*WorkerReportTaskListStatusRequest) GetStatus 

func (x *WorkerReportTaskListStatusRequest) GetStatus() int32

func (*WorkerReportTaskListStatusRequest) GetTaskId 

func (x *WorkerReportTaskListStatusRequest) GetTaskId() []int64

func (*WorkerReportTaskListStatusRequest) ProtoMessage 

func (*WorkerReportTaskListStatusRequest) ProtoMessage()

func (*WorkerReportTaskListStatusRequest) ProtoReflect 

func (x *WorkerReportTaskListStatusRequest) ProtoReflect() protoreflect.Message

func (*WorkerReportTaskListStatusRequest) Reset 

func (x *WorkerReportTaskListStatusRequest) Reset()

func (*WorkerReportTaskListStatusRequest) String 

func (x *WorkerReportTaskListStatusRequest) String() string

type WorkerReportTaskListStatusResponse 

type WorkerReportTaskListStatusResponse 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
}

func (*WorkerReportTaskListStatusResponse) Descriptor deprecated 

func (*WorkerReportTaskListStatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use WorkerReportTaskListStatusResponse.ProtoReflect.Descriptor instead.

func (*WorkerReportTaskListStatusResponse) GetMessage 

func (x *WorkerReportTaskListStatusResponse) GetMessage() string

func (*WorkerReportTaskListStatusResponse) GetSuccess 

func (x *WorkerReportTaskListStatusResponse) GetSuccess() bool

func (*WorkerReportTaskListStatusResponse) ProtoMessage 

func (*WorkerReportTaskListStatusResponse) ProtoMessage()

func (*WorkerReportTaskListStatusResponse) ProtoReflect 

func (x *WorkerReportTaskListStatusResponse) ProtoReflect() protoreflect.Message

func (*WorkerReportTaskListStatusResponse) Reset 

func (x *WorkerReportTaskListStatusResponse) Reset()

func (*WorkerReportTaskListStatusResponse) String 

func (x *WorkerReportTaskListStatusResponse) String() string

type WorkerReportTaskProgressRequest 

type WorkerReportTaskProgressRequest struct {
	UniqueId *string  `protobuf:"bytes,1,req,name=unique_id,json=uniqueId" json:"unique_id,omitempty"`
	Progress *float32 `protobuf:"fixed32,2,req,name=progress" json:"progress,omitempty"`
	// contains filtered or unexported fields
}

Worker report task progress to Server

func (*WorkerReportTaskProgressRequest) Descriptor deprecated 

func (*WorkerReportTaskProgressRequest) Descriptor() ([]byte, []int)

Deprecated: Use WorkerReportTaskProgressRequest.ProtoReflect.Descriptor instead.

func (*WorkerReportTaskProgressRequest) GetProgress 

func (x *WorkerReportTaskProgressRequest) GetProgress() float32

func (*WorkerReportTaskProgressRequest) GetUniqueId 

func (x *WorkerReportTaskProgressRequest) GetUniqueId() string

func (*WorkerReportTaskProgressRequest) ProtoMessage 

func (*WorkerReportTaskProgressRequest) ProtoMessage()

func (*WorkerReportTaskProgressRequest) ProtoReflect 

func (x *WorkerReportTaskProgressRequest) ProtoReflect() protoreflect.Message

func (*WorkerReportTaskProgressRequest) Reset 

func (x *WorkerReportTaskProgressRequest) Reset()

func (*WorkerReportTaskProgressRequest) String 

func (x *WorkerReportTaskProgressRequest) String() string

type WorkerReportTaskProgressResponse 

type WorkerReportTaskProgressResponse 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
}

func (*WorkerReportTaskProgressResponse) Descriptor deprecated 

func (*WorkerReportTaskProgressResponse) Descriptor() ([]byte, []int)

Deprecated: Use WorkerReportTaskProgressResponse.ProtoReflect.Descriptor instead.

func (*WorkerReportTaskProgressResponse) GetMessage 

func (x *WorkerReportTaskProgressResponse) GetMessage() string

func (*WorkerReportTaskProgressResponse) GetSuccess 

func (x *WorkerReportTaskProgressResponse) GetSuccess() bool

func (*WorkerReportTaskProgressResponse) ProtoMessage 

func (*WorkerReportTaskProgressResponse) ProtoMessage()

func (*WorkerReportTaskProgressResponse) ProtoReflect 

func (x *WorkerReportTaskProgressResponse) ProtoReflect() protoreflect.Message

func (*WorkerReportTaskProgressResponse) Reset 

func (x *WorkerReportTaskProgressResponse) Reset()

func (*WorkerReportTaskProgressResponse) String 

func (x *WorkerReportTaskProgressResponse) String() string

type WorkerReportTaskStatusRequest 

type WorkerReportTaskStatusRequest struct {
	UniqueId      *string `protobuf:"bytes,1,req,name=unique_id,json=uniqueId" json:"unique_id,omitempty"`
	Status        *int32  `protobuf:"varint,2,req,name=status" json:"status,omitempty"`
	WorkerAddress *string `protobuf:"bytes,3,opt,name=worker_address,json=workerAddress" json:"worker_address,omitempty"`
	WorkerId      *string `protobuf:"bytes,4,opt,name=worker_id,json=workerId" json:"worker_id,omitempty"`
	DeliveryId    *int64  `protobuf:"varint,5,opt,name=delivery_id,json=deliveryId" json:"delivery_id,omitempty"`
	JobInstanceId *int64  `protobuf:"varint,6,req,name=job_instance_id,json=jobInstanceId" json:"job_instance_id,omitempty"`
	// contains filtered or unexported fields
}

Worker report task status to Server

func (*WorkerReportTaskStatusRequest) Descriptor deprecated 

func (*WorkerReportTaskStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use WorkerReportTaskStatusRequest.ProtoReflect.Descriptor instead.

func (*WorkerReportTaskStatusRequest) GetDeliveryId 

func (x *WorkerReportTaskStatusRequest) GetDeliveryId() int64

func (*WorkerReportTaskStatusRequest) GetJobInstanceId 

func (x *WorkerReportTaskStatusRequest) GetJobInstanceId() int64

func (*WorkerReportTaskStatusRequest) GetStatus 

func (x *WorkerReportTaskStatusRequest) GetStatus() int32

func (*WorkerReportTaskStatusRequest) GetUniqueId 

func (x *WorkerReportTaskStatusRequest) GetUniqueId() string

func (*WorkerReportTaskStatusRequest) GetWorkerAddress 

func (x *WorkerReportTaskStatusRequest) GetWorkerAddress() string

func (*WorkerReportTaskStatusRequest) GetWorkerId 

func (x *WorkerReportTaskStatusRequest) GetWorkerId() string

func (*WorkerReportTaskStatusRequest) ProtoMessage 

func (*WorkerReportTaskStatusRequest) ProtoMessage()

func (*WorkerReportTaskStatusRequest) ProtoReflect 

func (x *WorkerReportTaskStatusRequest) ProtoReflect() protoreflect.Message

func (*WorkerReportTaskStatusRequest) Reset 

func (x *WorkerReportTaskStatusRequest) Reset()

func (*WorkerReportTaskStatusRequest) String 

func (x *WorkerReportTaskStatusRequest) String() string

type WorkerReportTaskStatusResponse 

type WorkerReportTaskStatusResponse 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
}

func (*WorkerReportTaskStatusResponse) Descriptor deprecated 

func (*WorkerReportTaskStatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use WorkerReportTaskStatusResponse.ProtoReflect.Descriptor instead.

func (*WorkerReportTaskStatusResponse) GetDeliveryId 

func (x *WorkerReportTaskStatusResponse) GetDeliveryId() int64

func (*WorkerReportTaskStatusResponse) GetMessage 

func (x *WorkerReportTaskStatusResponse) GetMessage() string

func (*WorkerReportTaskStatusResponse) GetSuccess 

func (x *WorkerReportTaskStatusResponse) GetSuccess() bool

func (*WorkerReportTaskStatusResponse) ProtoMessage 

func (*WorkerReportTaskStatusResponse) ProtoMessage()

func (*WorkerReportTaskStatusResponse) ProtoReflect 

func (x *WorkerReportTaskStatusResponse) ProtoReflect() protoreflect.Message

func (*WorkerReportTaskStatusResponse) Reset 

func (x *WorkerReportTaskStatusResponse) Reset()

func (*WorkerReportTaskStatusResponse) String 

func (x *WorkerReportTaskStatusResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.