public interface

ConnectionPoolConfiguration

com.netflix.astyanax.connectionpool.ConnectionPoolConfiguration
Known Indirect Subclasses

Summary

Public Methods
abstract AuthenticationCredentials getAuthenticationCredentials()
Can return null if no login required
abstract BadHostDetector getBadHostDetector()
TODO
abstract int getConnectTimeout()
Socket connect timeout
abstract int getConnectionLimiterMaxPendingCount()
Maximum number of connection attempts in a given window
abstract int getConnectionLimiterWindowSize()
Window size for limiting the number of connection open requests
abstract int getInitConnsPerHost()
Initial number of connections created when a connection pool is started
abstract float getLatencyAwareBadnessThreshold()
Return the threshold after which a host will not be considered good enough for executing operations.
abstract int getLatencyAwareResetInterval()
abstract float getLatencyAwareSentinelCompare()
Sentinel compare value for Phi Accrual
abstract int getLatencyAwareUpdateInterval()
abstract int getLatencyAwareWindowSize()
Latency samples window size for scoring algorithm
abstract LatencyScoreStrategy getLatencyScoreStrategy()
TODO
abstract int getMaxBlockedThreadsPerHost()
Get max number of blocked clients for a host.
abstract int getMaxConns()
Maximum number of connections in the pool, not used by all connection pool implementations
abstract int getMaxConnsPerHost()
Maximum number of connections to allocate for a single host's pool
abstract int getMaxFailoverCount()
Get the max number of failover attempts
abstract int getMaxOperationsPerConnection()
Maximum allowed operations per connections before forcing the connection to close
abstract int getMaxPendingConnectionsPerHost()
Maximum number of pending connect attempts per host
abstract int getMaxTimeoutCount()
Number of allowed timeouts within getTimeoutWindow() milliseconds
abstract int getMaxTimeoutWhenExhausted()
Maximum amount of time to wait for a connection to free up when a connection pool is exhausted.
abstract String getName()
Unique name assigned to this connection pool
abstract int getPort()
Data port to be used when no port is specified to a list of seeds or when doing a ring describe since the ring describe does not include a host
abstract RetryBackoffStrategy getRetryBackoffStrategy()
Return the backoff strategy to use.
abstract int getRetryDelaySlice()
TODO
abstract int getRetryMaxDelaySlice()
TODO
abstract int getRetrySuspendWindow()
TODO
abstract List<Host> getSeedHosts()
Return a list of Host objects from the list of seeds returned by getSeeds().
abstract String getSeeds()
List of comma delimited host:port combinations.
abstract int getSocketTimeout()
Socket read/write timeout
abstract int getTimeoutWindow()
Shut down a host if it times out too many time within this window

Public Methods

public abstract AuthenticationCredentials getAuthenticationCredentials ()

Can return null if no login required

public abstract BadHostDetector getBadHostDetector ()

TODO

public abstract int getConnectTimeout ()

Socket connect timeout

public abstract int getConnectionLimiterMaxPendingCount ()

Maximum number of connection attempts in a given window

public abstract int getConnectionLimiterWindowSize ()

Window size for limiting the number of connection open requests

public abstract int getInitConnsPerHost ()

Initial number of connections created when a connection pool is started

public abstract float getLatencyAwareBadnessThreshold ()

Return the threshold after which a host will not be considered good enough for executing operations.

Returns
  • Valid values are 0 to 1

public abstract int getLatencyAwareResetInterval ()

public abstract float getLatencyAwareSentinelCompare ()

Sentinel compare value for Phi Accrual

public abstract int getLatencyAwareUpdateInterval ()

public abstract int getLatencyAwareWindowSize ()

Latency samples window size for scoring algorithm

public abstract LatencyScoreStrategy getLatencyScoreStrategy ()

TODO

public abstract int getMaxBlockedThreadsPerHost ()

Get max number of blocked clients for a host.

public abstract int getMaxConns ()

Maximum number of connections in the pool, not used by all connection pool implementations

public abstract int getMaxConnsPerHost ()

Maximum number of connections to allocate for a single host's pool

public abstract int getMaxFailoverCount ()

Get the max number of failover attempts

public abstract int getMaxOperationsPerConnection ()

Maximum allowed operations per connections before forcing the connection to close

public abstract int getMaxPendingConnectionsPerHost ()

Maximum number of pending connect attempts per host

public abstract int getMaxTimeoutCount ()

Number of allowed timeouts within getTimeoutWindow() milliseconds

public abstract int getMaxTimeoutWhenExhausted ()

Maximum amount of time to wait for a connection to free up when a connection pool is exhausted.

public abstract String getName ()

Unique name assigned to this connection pool

public abstract int getPort ()

Data port to be used when no port is specified to a list of seeds or when doing a ring describe since the ring describe does not include a host

public abstract RetryBackoffStrategy getRetryBackoffStrategy ()

Return the backoff strategy to use.

public abstract int getRetryDelaySlice ()

TODO

public abstract int getRetryMaxDelaySlice ()

TODO

public abstract int getRetrySuspendWindow ()

TODO

public abstract List<Host> getSeedHosts ()

Return a list of Host objects from the list of seeds returned by getSeeds(). This list must contain at least one valid host other it would not be possible to do a ring describe.

public abstract String getSeeds ()

List of comma delimited host:port combinations. If port is not provided then getPort() will be used by default. This list must contain at least one valid host other it would not be possible to do a ring describe.

public abstract int getSocketTimeout ()

Socket read/write timeout

public abstract int getTimeoutWindow ()

Shut down a host if it times out too many time within this window