TokenAwareConnectionPoolImpl

Class Overview

Connection pool that partitions connections by the hosts which own the token being operated on. When a token is not available or an operation is known to span multiple tokens (such as a batch mutate or an index query) host pools are picked using round robin. This implementation takes an optimistic approach which is optimized for a well functioning ring with all nodes up and keeps downed hosts in the internal data structures.

Summary

[Expand] Inherited Fields
From class com.netflix.astyanax.connectionpool.impl.AbstractHostPartitionConnectionPool protected final ConnectionPoolConfiguration config protected final ConnectionFactory<CL> factory protected final hosts protected final ConnectionPoolMonitor monitor protected final Topology<CL> topology

[Expand] Inherited Methods
From class com.netflix.astyanax.connectionpool.impl.AbstractHostPartitionConnectionPool final boolean addHost(Host host, boolean refresh) Add a host to the connection pool. <R> OperationResult<R> executeWithFailover(Operation<CL, R> op, RetryPolicy retry) Execute an operation with failover within the context of the connection pool. List<HostConnectionPool<CL>> getActivePools() Return list of active hosts on which connections can be created HostConnectionPool<CL> getHostPool(Host host) Return an immutable connection pool for this host boolean hasHost(Host host) Return true if host is contained within the connection pool boolean isHostUp(Host host) Return true if the host is up abstract <R> ExecuteWithFailover<CL, R> newExecuteWithFailover(Operation<CL, R> op) Return a new failover context. HostConnectionPool<CL> newHostConnectionPool(Host host, ConnectionFactory<CL> factory, ConnectionPoolConfiguration config) void onHostDown(HostConnectionPool<CL> pool) void onHostUp(HostConnectionPool<CL> pool) void rebuildPartitions() Called every time a host is added, removed or is marked as down boolean removeHost(Host host, boolean refresh) Remove a host from the connection pool. synchronized void setHosts(Map<BigInteger, List<Host>> ring) Sets the complete set of hosts keyed by token. void shutdown() Shut down the connection pool and terminate all existing connections void start() Setup the connection pool and start any maintenance threads
From class java.lang.Object Object clone() boolean equals(Object arg0) void finalize() final Class<?> getClass() int hashCode() final void notify() final void notifyAll() String toString() final void wait() final void wait(long arg0, int arg1) final void wait(long arg0)
From interface com.netflix.astyanax.connectionpool.ConnectionPool abstract boolean addHost(Host host, boolean refresh) Add a host to the connection pool. abstract <R> OperationResult<R> executeWithFailover(Operation<CL, R> op, RetryPolicy retry) Execute an operation with failover within the context of the connection pool. abstract List<HostConnectionPool<CL>> getActivePools() Return list of active hosts on which connections can be created abstract HostConnectionPool<CL> getHostPool(Host host) Return an immutable connection pool for this host abstract boolean hasHost(Host host) Return true if host is contained within the connection pool abstract boolean isHostUp(Host host) Return true if the host is up abstract boolean removeHost(Host host, boolean refresh) Remove a host from the connection pool. abstract void setHosts(Map<BigInteger, List<Host>> ring) Sets the complete set of hosts keyed by token. abstract void shutdown() Shut down the connection pool and terminate all existing connections abstract void start() Setup the connection pool and start any maintenance threads
From interface com.netflix.astyanax.connectionpool.impl.SimpleHostConnectionPool.Listener abstract void onHostDown(HostConnectionPool<CL> pool) abstract void onHostUp(HostConnectionPool<CL> pool)