程序包 cn.feiliu.taskflow.sdk.config

类 WorkerPropertyManager

java.lang.Object

cn.feiliu.taskflow.sdk.config.WorkerPropertyManager

public class WorkerPropertyManager
extends Object

从以下版本开始:

2024-09-23

作者:

SHOUSHEN.LUAN

字段概要

字段

修饰符和类型	字段	说明
protected static String	DOMAIN
protected static String	OVERRIDE_DISCOVERY

构造器概要

构造器

构造器	说明
WorkerPropertyManager()

方法概要

修饰符和类型	方法	说明
static int	getBatchPollTimeoutInMS(String taskDefName)	获取批量拉取任务超时时间
static String	getDomainWithFallback(String taskType, String allWorkers, String defaultValue)
static int	getPollingInterval(String taskDefName)	获取Worker拉取间隔时间
static boolean	getPollOutOfDiscovery(String taskDefName, String allWorkers, boolean defaultValue)
static boolean	leaseExtendEnabled(String taskDefName)
static boolean	paused(String taskDefName)	获取任务是否为暂停状态

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

DOMAIN

protected static final String DOMAIN

另请参阅:

常量字段值

OVERRIDE_DISCOVERY

protected static final String OVERRIDE_DISCOVERY

另请参阅:

常量字段值

构造器详细资料

WorkerPropertyManager

public WorkerPropertyManager()

方法详细资料

paused

public static boolean paused(String taskDefName)

获取任务是否为暂停状态

参数:

taskDefName -

返回:

getPollingInterval

public static int getPollingInterval(String taskDefName)

获取Worker拉取间隔时间

参数:

taskDefName -

返回:

leaseExtendEnabled

public static boolean leaseExtendEnabled(String taskDefName)

getBatchPollTimeoutInMS

public static int getBatchPollTimeoutInMS(String taskDefName)

获取批量拉取任务超时时间

参数:

taskDefName -

返回:

getDomainWithFallback

public static String getDomainWithFallback(String taskType,
                                           String allWorkers,
                                           String defaultValue)

getPollOutOfDiscovery

public static boolean getPollOutOfDiscovery(String taskDefName,
                                            String allWorkers,
                                            boolean defaultValue)