com.aquenos.cassandra.pvarchiver.server.spring

Class ThrottlingProperties

java.lang.Object

com.aquenos.cassandra.pvarchiver.server.spring.ThrottlingProperties

@ConfigurationProperties(prefix="throttling",
                         ignoreUnknownFields=false)
public class ThrottlingProperties
extends Object

Configuration properties that control throttling of statements that are executed by the Cassandra database. These properties allow to specify how many statements are executed concurrently, thus providing a protection against overloading the database cluster. This object is injected with properties that have the throttling.* prefix.

Instances of this class are safe for concurrent read access but are not safe for concurrent write access. Typically, this should not be a problem because an instance of this class is initialized once at application startup and then only used for read access.

Author:

Sebastian Marsching

Constructor Summary

Constructors

Constructor and Description
ThrottlingProperties() Creates a properties object, initializing all properties with their default values.

Method Summary

Modifier and Type	Method and Description
int	getMaxConcurrentChannelMetaDataReadStatements() Returns the maximum number of read statements that may be concurrently executed by the ChannelMetaDataDAO.
int	getMaxConcurrentChannelMetaDataWriteStatements() Returns the maximum number of write statements that may be concurrently executed by the ChannelMetaDataDAO.
int	getMaxConcurrentControlSystemSupportReadStatements() Returns the maximum number of read statements that may be concurrently executed by all ControlSystemSupports.
int	getMaxConcurrentControlSystemSupportWriteStatements() Returns the maximum number of write statements that may be concurrently executed by all ControlSystemSupports.
void	setMaxConcurrentChannelMetaDataReadStatements(int maxConcurrentChannelMetaDataReadStatements) Sets the maximum number of read statements that may be concurrently executed by the ChannelMetaDataDAO.
void	setMaxConcurrentChannelMetaDataWriteStatements(int maxConcurrentChannelMetaDataWriteStatements) Sets the maximum number of write statements that may be concurrently executed by the ChannelMetaDataDAO.
void	setMaxConcurrentControlSystemSupportReadStatements(int maxConcurrentControlSystemSupportReadStatements) Sets the maximum number of read statements that may be concurrently executed by all ControlSystemSupports.
void	setMaxConcurrentControlSystemSupportWriteStatements(int maxConcurrentControlSystemSupportWriteStatements) Sets the maximum number of write statements that may be concurrently executed by all ControlSystemSupports.

Methods inherited from class java.lang.Object

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

Constructor Detail

ThrottlingProperties

public ThrottlingProperties()

Creates a properties object, initializing all properties with their default values.

Method Detail

getMaxConcurrentChannelMetaDataReadStatements

public int getMaxConcurrentChannelMetaDataReadStatements()

Returns the maximum number of read statements that may be concurrently executed by the ChannelMetaDataDAO. Typically, these are read statements that load a channel configuration or information object or that look for pending channel operations. The default value is 64.

Returns:

maximum number of concurrently running read statements allowed for the ChannelMetaDataDAO.

setMaxConcurrentChannelMetaDataReadStatements

public void setMaxConcurrentChannelMetaDataReadStatements(int maxConcurrentChannelMetaDataReadStatements)

Sets the maximum number of read statements that may be concurrently executed by the ChannelMetaDataDAO. Typically, these are read statements that load a channel configuration or information object or that look for pending channel operations. The default value is 64.

Parameters:

maxConcurrentChannelMetaDataReadStatements - maximum number of concurrently running read statements allowed for the ChannelMetaDataDAO. Must be greater than zero.

Throws:

IllegalArgumentException - if the specified value is less than one.

getMaxConcurrentChannelMetaDataWriteStatements

public int getMaxConcurrentChannelMetaDataWriteStatements()

Returns the maximum number of write statements that may be concurrently executed by the ChannelMetaDataDAO. Typically, these are write statements that modify a channel configuration and information object or that add or remove pending channel operations. These write statements typically are logged batch statements or light-weight transactions, so they are significantly more expensive than regular write statements. The default value is 16.

Returns:

maximum number of concurrently running write statements allowed for the ChannelMetaDataDAO.

setMaxConcurrentChannelMetaDataWriteStatements

public void setMaxConcurrentChannelMetaDataWriteStatements(int maxConcurrentChannelMetaDataWriteStatements)

Sets the maximum number of write statements that may be concurrently executed by the ChannelMetaDataDAO. Typically, these are write statements that modify a channel configuration and information object or that add or remove pending channel operations. These write statements typically are logged batch statements or light-weight transactions, so they are significantly more expensive than regular write statements. The default value is 16.

Parameters:

maxConcurrentChannelMetaDataWriteStatements - maximum number of concurrently running write statements allowed for the ChannelMetaDataDAO. Must be greater than zero.

Throws:

IllegalArgumentException - if the specified value is less than one.

getMaxConcurrentControlSystemSupportReadStatements

public int getMaxConcurrentControlSystemSupportReadStatements()

Returns the maximum number of read statements that may be concurrently executed by all ControlSystemSupports. Typically, these are read statements that read samples from a sample bucket. All ControlSystemSupports share the same session and thus all their statements contribute towards reaching this limit. The default value is 128.

Returns:

maximum number of concurrently running read statements allowed for all ControlSystemSupports.

setMaxConcurrentControlSystemSupportReadStatements

public void setMaxConcurrentControlSystemSupportReadStatements(int maxConcurrentControlSystemSupportReadStatements)

Sets the maximum number of read statements that may be concurrently executed by all ControlSystemSupports. Typically, these are read statements that read samples from a sample bucket. All ControlSystemSupports share the same session and thus all their statements contribute towards reaching this limit. The default value is 128.

Parameters:

maxConcurrentControlSystemSupportReadStatements - maximum number of concurrently running read statements allowed for all ControlSystemSupports.

Throws:

IllegalArgumentException - if the specified value is less than one.

getMaxConcurrentControlSystemSupportWriteStatements

public int getMaxConcurrentControlSystemSupportWriteStatements()

Returns the maximum number of write statements that may be concurrently executed by all ControlSystemSupports. Typically, these are write statements that write a single sample to a sample bucket, which means that this kind of statements is rather cheap. All ControlSystemSupports share the same session and thus all their statements contribute towards reaching this limit. The default value is 512.

Returns:

maximum number of concurrently running write statements allowed for all ControlSystemSupports.

setMaxConcurrentControlSystemSupportWriteStatements

public void setMaxConcurrentControlSystemSupportWriteStatements(int maxConcurrentControlSystemSupportWriteStatements)

Sets the maximum number of write statements that may be concurrently executed by all ControlSystemSupports. Typically, these are write statements that write a single sample to a sample bucket, which means that this kind of statements is rather cheap. All ControlSystemSupports share the same session and thus all their statements contribute towards reaching this limit. The default value is 512.

Parameters:

maxConcurrentControlSystemSupportWriteStatements - maximum number of concurrently running write statements allowed for all ControlSystemSupports.

Throws:

IllegalArgumentException - if the specified value is less than one.