com.netflix.astyanax.connectionpool

Class ConnectionPoolProxy<T>

java.lang.Object

com.netflix.astyanax.connectionpool.ConnectionPoolProxy<T>

All Implemented Interfaces:

ConnectionPool<T>

public class ConnectionPoolProxy<T>
extends java.lang.Object
implements ConnectionPool<T>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ConnectionPoolProxy.SeedHostListener

Constructor Summary

Constructors

Constructor and Description
ConnectionPoolProxy(ConnectionPoolConfiguration cpConfig, ConnectionFactory<T> connectionFactory, ConnectionPoolMonitor monitor)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	addHost(Host host, boolean refresh) Add a host to the connection pool.
void	addListener(ConnectionPoolProxy.SeedHostListener listener)
<R> OperationResult<R>	executeWithFailover(Operation<T,R> op, RetryPolicy retry) Execute an operation with failover within the context of the connection pool.
java.util.List<HostConnectionPool<T>>	getActivePools()
ConnectionPoolConfiguration	getConnectionPoolConfiguration()
ConnectionPoolMonitor	getConnectionPoolMonitor()
HostConnectionPool<T>	getHostPool(Host host)
java.util.Collection<Host>	getHosts()
Partitioner	getPartitioner()
java.util.List<HostConnectionPool<T>>	getPools()
Topology<T>	getTopology()
boolean	hasHost(Host host)
boolean	isHostUp(Host host)
boolean	removeHost(Host host, boolean refresh) Remove a host from the connection pool.
void	setHosts(java.util.Collection<Host> hosts) Set the complete set of hosts in the ring
void	shutdown() Shut down the connection pool and terminate all existing connections
void	start() Setup the connection pool and start any maintenance threads

Methods inherited from class java.lang.Object

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

Constructor Detail

ConnectionPoolProxy

public ConnectionPoolProxy(ConnectionPoolConfiguration cpConfig,
                   ConnectionFactory<T> connectionFactory,
                   ConnectionPoolMonitor monitor)

Method Detail

getConnectionPoolConfiguration

public ConnectionPoolConfiguration getConnectionPoolConfiguration()

getConnectionPoolMonitor

public ConnectionPoolMonitor getConnectionPoolMonitor()

setHosts

public void setHosts(java.util.Collection<Host> hosts)

Description copied from interface: ConnectionPool

Set the complete set of hosts in the ring

Specified by:

setHosts in interface ConnectionPool<T>

getHosts

public java.util.Collection<Host> getHosts()

addListener

public void addListener(ConnectionPoolProxy.SeedHostListener listener)

addHost

public boolean addHost(Host host,
              boolean refresh)

Description copied from interface: ConnectionPool

Add a host to the connection pool.

Specified by:

addHost in interface ConnectionPool<T>

removeHost

public boolean removeHost(Host host,
                 boolean refresh)

Description copied from interface: ConnectionPool

Remove a host from the connection pool. Any pending connections will be allowed to complete

Specified by:

removeHost in interface ConnectionPool<T>

isHostUp

public boolean isHostUp(Host host)

Specified by:

isHostUp in interface ConnectionPool<T>

Returns:

Return true if the host is up

hasHost

public boolean hasHost(Host host)

Specified by:

hasHost in interface ConnectionPool<T>

Returns:

Return true if host is contained within the connection pool

getActivePools

public java.util.List<HostConnectionPool<T>> getActivePools()

Specified by:

getActivePools in interface ConnectionPool<T>

Returns:

Return list of active hosts on which connections can be created

getPools

public java.util.List<HostConnectionPool<T>> getPools()

Specified by:

getPools in interface ConnectionPool<T>

Returns:

Get all pools

getHostPool

public HostConnectionPool<T> getHostPool(Host host)

Specified by:

getHostPool in interface ConnectionPool<T>

Returns:

Return an immutable connection pool for this host

executeWithFailover

public <R> OperationResult<R> executeWithFailover(Operation<T,R> op,
                                         RetryPolicy retry)
                                       throws ConnectionException,
                                              OperationException

Description copied from interface: ConnectionPool

Execute an operation with failover within the context of the connection pool. The operation will only fail over for connection pool errors and not application errors.

Specified by:

executeWithFailover in interface ConnectionPool<T>

Throws:

ConnectionException

OperationException

shutdown

public void shutdown()

Description copied from interface: ConnectionPool

Shut down the connection pool and terminate all existing connections

Specified by:

shutdown in interface ConnectionPool<T>

start

public void start()

Description copied from interface: ConnectionPool

Setup the connection pool and start any maintenance threads

Specified by:

start in interface ConnectionPool<T>

getTopology

public Topology<T> getTopology()

Specified by:

getTopology in interface ConnectionPool<T>

Returns:

Return the internal topology which represents the partitioning of data across hosts in the pool

getPartitioner

public Partitioner getPartitioner()

Specified by:

getPartitioner in interface ConnectionPool<T>

Returns:

Return the partitioner used by this pool.