io.parallec.core.config

Class ParallecGlobalConfig

java.lang.Object

io.parallec.core.config.ParallecGlobalConfig

public class ParallecGlobalConfig
extends java.lang.Object

this is the global system config. You can replace the values here before executing them. Different from those settings defined in ParallelTaskConfig, settings here are effective to all executions, and cannot be overwritten for a particular task.

Author:

Yuanteng (Jeff) Pei

Field Summary

Fields

Modifier and Type	Field and Description
static int	concurrencyDefault The concurrency for each task.
static int	concurrencySshLimit The max concurrency for SSH task.
static double	logAllResponseAfterPercent The log all response after percent.
static int	logAllResponseBeforeInitCount The log all response before init count.
static double	logAllResponseBeforePercent The log all response before percent.
static int	logAllResponseIfTotalLessThan The log all response if total less than.
static int	logResponseInterval The log response interval.
static int	maxCapacity The max capacity for the job scheduler.
static int	ningFastClientConnectionTimeoutMillis The ning fast client connection timeout millis.
static int	ningFastClientRequestTimeoutMillis The ning fast client request timeout millis.
static int	ningSlowClientConnectionTimeoutMillis The ning slow client connection timeout millis.
static int	ningSlowClientRequestTimeoutMillis The ning slow client request timeout millis.
static double	pingFutureCheckIntervalSec The ping future check interval sec.
static PingMode	pingModeDefault The ping mode default.
static int	pingNumRetriesDefault The ping num retries default.
static int	pingTimeoutMillisDefault The ping timeout millis default.
static long	schedulerCheckInterval The scheduler check interval.
static long	schedulerInitDelay The scheduler init delay.
static int	sshBufferSize The ssh buffer size.
static int	sshConnectionTimeoutMillisDefault The ssh connection timeout millis default.
static double	sshFutureCheckIntervalSec The ssh future check interval sec.
static int	sshSleepMIllisBtwReadBuffer The ssh sleep millis btw read buffer.
static java.lang.String	taskLogFolderWithSlash The task log folder with slash.
static java.lang.String	taskLogPostfix The task log postfix.
static int	tcpConnectTimeoutMillisDefault The tcp connection timeout millis default.
static int	tcpIdleTimeoutSecDefault The tcp idle timeout seconds default.
static int	udpIdleTimeoutSecDefault The udp connection timeout millis default.
static int	urlConnectionConnectTimeoutMillis The url connection connect timeout millis.
static int	urlConnectionReadTimeoutMillis The url connection read timeout millis.
static java.lang.String	userDataFolderWithSlash The Constant USERDATA_FOLDER_WITH_SLASH.

Constructor Summary

Constructors

Constructor and Description
ParallecGlobalConfig()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

maxCapacity

public static int maxCapacity

The max capacity for the job scheduler. default 2500

concurrencyDefault

public static int concurrencyDefault

The concurrency for each task. default 1000

concurrencySshLimit

public static int concurrencySshLimit

The max concurrency for SSH task. default 400.

schedulerCheckInterval

public static long schedulerCheckInterval

The scheduler check interval. default 500ms

schedulerInitDelay

public static long schedulerInitDelay

The scheduler init delay. default 500 ms

ningSlowClientRequestTimeoutMillis

public static int ningSlowClientRequestTimeoutMillis

The ning slow client request timeout millis.

ningSlowClientConnectionTimeoutMillis

public static int ningSlowClientConnectionTimeoutMillis

The ning slow client connection timeout millis.

ningFastClientRequestTimeoutMillis

public static int ningFastClientRequestTimeoutMillis

The ning fast client request timeout millis.

ningFastClientConnectionTimeoutMillis

public static int ningFastClientConnectionTimeoutMillis

The ning fast client connection timeout millis.

sshConnectionTimeoutMillisDefault

public static int sshConnectionTimeoutMillisDefault

The ssh connection timeout millis default.

sshSleepMIllisBtwReadBuffer

public static int sshSleepMIllisBtwReadBuffer

The ssh sleep millis btw read buffer.

sshBufferSize

public static int sshBufferSize

The ssh buffer size.

tcpConnectTimeoutMillisDefault

public static int tcpConnectTimeoutMillisDefault

The tcp connection timeout millis default.

udpIdleTimeoutSecDefault

public static int udpIdleTimeoutSecDefault

The udp connection timeout millis default.

tcpIdleTimeoutSecDefault

public static int tcpIdleTimeoutSecDefault

The tcp idle timeout seconds default.

pingTimeoutMillisDefault

public static int pingTimeoutMillisDefault

The ping timeout millis default.

pingModeDefault

public static PingMode pingModeDefault

The ping mode default.

pingNumRetriesDefault

public static int pingNumRetriesDefault

The ping num retries default.

userDataFolderWithSlash

public static java.lang.String userDataFolderWithSlash

The Constant USERDATA_FOLDER_WITH_SLASH.

taskLogFolderWithSlash

public static java.lang.String taskLogFolderWithSlash

The task log folder with slash.

taskLogPostfix

public static java.lang.String taskLogPostfix

The task log postfix.

sshFutureCheckIntervalSec

public static double sshFutureCheckIntervalSec

The ssh future check interval sec.

pingFutureCheckIntervalSec

public static double pingFutureCheckIntervalSec

The ping future check interval sec.

logResponseInterval

public static int logResponseInterval

The log response interval.

logAllResponseAfterPercent

public static double logAllResponseAfterPercent

The log all response after percent.

logAllResponseBeforePercent

public static double logAllResponseBeforePercent

The log all response before percent.

logAllResponseBeforeInitCount

public static int logAllResponseBeforeInitCount

The log all response before init count.

logAllResponseIfTotalLessThan

public static int logAllResponseIfTotalLessThan

The log all response if total less than.

urlConnectionConnectTimeoutMillis

public static int urlConnectionConnectTimeoutMillis

The url connection connect timeout millis. Used when load target host from URL/CMS

urlConnectionReadTimeoutMillis

public static int urlConnectionReadTimeoutMillis

The url connection read timeout millis. Used when load target host from URL/CMS

Constructor Detail

ParallecGlobalConfig

public ParallecGlobalConfig()