public interface

Topology

com.netflix.astyanax.connectionpool.impl.Topology<CL>
Known Indirect Subclasses

Summary

Public Methods
abstract void addPool(HostConnectionPool<CL> pool)
Add a pool without knowing it's token.
abstract HostConnectionPoolPartition<CL> getAllPools()
Return a partition that represents all hosts in the ring
abstract HostConnectionPoolPartition<CL> getPartition(BigInteger token)
Search for the partition that owns this token
abstract int getPartitionCount()
Get total number of tokens in the topology
abstract void refresh()
Refresh the internal state and apply the latency score strategy
abstract void removePool(HostConnectionPool<CL> pool)
Remove this pool from all partitions
abstract void resumePool(HostConnectionPool<CL> pool)
Resume a host that was previously down
abstract boolean setPools(Map<BigIntegerCollection<HostConnectionPool<CL>>> ring)
Refresh the internal topology structure
abstract void suspendPool(HostConnectionPool<CL> pool)
Suspend a host that is down

Public Methods

public abstract void addPool (HostConnectionPool<CL> pool)

Add a pool without knowing it's token. This pool will be added to the all pools partition only

public abstract HostConnectionPoolPartition<CL> getAllPools ()

Return a partition that represents all hosts in the ring

public abstract HostConnectionPoolPartition<CL> getPartition (BigInteger token)

Search for the partition that owns this token

public abstract int getPartitionCount ()

Get total number of tokens in the topology

public abstract void refresh ()

Refresh the internal state and apply the latency score strategy

public abstract void removePool (HostConnectionPool<CL> pool)

Remove this pool from all partitions

public abstract void resumePool (HostConnectionPool<CL> pool)

Resume a host that was previously down

public abstract boolean setPools (Map<BigIntegerCollection<HostConnectionPool<CL>>> ring)

Refresh the internal topology structure

public abstract void suspendPool (HostConnectionPool<CL> pool)

Suspend a host that is down