package tech.powerjob.server.core.handler;
|
|
import tech.powerjob.common.request.*;
|
import tech.powerjob.common.response.AskResponse;
|
|
/**
|
* 定义 server 与 worker 之间需要处理的协议
|
*
|
* @author tjq
|
* @since 2022/9/10
|
*/
|
public interface IWorkerRequestHandler {
|
|
/**
|
* 处理 worker 上报的心跳信息
|
* @param heartbeat 心跳信息
|
*/
|
void processWorkerHeartbeat(WorkerHeartbeat heartbeat);
|
|
/**
|
* 处理 TaskTracker 的任务实例上报
|
* @param req 上报请求
|
* @return 响应信息
|
*/
|
AskResponse processTaskTrackerReportInstanceStatus(TaskTrackerReportInstanceStatusReq req);
|
|
/**
|
* 处理 worker 查询执行器集群
|
* @param req 请求
|
* @return cluster info
|
*/
|
AskResponse processWorkerQueryExecutorCluster(WorkerQueryExecutorClusterReq req);
|
|
/**
|
* 处理 worker 日志推送请求（内部使用线程池异步处理，非阻塞）
|
* @param req 请求
|
*/
|
void processWorkerLogReport(WorkerLogReportReq req);
|
|
/**
|
* 处理 worker 的容器部署请求
|
* @param request 请求
|
* @return 容器部署信息
|
*/
|
AskResponse processWorkerNeedDeployContainer(WorkerNeedDeployContainerRequest request);
|
}
|
