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";

}