Interface CacheTopologyHandler

public interface CacheTopologyHandler
The link between LocalTopologyManager and StateTransferManager.
Since:
5.2
Author:
Dan Berindei

  • Method Details

    • updateConsistentHash

      CompletionStage<Void> updateConsistentHash(CacheTopology cacheTopology)
      Invoked when the CH has to be immediately updated because of a leave or when the state transfer has completed and we have to install a permanent CH (pendingCH == null). A state transfer is not always required.

    • rebalance

      CompletionStage<Void> rebalance(CacheTopology cacheTopology)
      Invoked when state transfer has to be started. The caller will not consider the local rebalance done when this method returns. Instead, the handler will have to call LocalTopologyManager.confirmRebalancePhase(String, int, int, Throwable)

    • onTopologyReceived

      void onTopologyReceived(CacheTopology cacheTopology)
      Invoked when a topology is received.

      Invokes the listener every time a new topology is received. The topology might have a pending consistent hash, or it might already be stable.

      Parameters:
      cacheTopology - The received cache topology.