Package org.infinispan.client.hotrod.impl

Class TopologyInfo

java.lang.Object

org.infinispan.client.hotrod.impl.TopologyInfo

@NotThreadSafe
public final class TopologyInfo
extends Object

Maintains topology information about caches.

Author:

gustavonalle, Dan Berindei

Constructor Summary

Constructors

Constructor	Description
TopologyInfo(Configuration configuration, ClusterInfo clusterInfo)

Method Summary

Modifier and Type	Method	Description
SegmentConsistentHash	createConsistentHash(int numSegments, short hashFunctionVersion, SocketAddress[][] segmentOwners)
void	forEachCache(BiConsumer<WrappedBytes,CacheInfo> action)
Collection<InetSocketAddress>	getAllServers()
CacheInfo	getCacheInfo(WrappedBytes cacheName)
CacheTopologyInfo	getCacheTopologyInfo(byte[] cacheName)
ClusterInfo	getCluster()
ConsistentHashFactory	getConsistentHashFactory()
CacheInfo	getOrCreateCacheInfo(WrappedBytes cacheName)
Map<SocketAddress,Set<Integer>>	getPrimarySegmentsByServer(byte[] cacheName)
List<InetSocketAddress>	getServers(WrappedBytes cacheName)
int	getTopologyAge()
void	reset(WrappedBytes cacheName)	Reset a single ache to the initial server list.
void	switchCluster(ClusterInfo newCluster)	Switch to another cluster and update the topologies of all caches with its initial server list.
void	updateCacheInfo(WrappedBytes cacheName, CacheInfo oldCacheInfo, CacheInfo newCacheInfo)

Methods inherited from class java.lang.Object

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

Constructor Details

TopologyInfo

public TopologyInfo(Configuration configuration,
 ClusterInfo clusterInfo)

Method Details

getPrimarySegmentsByServer

public Map<SocketAddress,Set<Integer>> getPrimarySegmentsByServer(byte[] cacheName)

getServers

public List<InetSocketAddress> getServers(WrappedBytes cacheName)

getAllServers

public Collection<InetSocketAddress> getAllServers()

createConsistentHash

public SegmentConsistentHash createConsistentHash(int numSegments,
 short hashFunctionVersion,
 SocketAddress[][] segmentOwners)

getConsistentHashFactory

public ConsistentHashFactory getConsistentHashFactory()

getCacheTopologyInfo

public CacheTopologyInfo getCacheTopologyInfo(byte[] cacheName)

getCacheInfo

public CacheInfo getCacheInfo(WrappedBytes cacheName)

getOrCreateCacheInfo

public CacheInfo getOrCreateCacheInfo(WrappedBytes cacheName)

switchCluster

public void switchCluster(ClusterInfo newCluster)

Switch to another cluster and update the topologies of all caches with its initial server list.

reset

public void reset(WrappedBytes cacheName)

Reset a single ache to the initial server list.

Useful if there are still live servers in the cluster, but all the server in this cache's current topology are unreachable.

getCluster

public ClusterInfo getCluster()

getTopologyAge

public int getTopologyAge()

updateCacheInfo

public void updateCacheInfo(WrappedBytes cacheName,
 CacheInfo oldCacheInfo,
 CacheInfo newCacheInfo)

forEachCache

public void forEachCache(BiConsumer<WrappedBytes,CacheInfo> action)