executorv1

type ExecuteRequest struct {
	Eid             int64  `protobuf:"varint,1,opt,name=eid,proto3" json:"eid,omitempty"` // execution id
	TaskId          int64  `protobuf:"varint,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	TaskName        string `protobuf:"bytes,3,opt,name=task_name,json=taskName,proto3" json:"task_name,omitempty"`
	TaskHandlerName string `protobuf:"bytes,4,opt,name=task_handler_name,json=taskHandlerName,proto3" json:"task_handler_name,omitempty"`
	// 这里有两部分
	// 1 一部分是通过管理后台，业务方自己搞的参数
	// 2. 另外一部分是我们调度用的，比如说 offset, limit
	// 即包含了业务参数和调度参数 (e.g., offset, limit)
	Params map[string]string `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

type ExecuteResponse struct {
	ExecutionState *ExecutionState `protobuf:"bytes,1,opt,name=execution_state,json=executionState,proto3" json:"execution_state,omitempty"`
	// contains filtered or unexported fields
}

type ExecutionState struct {
	Id       int64  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	TaskId   int64  `protobuf:"varint,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	TaskName string `protobuf:"bytes,3,opt,name=task_name,json=taskName,proto3" json:"task_name,omitempty"`
	// 中断时刻执行节点的执行进度
	Status ExecutionStatus `protobuf:"varint,4,opt,name=status,proto3,enum=executor.v1.ExecutionStatus" json:"status,omitempty"` // RUNNING，FAILED_RETRYABLE，FAILED，SUCCESS
	// 0-100 的数字。代表进度
	// RUNNING 状态才有意义
	RunningProgress int32 `protobuf:"varint,5,opt,name=running_progress,json=runningProgress,proto3" json:"running_progress,omitempty"`
	// 执行节点请求调度节点执行重调度，
	// 调度节点无需调interrupt，调度节点可以直接重调度，因为此时执行节点必然已经停止了
	RequestReschedule bool `protobuf:"varint,6,opt,name=request_reschedule,json=requestReschedule,proto3" json:"request_reschedule,omitempty"`
	// 重调度（执行节点主动提出）或者中断后的恢复参数（调度节点主动要求）
	// 用于重调度或中断恢复重新调度的参数
	// 比如：调用 A 节点上，中断任务
	// A 节点返回 offset = 10000, limit = 100
	// 你后续重调度到 B 节点上，
	// 传递给 B 节点的 ExecuteRequest 的 params 里面就包含 offset, limit
	RescheduledParams map[string]string `` /* 186-byte string literal not displayed */
	// 执行节点的 nodeID，用于记录是哪个节点处理了任务
	ExecutorNodeId string `protobuf:"bytes,8,opt,name=executor_node_id,json=executorNodeId,proto3" json:"executor_node_id,omitempty"`
	// contains filtered or unexported fields
}

type ExecutionStatus int32

type ExecutorServiceClient interface {
	// 执行一个任务
	Execute(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (*ExecuteResponse, error)
	// 中断一个正在执行的任务
	Interrupt(ctx context.Context, in *InterruptRequest, opts ...grpc.CallOption) (*InterruptResponse, error)
	// 查询一个任务的状态（用于轮询模式）
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)
	// 查询业务方任务总数量
	Prepare(ctx context.Context, in *PrepareRequest, opts ...grpc.CallOption) (*PrepareResponse, error)
}

type ExecutorServiceServer interface {
	// 执行一个任务
	Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error)
	// 中断一个正在执行的任务
	Interrupt(context.Context, *InterruptRequest) (*InterruptResponse, error)
	// 查询一个任务的状态（用于轮询模式）
	Query(context.Context, *QueryRequest) (*QueryResponse, error)
	// 查询业务方任务总数量
	Prepare(context.Context, *PrepareRequest) (*PrepareResponse, error)
	// contains filtered or unexported methods
}

type InterruptRequest struct {
	Eid int64 `protobuf:"varint,1,opt,name=eid,proto3" json:"eid,omitempty"`
	// contains filtered or unexported fields
}

type InterruptResponse struct {
	Success        bool            `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` // 是否成功中断
	ExecutionState *ExecutionState `protobuf:"bytes,3,opt,name=execution_state,json=executionState,proto3" json:"execution_state,omitempty"`
	// contains filtered or unexported fields
}

type PrepareRequest struct {
	Eid      int64  `protobuf:"varint,1,opt,name=eid,proto3" json:"eid,omitempty"` // execution id
	TaskId   int64  `protobuf:"varint,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	TaskName string `protobuf:"bytes,3,opt,name=task_name,json=taskName,proto3" json:"task_name,omitempty"`
	// 这里有两部分
	// 1 一部分是通过管理后台，业务方自己搞的参数
	// 2. 另外一部分是我们调度用的，比如说 offset, limit
	// 即包含了业务参数和调度参数 (e.g., offset, limit)
	Params map[string]string `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

type PrepareResponse struct {
	Params map[string]string `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

type QueryRequest struct {
	Eid int64 `protobuf:"varint,1,opt,name=eid,proto3" json:"eid,omitempty"`
	// contains filtered or unexported fields
}

type QueryResponse struct {
	ExecutionState *ExecutionState `protobuf:"bytes,1,opt,name=execution_state,json=executionState,proto3" json:"execution_state,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedExecutorServiceServer struct{}

type UnsafeExecutorServiceServer interface {
	// contains filtered or unexported methods
}