Class TopologyInfo
- java.lang.Object
-
- org.infinispan.client.hotrod.impl.TopologyInfo
-
public final class TopologyInfo extends Object
Maintains topology information about caches.- Author:
- gustavonalle
-
-
Constructor Summary
Constructors Constructor Description TopologyInfo(AtomicInteger topologyId, Collection<SocketAddress> initialServers, Configuration configuration)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description AtomicInteger
createTopologyId(byte[] cacheName, int topologyId)
CacheTopologyInfo
getCacheTopologyInfo(byte[] cacheName)
ConsistentHash
getConsistentHash(byte[] cacheName)
ConsistentHashFactory
getConsistentHashFactory()
Optional<SocketAddress>
getHashAwareServer(Object key, byte[] cacheName)
Collection<SocketAddress>
getServers()
Collection<SocketAddress>
getServers(org.infinispan.commons.marshall.WrappedByteArray cacheName)
int
getTopologyId(byte[] cacheName)
boolean
isTopologyValid(byte[] cacheName)
void
setAllTopologyIds(int newTopologyId)
void
setTopologyId(byte[] cacheName, int topologyId)
void
updateServers(byte[] cacheName, Collection<SocketAddress> updatedServers)
void
updateTopology(SocketAddress[][] segmentOwners, int numSegments, short hashFunctionVersion, byte[] cacheName, AtomicInteger topologyId)
void
updateTopology(Map<SocketAddress,Set<Integer>> servers2Hash, int numKeyOwners, short hashFunctionVersion, int hashSpace, byte[] cacheName, AtomicInteger topologyId)
-
-
-
Constructor Detail
-
TopologyInfo
public TopologyInfo(AtomicInteger topologyId, Collection<SocketAddress> initialServers, Configuration configuration)
-
-
Method Detail
-
getServers
public Collection<SocketAddress> getServers(org.infinispan.commons.marshall.WrappedByteArray cacheName)
-
getServers
public Collection<SocketAddress> getServers()
-
updateTopology
public void updateTopology(Map<SocketAddress,Set<Integer>> servers2Hash, int numKeyOwners, short hashFunctionVersion, int hashSpace, byte[] cacheName, AtomicInteger topologyId)
-
updateTopology
public void updateTopology(SocketAddress[][] segmentOwners, int numSegments, short hashFunctionVersion, byte[] cacheName, AtomicInteger topologyId)
-
getHashAwareServer
public Optional<SocketAddress> getHashAwareServer(Object key, byte[] cacheName)
-
isTopologyValid
public boolean isTopologyValid(byte[] cacheName)
-
updateServers
public void updateServers(byte[] cacheName, Collection<SocketAddress> updatedServers)
-
getConsistentHash
public ConsistentHash getConsistentHash(byte[] cacheName)
-
getConsistentHashFactory
public ConsistentHashFactory getConsistentHashFactory()
-
createTopologyId
public AtomicInteger createTopologyId(byte[] cacheName, int topologyId)
-
setTopologyId
public void setTopologyId(byte[] cacheName, int topologyId)
-
setAllTopologyIds
public void setAllTopologyIds(int newTopologyId)
-
getTopologyId
public int getTopologyId(byte[] cacheName)
-
getCacheTopologyInfo
public CacheTopologyInfo getCacheTopologyInfo(byte[] cacheName)
-
-