executorv1

type AgentServiceClient interface {
	PullTask(ctx context.Context, in *PullTaskRequest, opts ...grpc.CallOption) (*PullTaskResponse, error)
}

type AgentServiceServer interface {
	PullTask(context.Context, *PullTaskRequest) (*PullTaskResponse, error)
	// contains filtered or unexported methods
}

type BatchListTaskExecutionsRequest struct {
	TaskIds []int64 `protobuf:"varint,1,rep,packed,name=task_ids,json=taskIds,proto3" json:"task_ids,omitempty"`
	// contains filtered or unexported fields
}

type BatchListTaskExecutionsResponse struct {
	Results map[int64]*TaskExecutionList `` // key is task_id
	/* 142-byte string literal not displayed */
	// contains filtered or unexported fields
}

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 ExecutionLog struct {
	Id      int64  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Time    int64  `protobuf:"varint,2,opt,name=time,proto3" json:"time,omitempty"`
	Content string `protobuf:"bytes,3,opt,name=content,proto3" json:"content,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=etask.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"`
	// 任务执行的结构化结果（JSON 格式字符串）
	// 通过 FD3 或 want_result 函数返回的结构化数据
	TaskResult string `protobuf:"bytes,9,opt,name=task_result,json=taskResult,proto3" json:"task_result,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 GetExecutionLogsRequest struct {
	ExecutionId int64 `protobuf:"varint,1,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	MinId       int64 `protobuf:"varint,2,opt,name=min_id,json=minId,proto3" json:"min_id,omitempty"`
	Limit       int32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

type GetExecutionLogsResponse struct {
	Logs  []*ExecutionLog `protobuf:"bytes,1,rep,name=logs,proto3" json:"logs,omitempty"`
	MaxId int64           `protobuf:"varint,2,opt,name=max_id,json=maxId,proto3" json:"max_id,omitempty"`
	// contains filtered or unexported fields
}

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 ListTaskExecutionsRequest struct {
	TaskId int64 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// contains filtered or unexported fields
}

type ListTaskExecutionsResponse struct {
	Executions []*TaskExecution `protobuf:"bytes,1,rep,name=executions,proto3" json:"executions,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 PullTaskRequest struct {
	ServiceName string   `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"` // 这个机器所属的分组 ServiceName (比如：ework-executor-node1)
	Handlers    []string `protobuf:"bytes,2,rep,name=handlers,proto3" json:"handlers,omitempty"`                          // 这台机器目前可支持的所有 Handler 名字 (如 shell, demo)
	NodeId      string   `protobuf:"bytes,3,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`                // 具体这台机器的唯一实例 ID
	// contains filtered or unexported fields
}

type PullTaskResponse struct {
	HasTask bool `protobuf:"varint,1,opt,name=has_task,json=hasTask,proto3" json:"has_task,omitempty"` // 是否取到活儿了
	// 如果取到了，直接复用刚才的 ExecuteRequest 下发给它！
	TaskReq *ExecuteRequest `protobuf:"bytes,2,opt,name=task_req,json=taskReq,proto3" json:"task_req,omitempty"`
	// 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 TaskExecution 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"`
	StartTime       int64           `protobuf:"varint,4,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime         int64           `protobuf:"varint,5,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Status          ExecutionStatus `protobuf:"varint,6,opt,name=status,proto3,enum=etask.executor.v1.ExecutionStatus" json:"status,omitempty"`
	RunningProgress int32           `protobuf:"varint,7,opt,name=running_progress,json=runningProgress,proto3" json:"running_progress,omitempty"`
	ExecutorNodeId  string          `protobuf:"bytes,8,opt,name=executor_node_id,json=executorNodeId,proto3" json:"executor_node_id,omitempty"`
	TaskResult      string          `protobuf:"bytes,9,opt,name=task_result,json=taskResult,proto3" json:"task_result,omitempty"`
	// contains filtered or unexported fields
}

type TaskExecutionList struct {
	Executions []*TaskExecution `protobuf:"bytes,1,rep,name=executions,proto3" json:"executions,omitempty"`
	// contains filtered or unexported fields
}

type TaskExecutionServiceClient interface {
	// 列出任务执行记录
	ListTaskExecutions(ctx context.Context, in *ListTaskExecutionsRequest, opts ...grpc.CallOption) (*ListTaskExecutionsResponse, error)
	// 获取执行日志
	GetExecutionLogs(ctx context.Context, in *GetExecutionLogsRequest, opts ...grpc.CallOption) (*GetExecutionLogsResponse, error)
	// 批量列出任务执行记录
	BatchListTaskExecutions(ctx context.Context, in *BatchListTaskExecutionsRequest, opts ...grpc.CallOption) (*BatchListTaskExecutionsResponse, error)
}

type TaskExecutionServiceServer interface {
	// 列出任务执行记录
	ListTaskExecutions(context.Context, *ListTaskExecutionsRequest) (*ListTaskExecutionsResponse, error)
	// 获取执行日志
	GetExecutionLogs(context.Context, *GetExecutionLogsRequest) (*GetExecutionLogsResponse, error)
	// 批量列出任务执行记录
	BatchListTaskExecutions(context.Context, *BatchListTaskExecutionsRequest) (*BatchListTaskExecutionsResponse, error)
	// contains filtered or unexported methods
}

type UnimplementedAgentServiceServer struct{}

type UnimplementedExecutorServiceServer struct{}

type UnimplementedTaskExecutionServiceServer struct{}

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

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

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