|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.netflix.astyanax.connectionpool.impl.ConnectionPoolConfigurationImpl
public class ConnectionPoolConfigurationImpl
Constructor Summary | |
---|---|
ConnectionPoolConfigurationImpl(String name)
|
Method Summary | |
---|---|
BadHostDetector |
getBadHostDetector()
TODO |
int |
getConnectionLimiterMaxPendingCount()
Maximum number of connection attempts in a given window |
int |
getConnectionLimiterWindowSize()
Window size for limiting the number of connection open requests |
int |
getConnectTimeout()
Socket connect timeout |
int |
getInitConnsPerHost()
Initial number of connections created when a connection pool is started |
float |
getLatencyAwareBadnessThreshold()
Return the threshold after which a host will not be considered good enough for executing operations. |
int |
getLatencyAwareResetInterval()
|
float |
getLatencyAwareSentinelCompare()
Sentinel compare value for Phi Accrual |
int |
getLatencyAwareUpdateInterval()
|
int |
getLatencyAwareWindowSize()
Latency samples window size for scoring algorithm |
LatencyScoreStrategy |
getLatencyScoreStrategy()
TODO |
int |
getMaxBlockedThreadsPerHost()
Get max number of blocked clients for a host. |
int |
getMaxConns()
Maximum number of connections in the pool, not used by all connection pool implementations |
int |
getMaxConnsPerHost()
Maximum number of connections to allocate for a single host's pool |
int |
getMaxFailoverCount()
Get the max number of failover attempts |
int |
getMaxOperationsPerConnection()
Maximum allowed operations per connections before forcing the connection to close |
int |
getMaxPendingConnectionsPerHost()
Maximum number of pending connect attempts per host |
int |
getMaxTimeoutCount()
Number of allowed timeouts within getTimeoutWindow() milliseconds |
int |
getMaxTimeoutWhenExhausted()
Maximum amount of time to wait for a connection to free up when a connection pool is exhausted. |
String |
getName()
Unique name assigned to this connection pool |
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 |
RetryBackoffStrategy |
getRetryBackoffStrategy()
Return the backoff strategy to use. |
int |
getRetryDelaySlice()
TODO |
int |
getRetryMaxDelaySlice()
TODO |
int |
getRetrySuspendWindow()
TODO |
List<Host> |
getSeedHosts()
Return a list of Host objects from the list of seeds returned by getSeeds(). |
String |
getSeeds()
List of comma delimited host:port combinations. |
int |
getSocketTimeout()
Socket read/write timeout |
int |
getTimeoutWindow()
Shut down a host if it times out too many time within this window |
ConnectionPoolConfigurationImpl |
setBadHostDetector(BadHostDetector badHostDetector)
|
ConnectionPoolConfigurationImpl |
setConnectionLimiterMaxPendingCount(int connectionLimiterMaxPendingCount)
|
ConnectionPoolConfigurationImpl |
setConnectionLimiterWindowSize(int pendingConnectionWindowSize)
|
ConnectionPoolConfigurationImpl |
setConnectTimeout(int connectTimeout)
|
ConnectionPoolConfigurationImpl |
setInitConnsPerHost(int initConns)
|
ConnectionPoolConfigurationImpl |
setLatencyAwareBadnessThreshold(float threshold)
|
ConnectionPoolConfigurationImpl |
setLatencyAwareResetInterval(int latencyAwareResetInterval)
|
ConnectionPoolConfigurationImpl |
setLatencyAwareSentinelCompare(float latencyAwareSentinelCompare)
|
ConnectionPoolConfigurationImpl |
setLatencyAwareUpdateInterval(int latencyAwareUpdateInterval)
|
ConnectionPoolConfigurationImpl |
setLatencyAwareWindowSize(int latencyAwareWindowSize)
|
ConnectionPoolConfigurationImpl |
setLatencyScoreStrategy(LatencyScoreStrategy latencyScoreStrategy)
|
ConnectionPoolConfigurationImpl |
setMaxBlockedThreadsPerHost(int maxBlockedThreadsPerHost)
|
ConnectionPoolConfigurationImpl |
setMaxConns(int maxConns)
|
ConnectionPoolConfigurationImpl |
setMaxConnsPerHost(int maxConns)
|
ConnectionPoolConfigurationImpl |
setMaxFailoverCount(int maxFailoverCount)
|
ConnectionPoolConfigurationImpl |
setMaxOperationsPerConnection(int maxOperationsPerConnection)
|
ConnectionPoolConfigurationImpl |
setMaxPendingConnectionsPerHost(int maxPendingConnectionsPerHost)
|
ConnectionPoolConfigurationImpl |
setMaxTimeoutCount(int maxTimeoutCount)
|
ConnectionPoolConfigurationImpl |
setMaxTimeoutWhenExhausted(int timeout)
|
ConnectionPoolConfigurationImpl |
setPort(int port)
|
ConnectionPoolConfigurationImpl |
setRetryBackoffStrategy(RetryBackoffStrategy hostRetryBackoffStrategy)
|
ConnectionPoolConfigurationImpl |
setRetryDelaySlice(int retryDelaySlice)
|
ConnectionPoolConfigurationImpl |
setRetryMaxDelaySlice(int retryMaxDelaySlice)
|
ConnectionPoolConfigurationImpl |
setRetrySuspendWindow(int retrySuspendWindow)
|
ConnectionPoolConfigurationImpl |
setSeeds(String seeds)
|
ConnectionPoolConfigurationImpl |
setSocketTimeout(int socketTimeout)
|
ConnectionPoolConfigurationImpl |
setTimeoutWindow(int timeoutWindow)
|
String |
toString()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
public static final int DEFAULT_MAX_TIME_WHEN_EXHAUSTED
public static final int DEFAULT_SOCKET_TIMEOUT
public static final int DEFAULT_CONNECT_TIMEOUT
public static final int DEFAULT_MAX_ACTIVE_PER_PARTITION
public static final int DEFAULT_INIT_PER_PARTITION
public static final int DEFAULT_PORT
public static final int DEFAULT_FAILOVER_COUNT
public static final int DEFAULT_FAILOVER_WAIT_TIME
public static final int DEFAULT_MAX_CONNS
public static final int DEFAULT_LATENCY_AWARE_WINDOW_SIZE
public static final float DEFAULT_LATENCY_AWARE_SENTINEL_COMPARE
public static final int DEFAULT_LATENCY_AWARE_UPDATE_INTERVAL
public static final int DEFAULT_LATENCY_AWARE_RESET_INTERVAL
public static final float DEFAULT_LATENCY_AWARE_BADNESS_THRESHOLD
public static final int DEFAULT_CONNECTION_LIMITER_WINDOW_SIZE
public static final int DEFAULT_CONNECTION_LIMITER_MAX_PENDING_COUNT
public static final int DEFAULT_MAX_WAIT_FOR_PENDING_CONNECTION
public static final int DEFAULT_MAX_PENDING_CONNECTIONS_PER_HOST
public static final int DEFAULT_MAX_BLOCKED_THREADS_PER_HOST
public static final int DEFAULT_MAX_TIMEOUT_COUNT
public static final int DEFAULT_TIMEOUT_WINDOW
public static final int DEFAULT_RETRY_SUSPEND_WINDOW
public static final int DEFAULT_RETRY_DELAY_SLICE
public static final int DEFAULT_RETRY_MAX_DELAY_SLICE
public static final int DEFAULT_MAX_OPERATIONS_PER_CONNECTION
public static final BadHostDetector DEFAULT_BAD_HOST_DETECTOR
Constructor Detail |
---|
public ConnectionPoolConfigurationImpl(String name)
Method Detail |
---|
public String getName()
ConnectionPoolConfiguration
getName
in interface ConnectionPoolConfiguration
public int getSocketTimeout()
ConnectionPoolConfiguration
getSocketTimeout
in interface ConnectionPoolConfiguration
public ConnectionPoolConfigurationImpl setSocketTimeout(int socketTimeout)
public int getConnectTimeout()
ConnectionPoolConfiguration
getConnectTimeout
in interface ConnectionPoolConfiguration
public ConnectionPoolConfigurationImpl setConnectTimeout(int connectTimeout)
public String getSeeds()
ConnectionPoolConfiguration
getSeeds
in interface ConnectionPoolConfiguration
public ConnectionPoolConfigurationImpl setSeeds(String seeds)
public int getMaxTimeoutWhenExhausted()
ConnectionPoolConfiguration
getMaxTimeoutWhenExhausted
in interface ConnectionPoolConfiguration
public ConnectionPoolConfigurationImpl setMaxTimeoutWhenExhausted(int timeout)
public int getPort()
ConnectionPoolConfiguration
getPort
in interface ConnectionPoolConfiguration
public ConnectionPoolConfigurationImpl setPort(int port)
public int getMaxConnsPerHost()
ConnectionPoolConfiguration
getMaxConnsPerHost
in interface ConnectionPoolConfiguration
public ConnectionPoolConfigurationImpl setMaxConnsPerHost(int maxConns)
public int getInitConnsPerHost()
ConnectionPoolConfiguration
getInitConnsPerHost
in interface ConnectionPoolConfiguration
public ConnectionPoolConfigurationImpl setInitConnsPerHost(int initConns)
public RetryBackoffStrategy getRetryBackoffStrategy()
ConnectionPoolConfiguration
getRetryBackoffStrategy
in interface ConnectionPoolConfiguration
RetryBackoffStrategy
public ConnectionPoolConfigurationImpl setRetryBackoffStrategy(RetryBackoffStrategy hostRetryBackoffStrategy)
public List<Host> getSeedHosts()
ConnectionPoolConfiguration
getSeedHosts
in interface ConnectionPoolConfiguration
public int getMaxFailoverCount()
ConnectionPoolConfiguration
getMaxFailoverCount
in interface ConnectionPoolConfiguration
public ConnectionPoolConfigurationImpl setMaxFailoverCount(int maxFailoverCount)
public int getMaxConns()
ConnectionPoolConfiguration
getMaxConns
in interface ConnectionPoolConfiguration
public ConnectionPoolConfigurationImpl setMaxConns(int maxConns)
public int getLatencyAwareWindowSize()
ConnectionPoolConfiguration
getLatencyAwareWindowSize
in interface ConnectionPoolConfiguration
public ConnectionPoolConfigurationImpl setLatencyAwareWindowSize(int latencyAwareWindowSize)
public float getLatencyAwareSentinelCompare()
ConnectionPoolConfiguration
getLatencyAwareSentinelCompare
in interface ConnectionPoolConfiguration
public ConnectionPoolConfigurationImpl setLatencyAwareSentinelCompare(float latencyAwareSentinelCompare)
public float getLatencyAwareBadnessThreshold()
ConnectionPoolConfiguration
getLatencyAwareBadnessThreshold
in interface ConnectionPoolConfiguration
public ConnectionPoolConfigurationImpl setLatencyAwareBadnessThreshold(float threshold)
public int getConnectionLimiterWindowSize()
ConnectionPoolConfiguration
getConnectionLimiterWindowSize
in interface ConnectionPoolConfiguration
public ConnectionPoolConfigurationImpl setConnectionLimiterWindowSize(int pendingConnectionWindowSize)
public int getConnectionLimiterMaxPendingCount()
ConnectionPoolConfiguration
getConnectionLimiterMaxPendingCount
in interface ConnectionPoolConfiguration
public ConnectionPoolConfigurationImpl setConnectionLimiterMaxPendingCount(int connectionLimiterMaxPendingCount)
public int getMaxPendingConnectionsPerHost()
ConnectionPoolConfiguration
getMaxPendingConnectionsPerHost
in interface ConnectionPoolConfiguration
public ConnectionPoolConfigurationImpl setMaxPendingConnectionsPerHost(int maxPendingConnectionsPerHost)
public int getMaxBlockedThreadsPerHost()
ConnectionPoolConfiguration
getMaxBlockedThreadsPerHost
in interface ConnectionPoolConfiguration
public ConnectionPoolConfigurationImpl setMaxBlockedThreadsPerHost(int maxBlockedThreadsPerHost)
public int getTimeoutWindow()
ConnectionPoolConfiguration
getTimeoutWindow
in interface ConnectionPoolConfiguration
public ConnectionPoolConfigurationImpl setTimeoutWindow(int timeoutWindow)
public int getMaxTimeoutCount()
ConnectionPoolConfiguration
getMaxTimeoutCount
in interface ConnectionPoolConfiguration
public ConnectionPoolConfigurationImpl setMaxTimeoutCount(int maxTimeoutCount)
public int getLatencyAwareUpdateInterval()
getLatencyAwareUpdateInterval
in interface ConnectionPoolConfiguration
public ConnectionPoolConfigurationImpl setLatencyAwareUpdateInterval(int latencyAwareUpdateInterval)
public int getLatencyAwareResetInterval()
getLatencyAwareResetInterval
in interface ConnectionPoolConfiguration
public ConnectionPoolConfigurationImpl setLatencyAwareResetInterval(int latencyAwareResetInterval)
public int getRetrySuspendWindow()
ConnectionPoolConfiguration
getRetrySuspendWindow
in interface ConnectionPoolConfiguration
public ConnectionPoolConfigurationImpl setRetrySuspendWindow(int retrySuspendWindow)
public int getMaxOperationsPerConnection()
ConnectionPoolConfiguration
getMaxOperationsPerConnection
in interface ConnectionPoolConfiguration
public ConnectionPoolConfigurationImpl setMaxOperationsPerConnection(int maxOperationsPerConnection)
public LatencyScoreStrategy getLatencyScoreStrategy()
ConnectionPoolConfiguration
getLatencyScoreStrategy
in interface ConnectionPoolConfiguration
public ConnectionPoolConfigurationImpl setLatencyScoreStrategy(LatencyScoreStrategy latencyScoreStrategy)
public BadHostDetector getBadHostDetector()
ConnectionPoolConfiguration
getBadHostDetector
in interface ConnectionPoolConfiguration
public ConnectionPoolConfigurationImpl setBadHostDetector(BadHostDetector badHostDetector)
public int getRetryMaxDelaySlice()
ConnectionPoolConfiguration
getRetryMaxDelaySlice
in interface ConnectionPoolConfiguration
public ConnectionPoolConfigurationImpl setRetryMaxDelaySlice(int retryMaxDelaySlice)
public int getRetryDelaySlice()
ConnectionPoolConfiguration
getRetryDelaySlice
in interface ConnectionPoolConfiguration
public ConnectionPoolConfigurationImpl setRetryDelaySlice(int retryDelaySlice)
public String toString()
toString
in class Object
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |