Class TopologyInfo


  • public final class TopologyInfo
    extends Object
    Maintains topology information about caches.
    Author:
    gustavonalle
    • Method Detail

      • getServers

        public Collection<SocketAddress> getServers​(org.infinispan.commons.marshall.WrappedByteArray cacheName)
      • 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)
      • isTopologyValid

        public boolean isTopologyValid​(byte[] cacheName)
      • getConsistentHash

        public ConsistentHash getConsistentHash​(byte[] cacheName)
      • 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)