voldemort.rest.coordinator
Class CoordinatorConfig

java.lang.Object
  voldemort.rest.coordinator.CoordinatorConfig

public class CoordinatorConfig
extends java.lang.Object

Field Summary

static java.lang.String	BOOTSTRAP_URLS_PROPERTY
static java.lang.String	COORDINATOR_CORE_THREADS
static java.lang.String	COORDINATOR_MAX_THREADS
static java.lang.String	COORDINATOR_QUEUED_REQUESTS
static java.lang.String	FAT_CLIENTS_CONFIG_FILE_PATH_PROPERTY
static java.lang.String	HTTP_MESSAGE_DECODER_MAX_CHUNK_SIZE
static java.lang.String	HTTP_MESSAGE_DECODER_MAX_HEADER_SIZE
static java.lang.String	HTTP_MESSAGE_DECODER_MAX_INITIAL_LINE_LENGTH
static java.lang.String	METADATA_CHECK_INTERVAL_IN_MS
static java.lang.String	NETTY_SERVER_BACKLOG
static java.lang.String	NETTY_SERVER_PORT

Constructor Summary

CoordinatorConfig()
Dummy constructor for testing purposes

CoordinatorConfig(java.io.File propertyFile)
Instantiate the coordinator config using a properties file

CoordinatorConfig(java.util.Properties properties)
Initiate the coordinator config from a set of properties.

Method Summary

java.lang.String[]	getBootstrapURLs()
int	getCoordinatorCoreThreads()
int	getCoordinatorMaxThreads()
int	getCoordinatorQueuedRequestsSize()
java.lang.String	getFatClientConfigPath()
int	getHttpMessageDecoderMaxChunkSize()
int	getHttpMessageDecoderMaxHeaderSize()
int	getHttpMessageDecoderMaxInitialLength()
int	getMetadataCheckIntervalInMs()
int	getNettyServerBacklog()
int	getServerPort()
CoordinatorConfig	setBootstrapURLs(java.util.List<java.lang.String> bootstrapUrls) Sets the bootstrap URLs used by the different Fat clients inside the Coordinator
CoordinatorConfig	setCoordinatorCoreThreads(int coordinatorCoreThreads)
CoordinatorConfig	setCoordinatorMaxThreads(int coordinatorMaxThreads)
CoordinatorConfig	setCoordinatorQueuedRequestsSize(int coordinatorQueuedRequestsSize)
CoordinatorConfig	setFatClientConfigPath(java.lang.String fatClientConfigPath) Defines individual config for each of the fat clients managed by the Coordinator
CoordinatorConfig	setHttpMessageDecoderMaxChunkSize(int httpMessageDecoderMaxChunkSize)
CoordinatorConfig	setHttpMessageDecoderMaxHeaderSize(int httpMessageDecoderMaxHeaderSize)
CoordinatorConfig	setHttpMessageDecoderMaxInitialLength(int httpMessageDecoderMaxInitialLength)
CoordinatorConfig	setMetadataCheckIntervalInMs(int metadataCheckIntervalInMs)
CoordinatorConfig	setNettyServerBacklog(int nettyServerBacklog)
CoordinatorConfig	setServerPort(int serverPort)

Methods inherited from class java.lang.Object

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

Field Detail

BOOTSTRAP_URLS_PROPERTY

public static final java.lang.String BOOTSTRAP_URLS_PROPERTY

See Also:

Constant Field Values

FAT_CLIENTS_CONFIG_FILE_PATH_PROPERTY

public static final java.lang.String FAT_CLIENTS_CONFIG_FILE_PATH_PROPERTY

See Also:

Constant Field Values

METADATA_CHECK_INTERVAL_IN_MS

public static final java.lang.String METADATA_CHECK_INTERVAL_IN_MS

See Also:

Constant Field Values

NETTY_SERVER_PORT

public static final java.lang.String NETTY_SERVER_PORT

See Also:

Constant Field Values

NETTY_SERVER_BACKLOG

public static final java.lang.String NETTY_SERVER_BACKLOG

See Also:

Constant Field Values

COORDINATOR_CORE_THREADS

public static final java.lang.String COORDINATOR_CORE_THREADS

See Also:

Constant Field Values

COORDINATOR_MAX_THREADS

public static final java.lang.String COORDINATOR_MAX_THREADS

See Also:

Constant Field Values

COORDINATOR_QUEUED_REQUESTS

public static final java.lang.String COORDINATOR_QUEUED_REQUESTS

See Also:

Constant Field Values

HTTP_MESSAGE_DECODER_MAX_INITIAL_LINE_LENGTH

public static final java.lang.String HTTP_MESSAGE_DECODER_MAX_INITIAL_LINE_LENGTH

See Also:

Constant Field Values

HTTP_MESSAGE_DECODER_MAX_HEADER_SIZE

public static final java.lang.String HTTP_MESSAGE_DECODER_MAX_HEADER_SIZE

See Also:

Constant Field Values

HTTP_MESSAGE_DECODER_MAX_CHUNK_SIZE

public static final java.lang.String HTTP_MESSAGE_DECODER_MAX_CHUNK_SIZE

See Also:

Constant Field Values

Constructor Detail

CoordinatorConfig

public CoordinatorConfig(java.io.File propertyFile)

Instantiate the coordinator config using a properties file

Parameters:

propertyFile - Properties file

CoordinatorConfig

public CoordinatorConfig(java.util.Properties properties)

Initiate the coordinator config from a set of properties. This is useful for wiring from Spring or for externalizing client properties to a properties file

Parameters:

properties - The properties to use

CoordinatorConfig

public CoordinatorConfig()

Dummy constructor for testing purposes

Method Detail

getBootstrapURLs

public java.lang.String[] getBootstrapURLs()

setBootstrapURLs

public CoordinatorConfig setBootstrapURLs(java.util.List<java.lang.String> bootstrapUrls)

Sets the bootstrap URLs used by the different Fat clients inside the Coordinator

Parameters:

bootstrapUrls - list of bootstrap URLs defining which cluster to connect to

Returns:

modified CoordinatorConfig

getFatClientConfigPath

public java.lang.String getFatClientConfigPath()

setFatClientConfigPath

public CoordinatorConfig setFatClientConfigPath(java.lang.String fatClientConfigPath)

Defines individual config for each of the fat clients managed by the Coordinator

Parameters:

fatClientConfigPath - The path of the file containing the fat client config in Avro format

getMetadataCheckIntervalInMs

public int getMetadataCheckIntervalInMs()

setMetadataCheckIntervalInMs

public CoordinatorConfig setMetadataCheckIntervalInMs(int metadataCheckIntervalInMs)

Parameters:

metadataCheckIntervalInMs - Defines the frequency with which to check for updates in the cluster metadata (Eg: cluster.xml and stores.xml)

getServerPort

public int getServerPort()

setServerPort

public CoordinatorConfig setServerPort(int serverPort)

Parameters:

serverPort - Defines the port to use while bootstrapping the Netty server

getNettyServerBacklog

public int getNettyServerBacklog()

setNettyServerBacklog

public CoordinatorConfig setNettyServerBacklog(int nettyServerBacklog)

Parameters:

nettyServerBacklog - Defines the netty server backlog value

getCoordinatorCoreThreads

public int getCoordinatorCoreThreads()

setCoordinatorCoreThreads

public CoordinatorConfig setCoordinatorCoreThreads(int coordinatorCoreThreads)

Parameters:

coordinatorCoreThreads - Specifies the # core request executor threads

getCoordinatorMaxThreads

public int getCoordinatorMaxThreads()

setCoordinatorMaxThreads

public CoordinatorConfig setCoordinatorMaxThreads(int coordinatorMaxThreads)

Parameters:

coordinatorMaxThreads - Specifies the # max request executor threads

getCoordinatorQueuedRequestsSize

public int getCoordinatorQueuedRequestsSize()

setCoordinatorQueuedRequestsSize

public CoordinatorConfig setCoordinatorQueuedRequestsSize(int coordinatorQueuedRequestsSize)

Parameters:

coordinatorQueuedRequestsSize - Defines the max # requests that can be queued for processing

setHttpMessageDecoderMaxInitialLength

public CoordinatorConfig setHttpMessageDecoderMaxInitialLength(int httpMessageDecoderMaxInitialLength)

Parameters:

httpMessageDecoderMaxInitialLength - Defines the maximum length of the initial line. If the length of the initial line exceeds this value, a TooLongFrameException will be raised.

getHttpMessageDecoderMaxInitialLength

public int getHttpMessageDecoderMaxInitialLength()

setHttpMessageDecoderMaxHeaderSize

public CoordinatorConfig setHttpMessageDecoderMaxHeaderSize(int httpMessageDecoderMaxHeaderSize)

Parameters:

httpMessageDecoderMaxHeaderSize - Defines maximum length of all headers. If the sum of the length of each header exceeds this value, a TooLongFrameException will be raised.

getHttpMessageDecoderMaxHeaderSize

public int getHttpMessageDecoderMaxHeaderSize()

setHttpMessageDecoderMaxChunkSize

public CoordinatorConfig setHttpMessageDecoderMaxChunkSize(int httpMessageDecoderMaxChunkSize)

Parameters:

httpMessageDecoderMaxChunkSize - Defines the maximum length of the content or each chunk. If the content length (or the length of each chunk) exceeds this value, the content or chunk will be split into multiple HttpChunks whose length is maxChunkSize at maximum.

getHttpMessageDecoderMaxChunkSize

public int getHttpMessageDecoderMaxChunkSize()