org.apache.bookkeeper.conf

Class ClientConfiguration

java.lang.Object

org.apache.commons.configuration.event.EventSource

org.apache.commons.configuration.AbstractConfiguration

org.apache.commons.configuration.CompositeConfiguration

org.apache.bookkeeper.conf.AbstractConfiguration

org.apache.bookkeeper.conf.ClientConfiguration

All Implemented Interfaces:

Cloneable, org.apache.commons.configuration.Configuration

public class ClientConfiguration
extends AbstractConfiguration

Configuration settings for client side

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	CLIENT_TCP_NODELAY
protected static String	DIGEST_TYPE
protected static String	PASSWD
protected static String	THROTTLE
protected static String	ZK_SERVERS
protected static String	ZK_TIMEOUT

Fields inherited from class org.apache.bookkeeper.conf.AbstractConfiguration

LEDGER_MANAGER_TYPE, ZK_LEDGERS_ROOT_PATH

Fields inherited from class org.apache.commons.configuration.AbstractConfiguration

END_TOKEN, EVENT_ADD_PROPERTY, EVENT_CLEAR, EVENT_CLEAR_PROPERTY, EVENT_READ_PROPERTY, EVENT_SET_PROPERTY, START_TOKEN

Constructor Summary

Constructors

Constructor and Description
ClientConfiguration() Construct a default client-side configuration
ClientConfiguration(AbstractConfiguration conf) Construct a client-side configuration using a base configuration

Method Summary

Methods

Modifier and Type	Method and Description
BookKeeper.DigestType	getBookieRecoveryDigestType() Get digest type used in bookkeeper admin
byte[]	getBookieRecoveryPasswd() Get passwd used in bookkeeper admin
boolean	getClientTcpNoDelay() Is tcp connection no delay.
int	getThrottleValue() Get throttle value
String	getZkServers() Get zookeeper servers to connect
int	getZkTimeout() Get zookeeper timeout
ClientConfiguration	setBookieRecoveryDigestType(BookKeeper.DigestType digestType) Set digest type used in bookkeeper admin.
ClientConfiguration	setBookieRecoveryPasswd(byte[] passwd) Set passwd used in bookkeeper admin.
ClientConfiguration	setClientTcpNoDelay(boolean noDelay) Set socket nodelay setting.
ClientConfiguration	setThrottleValue(int throttle) Set throttle value.
ClientConfiguration	setZkServers(String zkServers) Set zookeeper servers to connect
ClientConfiguration	setZkTimeout(int zkTimeout) Set zookeeper timeout

Methods inherited from class org.apache.bookkeeper.conf.AbstractConfiguration

getLedgerManagerType, getZkLedgersRootPath, loadConf, loadConf, setLedgerManagerType, setZkLedgersRootPath

Methods inherited from class org.apache.commons.configuration.CompositeConfiguration

addConfiguration, addPropertyDirect, clear, clearPropertyDirect, clone, containsKey, getConfiguration, getInMemoryConfiguration, getKeys, getKeys, getList, getNumberOfConfigurations, getProperty, getSource, getStringArray, isEmpty, removeConfiguration, setDelimiterParsingDisabled, setListDelimiter

Methods inherited from class org.apache.commons.configuration.AbstractConfiguration

addErrorLogListener, addProperty, append, clearProperty, copy, createInterpolator, getBigDecimal, getBigDecimal, getBigInteger, getBigInteger, getBoolean, getBoolean, getBoolean, getByte, getByte, getByte, getDefaultListDelimiter, getDelimiter, getDouble, getDouble, getDouble, getFloat, getFloat, getFloat, getInt, getInt, getInteger, getInterpolator, getList, getListDelimiter, getLogger, getLong, getLong, getLong, getProperties, getProperties, getShort, getShort, getShort, getString, getString, getSubstitutor, interpolate, interpolate, interpolatedConfiguration, interpolateHelper, isDelimiterParsingDisabled, isThrowExceptionOnMissing, resolveContainerStore, setDefaultListDelimiter, setDelimiter, setLogger, setProperty, setThrowExceptionOnMissing, subset

Methods inherited from class org.apache.commons.configuration.event.EventSource

addConfigurationListener, addErrorListener, clearConfigurationListeners, clearErrorListeners, createErrorEvent, createEvent, fireError, fireEvent, getConfigurationListeners, getErrorListeners, isDetailEvents, removeConfigurationListener, removeErrorListener, setDetailEvents

Methods inherited from class java.lang.Object

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

Field Detail

ZK_TIMEOUT

protected static final String ZK_TIMEOUT

See Also:

Constant Field Values

ZK_SERVERS

protected static final String ZK_SERVERS

See Also:

Constant Field Values

THROTTLE

protected static final String THROTTLE

See Also:

Constant Field Values

DIGEST_TYPE

protected static final String DIGEST_TYPE

See Also:

Constant Field Values

PASSWD

protected static final String PASSWD

See Also:

Constant Field Values

CLIENT_TCP_NODELAY

protected static final String CLIENT_TCP_NODELAY

See Also:

Constant Field Values

Constructor Detail

ClientConfiguration

public ClientConfiguration()

Construct a default client-side configuration

ClientConfiguration

public ClientConfiguration(AbstractConfiguration conf)

Construct a client-side configuration using a base configuration

Parameters:

conf - Base configuration

Method Detail

getThrottleValue

public int getThrottleValue()

Get throttle value

Returns:

throttle value

See Also:

setThrottleValue(int)

setThrottleValue

public ClientConfiguration setThrottleValue(int throttle)

Set throttle value. Since BookKeeper process requests in asynchrous way, it will holds those pending request in queue. You may easily run it out of memory if producing too many requests than the capability of bookie servers can handle. To prevent that from happeding, you can set a throttle value here.

Parameters:

throttle - Throttle Value

Returns:

client configuration

getBookieRecoveryDigestType

public BookKeeper.DigestType getBookieRecoveryDigestType()

Get digest type used in bookkeeper admin

Returns:

digest type

See Also:

setBookieRecoveryDigestType(org.apache.bookkeeper.client.BookKeeper.DigestType)

setBookieRecoveryDigestType

public ClientConfiguration setBookieRecoveryDigestType(BookKeeper.DigestType digestType)

Set digest type used in bookkeeper admin. Digest Type and Passwd used to open ledgers for admin tool For now, assume that all ledgers were created with the same DigestType and password. In the future, this admin tool will need to know for each ledger, what was the DigestType and password used to create it before it can open it. These values will come from System properties, though fixed defaults are defined here.

Parameters:

digestType - Digest Type

Returns:

client configuration

getBookieRecoveryPasswd

public byte[] getBookieRecoveryPasswd()

Get passwd used in bookkeeper admin

Returns:

password

See Also:

setBookieRecoveryPasswd(byte[])

setBookieRecoveryPasswd

public ClientConfiguration setBookieRecoveryPasswd(byte[] passwd)

Set passwd used in bookkeeper admin. Digest Type and Passwd used to open ledgers for admin tool For now, assume that all ledgers were created with the same DigestType and password. In the future, this admin tool will need to know for each ledger, what was the DigestType and password used to create it before it can open it. These values will come from System properties, though fixed defaults are defined here.

Parameters:

passwd - Password

Returns:

client configuration

getClientTcpNoDelay

public boolean getClientTcpNoDelay()

Is tcp connection no delay.

Returns:

tcp socket nodelay setting

See Also:

setClientTcpNoDelay(boolean)

setClientTcpNoDelay

public ClientConfiguration setClientTcpNoDelay(boolean noDelay)

Set socket nodelay setting. This settings is used to enabled/disabled Nagle's algorithm, which is a means of improving the efficiency of TCP/IP networks by reducing the number of packets that need to be sent over the network. If you are sending many small messages, such that more than one can fit in a single IP packet, setting client.tcpnodelay to false to enable Nagle algorithm can provide better performance.
Default value is true.

Parameters:

noDelay - NoDelay setting

Returns:

client configuration

getZkServers

public String getZkServers()

Get zookeeper servers to connect

Returns:

zookeeper servers

setZkServers

public ClientConfiguration setZkServers(String zkServers)

Set zookeeper servers to connect

Parameters:

zkServers - ZooKeeper servers to connect

getZkTimeout

public int getZkTimeout()

Get zookeeper timeout

Returns:

zookeeper client timeout

setZkTimeout

public ClientConfiguration setZkTimeout(int zkTimeout)

Set zookeeper timeout

Parameters:

zkTimeout - ZooKeeper client timeout

Returns:

client configuration