|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use HostConnectionPool | |
---|---|
com.netflix.astyanax.connectionpool | |
com.netflix.astyanax.connectionpool.impl | |
com.netflix.astyanax.shallows | |
com.netflix.astyanax.thrift |
Uses of HostConnectionPool in com.netflix.astyanax.connectionpool |
---|
Methods in com.netflix.astyanax.connectionpool that return HostConnectionPool | |
---|---|
HostConnectionPool<CL> |
Connection.getHostConnectionPool()
Get the parent host connection pool. |
HostConnectionPool<CL> |
ConnectionPool.getHostPool(Host host)
Return an immutable connection pool for this host |
HostConnectionPool<?> |
HostStats.getPool()
|
Methods in com.netflix.astyanax.connectionpool that return types with arguments of type HostConnectionPool | ||
---|---|---|
List<HostConnectionPool<CL>> |
ConnectionPool.getActivePools()
Return list of active hosts on which connections can be created |
|
|
LatencyScoreStrategy.sortAndfilterPartition(List<HostConnectionPool<CL>> pools,
AtomicBoolean prioritized)
Sorts and filters a list of hosts by looking at their up state and score. |
Methods in com.netflix.astyanax.connectionpool with parameters of type HostConnectionPool | |
---|---|
Connection<CL> |
ConnectionFactory.createConnection(HostConnectionPool<CL> pool)
|
void |
ConnectionPoolMonitor.onHostAdded(Host host,
HostConnectionPool<?> pool)
A host was added and given the associated pool. |
void |
ConnectionPoolMonitor.onHostReactivated(Host host,
HostConnectionPool<?> pool)
A host was reactivated after being marked down |
void |
HostStats.setPool(HostConnectionPool<?> pool)
|
Method parameters in com.netflix.astyanax.connectionpool with type arguments of type HostConnectionPool | ||
---|---|---|
|
LatencyScoreStrategy.sortAndfilterPartition(List<HostConnectionPool<CL>> pools,
AtomicBoolean prioritized)
Sorts and filters a list of hosts by looking at their up state and score. |
Uses of HostConnectionPool in com.netflix.astyanax.connectionpool.impl |
---|
Classes in com.netflix.astyanax.connectionpool.impl that implement HostConnectionPool | |
---|---|
class |
SimpleHostConnectionPool<CL>
Pool of connections for a single host. |
Fields in com.netflix.astyanax.connectionpool.impl declared as HostConnectionPool | |
---|---|
protected HostConnectionPool<CL> |
RoundRobinExecuteWithFailover.pool
|
Fields in com.netflix.astyanax.connectionpool.impl with type parameters of type HostConnectionPool | |
---|---|
protected org.cliffc.high_scale_lib.NonBlockingHashMap<Host,HostConnectionPool<CL>> |
AbstractHostPartitionConnectionPool.hosts
|
protected List<HostConnectionPool<CL>> |
RoundRobinExecuteWithFailover.pools
|
Methods in com.netflix.astyanax.connectionpool.impl that return HostConnectionPool | |
---|---|
HostConnectionPool<CL> |
RoundRobinExecuteWithFailover.getCurrentHostConnectionPool()
|
abstract HostConnectionPool<CL> |
AbstractExecuteWithFailoverImpl.getCurrentHostConnectionPool()
|
HostConnectionPool<CL> |
AbstractHostPartitionConnectionPool.getHostPool(Host host)
|
protected HostConnectionPool<CL> |
AbstractHostPartitionConnectionPool.newHostConnectionPool(Host host,
ConnectionFactory<CL> factory,
ConnectionPoolConfiguration config)
|
Methods in com.netflix.astyanax.connectionpool.impl that return types with arguments of type HostConnectionPool | ||
---|---|---|
List<HostConnectionPool<CL>> |
AbstractHostPartitionConnectionPool.getActivePools()
|
|
List<HostConnectionPool<CL>> |
HostConnectionPoolPartition.getPools()
|
|
|
SmaLatencyScoreStrategyImpl.sortAndfilterPartition(List<HostConnectionPool<CL>> srcPools,
AtomicBoolean prioritized)
|
Methods in com.netflix.astyanax.connectionpool.impl with parameters of type HostConnectionPool | |
---|---|
void |
Topology.addPool(HostConnectionPool<CL> pool)
Add a pool without knowing it's token. |
void |
TokenPartitionedTopology.addPool(HostConnectionPool<CL> pool)
|
boolean |
HostConnectionPoolPartition.addPool(HostConnectionPool<CL> pool)
|
void |
Slf4jConnectionPoolMonitorImpl.onHostAdded(Host host,
HostConnectionPool<?> pool)
|
void |
CountingConnectionPoolMonitor.onHostAdded(Host host,
HostConnectionPool<?> pool)
|
void |
SimpleHostConnectionPool.Listener.onHostDown(HostConnectionPool<CL> pool)
|
void |
AbstractHostPartitionConnectionPool.onHostDown(HostConnectionPool<CL> pool)
|
void |
Slf4jConnectionPoolMonitorImpl.onHostReactivated(Host host,
HostConnectionPool<?> pool)
|
void |
CountingConnectionPoolMonitor.onHostReactivated(Host host,
HostConnectionPool<?> pool)
|
void |
SimpleHostConnectionPool.Listener.onHostUp(HostConnectionPool<CL> pool)
|
void |
AbstractHostPartitionConnectionPool.onHostUp(HostConnectionPool<CL> pool)
|
void |
Topology.removePool(HostConnectionPool<CL> pool)
Remove this pool from all partitions |
void |
TokenPartitionedTopology.removePool(HostConnectionPool<CL> pool)
|
boolean |
HostConnectionPoolPartition.removePool(HostConnectionPool<CL> pool)
|
void |
Topology.resumePool(HostConnectionPool<CL> pool)
Resume a host that was previously down |
void |
TokenPartitionedTopology.resumePool(HostConnectionPool<CL> pool)
|
void |
Topology.suspendPool(HostConnectionPool<CL> pool)
Suspend a host that is down |
void |
TokenPartitionedTopology.suspendPool(HostConnectionPool<CL> pool)
|
Method parameters in com.netflix.astyanax.connectionpool.impl with type arguments of type HostConnectionPool | ||
---|---|---|
boolean |
HostConnectionPoolPartition.setPools(Collection<HostConnectionPool<CL>> pools)
Sets all pools for this partition. |
|
boolean |
Topology.setPools(Map<BigInteger,Collection<HostConnectionPool<CL>>> ring)
Refresh the internal topology structure |
|
boolean |
TokenPartitionedTopology.setPools(Map<BigInteger,Collection<HostConnectionPool<CL>>> ring)
|
|
|
SmaLatencyScoreStrategyImpl.sortAndfilterPartition(List<HostConnectionPool<CL>> srcPools,
AtomicBoolean prioritized)
|
Constructor parameters in com.netflix.astyanax.connectionpool.impl with type arguments of type HostConnectionPool | |
---|---|
RoundRobinExecuteWithFailover(ConnectionPoolConfiguration config,
ConnectionPoolMonitor monitor,
List<HostConnectionPool<CL>> pools,
int index)
|
Uses of HostConnectionPool in com.netflix.astyanax.shallows |
---|
Methods in com.netflix.astyanax.shallows that return types with arguments of type HostConnectionPool | ||
---|---|---|
|
EmptyLatencyScoreStrategyImpl.sortAndfilterPartition(List<HostConnectionPool<CL>> pools,
AtomicBoolean prioritized)
|
Methods in com.netflix.astyanax.shallows with parameters of type HostConnectionPool | |
---|---|
void |
EmptyConnectionPoolMonitor.onHostAdded(Host host,
HostConnectionPool<?> pool)
|
void |
EmptyConnectionPoolMonitor.onHostReactivated(Host host,
HostConnectionPool<?> pool)
|
Method parameters in com.netflix.astyanax.shallows with type arguments of type HostConnectionPool | ||
---|---|---|
|
EmptyLatencyScoreStrategyImpl.sortAndfilterPartition(List<HostConnectionPool<CL>> pools,
AtomicBoolean prioritized)
|
Uses of HostConnectionPool in com.netflix.astyanax.thrift |
---|
Methods in com.netflix.astyanax.thrift with parameters of type HostConnectionPool | |
---|---|
Connection<org.apache.cassandra.thrift.Cassandra.Client> |
ThriftSyncConnectionFactoryImpl.createConnection(HostConnectionPool<org.apache.cassandra.thrift.Cassandra.Client> pool)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |