package tech.powerjob.common.request;
|
|
import lombok.Data;
|
import tech.powerjob.common.PowerSerializable;
|
|
import java.util.List;
|
|
/**
|
* 服务端调度任务请求(一次任务处理的入口)
|
*
|
* @author tjq
|
* @since 2020/3/17
|
*/
|
@Data
|
public class ServerScheduleJobReq implements PowerSerializable {
|
|
/**
|
* 可用处理器地址,可能多值,逗号分隔
|
*/
|
private List<String> allWorkerAddress;
|
|
/**
|
* 最大机器数量
|
*/
|
private Integer maxWorkerCount;
|
|
/* *********************** 任务相关属性 *********************** */
|
|
/**
|
* 任务ID,当更换Server后需要根据 JobId 重新查询任务元数据
|
*/
|
private Long jobId;
|
|
private Long wfInstanceId;
|
/**
|
* 基础信息
|
*/
|
private Long instanceId;
|
|
/**
|
* 任务执行类型,单机、广播、MR
|
*/
|
private String executeType;
|
/**
|
* 处理器类型(内建,外部)
|
*/
|
private String processorType;
|
/**
|
* 处理器信息
|
*/
|
private String processorInfo;
|
|
|
/**
|
* 整个任务的总体超时时间
|
*/
|
private long instanceTimeoutMS;
|
|
/**
|
* 任务级别的参数,相当于类的static变量
|
*/
|
private String jobParams;
|
/**
|
* 实例级别的参数,相当于类的普通变量(API触发专用,从API触发处带入)
|
*/
|
private String instanceParams;
|
|
/**
|
* 每台机器的处理线程数上限
|
*/
|
private int threadConcurrency;
|
/**
|
* 子任务重试次数(任务本身的重试机制由server控制)
|
*/
|
private int taskRetryNum;
|
|
/**
|
* 时间表达式类型(CRON/API/FIX_RATE/FIX_DELAY)
|
*/
|
private String timeExpressionType;
|
/**
|
* 时间表达式,CRON/NULL/LONG/LONG(单位MS)
|
*/
|
private String timeExpression;
|
|
/**
|
* 最大同时运行任务数,默认 1
|
*/
|
private Integer maxInstanceNum;
|
|
/**
|
* 告警配置
|
*/
|
private String alarmConfig;
|
|
/**
|
* 日志配置
|
*/
|
private String logConfig;
|
|
/**
|
* 高级运行时配置
|
*/
|
private String advancedRuntimeConfig;
|
}
|