mirror of
https://github.com/PowerJob/PowerJob.git
synced 2025-07-17 00:00:04 +08:00
105 lines
3.2 KiB
Java
105 lines
3.2 KiB
Java
package tech.powerjob.common;
|
||
|
||
/**
|
||
* RemoteConstant
|
||
*
|
||
* @author tjq
|
||
* @since 2020/3/17
|
||
*/
|
||
public class RemoteConstant {
|
||
|
||
|
||
/* ************************ AKKA WORKER ************************ */
|
||
public static final int DEFAULT_WORKER_PORT = 27777;
|
||
|
||
|
||
/* ************************ OTHERS ************************ */
|
||
public static final String EMPTY_ADDRESS = "N/A";
|
||
public static final long DEFAULT_TIMEOUT_MS = 5000;
|
||
|
||
/* ************************ SERVER-self_side (s4s == server for server side) ************************ */
|
||
public static final String S4S_PATH = "friend";
|
||
|
||
/**
|
||
* server 集群间的心跳处理
|
||
*/
|
||
public static final String S4S_HANDLER_PING = "ping";
|
||
/**
|
||
* 处理其他 server 的执行请求
|
||
*/
|
||
public static final String S4S_HANDLER_PROCESS = "process";
|
||
|
||
/* ************************ SERVER-worker_side（s4w == server for worker side） ************************ */
|
||
public static final String S4W_PATH = "server";
|
||
/**
|
||
* server 处理在线日志
|
||
*/
|
||
public static final String S4W_HANDLER_REPORT_LOG = "reportLog";
|
||
/**
|
||
* server 处理 worker 心跳
|
||
*/
|
||
public static final String S4W_HANDLER_WORKER_HEARTBEAT = "workerHeartbeat";
|
||
|
||
/**
|
||
* server 处理 TaskTracker 上报的任务实例状态
|
||
*/
|
||
public static final String S4W_HANDLER_REPORT_INSTANCE_STATUS = "reportInstanceStatus";
|
||
|
||
/**
|
||
* server 查询任务的可执行集群
|
||
*/
|
||
public static final String S4W_HANDLER_QUERY_JOB_CLUSTER = "queryJobCluster";
|
||
|
||
/**
|
||
* server 处理 worker 请求部署容器命令
|
||
*/
|
||
public static final String S4W_HANDLER_WORKER_NEED_DEPLOY_CONTAINER = "queryContainer";
|
||
|
||
/* ************************ Worker-TaskTracker ************************ */
|
||
public static final String WTT_PATH = "taskTracker";
|
||
|
||
/**
|
||
* server 任务执行命令
|
||
*/
|
||
public static final String WTT_HANDLER_RUN_JOB = "runJob";
|
||
/**
|
||
* server 停止任务实例命令
|
||
*/
|
||
public static final String WTT_HANDLER_STOP_INSTANCE = "stopInstance";
|
||
|
||
/**
|
||
* sever 查询任务状态
|
||
*/
|
||
public static final String WTT_HANDLER_QUERY_INSTANCE_STATUS = "queryInstanceStatus";
|
||
|
||
/**
|
||
* PT 上报任务状态，包含执行结果
|
||
*/
|
||
public static final String WTT_HANDLER_REPORT_TASK_STATUS = "reportTaskStatus";
|
||
/**
|
||
* PT 上报自身状态
|
||
*/
|
||
public static final String WTT_HANDLER_REPORT_PROCESSOR_TRACKER_STATUS = "reportProcessorTrackerStatus";
|
||
|
||
/**
|
||
* Map 任务
|
||
*/
|
||
public static final String WTT_HANDLER_MAP_TASK = "mapTask";
|
||
|
||
/* ************************ Worker-ProcessorTracker ************************ */
|
||
public static final String WPT_PATH = "processorTracker";
|
||
|
||
public static final String WPT_HANDLER_START_TASK = "startTask";
|
||
|
||
public static final String WPT_HANDLER_STOP_INSTANCE = "stopInstance";
|
||
|
||
/* ************************ Worker-NORMAL ************************ */
|
||
|
||
public static final String WORKER_PATH = "worker";
|
||
|
||
public static final String WORKER_HANDLER_DEPLOY_CONTAINER = "deployContainer";
|
||
|
||
public static final String WORKER_HANDLER_DESTROY_CONTAINER = "destroyContainer";
|
||
|
||
}
|