io.parallec.core.config

Class ParallelTaskConfig

java.lang.Object

io.parallec.core.config.ParallelTaskConfig

public class ParallelTaskConfig
extends java.lang.Object

Configuration class to use with a ParallelTask. This can be overwritten for each task. Configs about various timeout, whether to auto save logs / save responses. whether to enable the capacity scheduler. Some of the most useful ones we directly have APIs by the ParallelTaskBuilder will load from the default value from ParallelTaskConfigDefault

Field Summary

Fields

Modifier and Type	Field and Description
private int	actorMaxOperationTimeoutSec The actor max operation timeout sec.
private long	asstManagerRetryIntervalMillis The asst manager retry interval millis.
private boolean	autoSaveLogToLocal
private boolean	enableCapacityAwareTaskScheduler The enable capacity protection.
private HandlerExecutionLocation	handlerExecutionLocation
private boolean	printHttpTrueHeaderMap The print http true header map.
private boolean	printPoller
private boolean	saveResponseToTask
private long	timeoutAskManagerSec The timeout the director send to the manager to cancel it from outside.
private long	timeoutInManagerSec The command manager internal timeout and cancel itself time in seconds Note this may need to be adjusted for long polling jobs.

Constructor Summary

Constructors

Constructor and Description
ParallelTaskConfig()

Method Summary

Modifier and Type	Method and Description
int	getActorMaxOperationTimeoutSec()
long	getAsstManagerRetryIntervalMillis()
HandlerExecutionLocation	getHandlerExecutionLocation()
long	getTimeoutAskManagerSec()
long	getTimeoutInManagerSec()
boolean	isAutoSaveLogToLocal()
boolean	isEnableCapacityAwareTaskScheduler()
boolean	isPrintHttpTrueHeaderMap()
boolean	isPrintPoller()
boolean	isSaveResponseToTask()
void	setActorMaxOperationTimeoutSec(int actorMaxOperationTimeoutSec)
void	setAsstManagerRetryIntervalMillis(long asstManagerRetryIntervalMillis)
void	setAutoSaveLogToLocal(boolean autoSaveLogToLocal)
void	setEnableCapacityAwareTaskScheduler(boolean enableCapacityAwareTaskScheduler)
void	setHandlerExecutionLocation(HandlerExecutionLocation handlerExecutionLocation)
void	setPrintHttpTrueHeaderMap(boolean printHttpTrueHeaderMap)
void	setPrintPoller(boolean printPoller)
void	setSaveResponseToTask(boolean saveResponseToTask)
void	setTimeoutAskManagerSec(long timeoutAskManagerSec)
void	setTimeoutInManagerSec(long timeoutInManagerSec)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

asstManagerRetryIntervalMillis

private long asstManagerRetryIntervalMillis

The asst manager retry interval millis.

actorMaxOperationTimeoutSec

private int actorMaxOperationTimeoutSec

The actor max operation timeout sec.

timeoutInManagerSec

private long timeoutInManagerSec

The command manager internal timeout and cancel itself time in seconds Note this may need to be adjusted for long polling jobs.

timeoutAskManagerSec

private long timeoutAskManagerSec

The timeout the director send to the manager to cancel it from outside.

printHttpTrueHeaderMap

private boolean printHttpTrueHeaderMap

The print http true header map.

printPoller

private boolean printPoller

saveResponseToTask

private boolean saveResponseToTask

enableCapacityAwareTaskScheduler

private boolean enableCapacityAwareTaskScheduler

The enable capacity protection. When enabled, a parallec task may not be immediately executed. Instead, it is submitted to a wait q. Every 0.5 second, a deamon thread (SingleThreadScheduledExecutor) is used to check if there is capacity to put the new node in. a parallel task capacity is calculated as Min(task.maxConcurrency, requestNum)

details check ParallelTaskManager initTaskScheduler

autoSaveLogToLocal

private boolean autoSaveLogToLocal

handlerExecutionLocation

private HandlerExecutionLocation handlerExecutionLocation

Constructor Detail

ParallelTaskConfig

public ParallelTaskConfig()

Method Detail

getAsstManagerRetryIntervalMillis

public long getAsstManagerRetryIntervalMillis()

setAsstManagerRetryIntervalMillis

public void setAsstManagerRetryIntervalMillis(long asstManagerRetryIntervalMillis)

getActorMaxOperationTimeoutSec

public int getActorMaxOperationTimeoutSec()

setActorMaxOperationTimeoutSec

public void setActorMaxOperationTimeoutSec(int actorMaxOperationTimeoutSec)

getTimeoutInManagerSec

public long getTimeoutInManagerSec()

setTimeoutInManagerSec

public void setTimeoutInManagerSec(long timeoutInManagerSec)

getTimeoutAskManagerSec

public long getTimeoutAskManagerSec()

setTimeoutAskManagerSec

public void setTimeoutAskManagerSec(long timeoutAskManagerSec)

isPrintHttpTrueHeaderMap

public boolean isPrintHttpTrueHeaderMap()

setPrintHttpTrueHeaderMap

public void setPrintHttpTrueHeaderMap(boolean printHttpTrueHeaderMap)

isPrintPoller

public boolean isPrintPoller()

setPrintPoller

public void setPrintPoller(boolean printPoller)

isSaveResponseToTask

public boolean isSaveResponseToTask()

setSaveResponseToTask

public void setSaveResponseToTask(boolean saveResponseToTask)

isEnableCapacityAwareTaskScheduler

public boolean isEnableCapacityAwareTaskScheduler()

setEnableCapacityAwareTaskScheduler

public void setEnableCapacityAwareTaskScheduler(boolean enableCapacityAwareTaskScheduler)

isAutoSaveLogToLocal

public boolean isAutoSaveLogToLocal()

setAutoSaveLogToLocal

public void setAutoSaveLogToLocal(boolean autoSaveLogToLocal)

getHandlerExecutionLocation

public HandlerExecutionLocation getHandlerExecutionLocation()

setHandlerExecutionLocation

public void setHandlerExecutionLocation(HandlerExecutionLocation handlerExecutionLocation)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object