org.infinispan.topology

Interface ClusterTopologyManager

All Known Implementing Classes:

ClusterTopologyManagerImpl

public interface ClusterTopologyManager

Maintains the list of members and performs rebalance operations. The RebalancePolicy actually decides when to perform the rebalance or how to update the consistent hash.

Since:

5.2

Author:

Dan Berindei

Method Summary

Methods

Modifier and Type	Method and Description
CacheTopology	handleJoin(String cacheName, Address joiner, CacheJoinInfo joinInfo, int viewId) Updates the members list and notifies the RebalancePolicy.
void	handleLeave(String cacheName, Address leaver, int viewId) Updates the members list and notifies the RebalancePolicy
void	handleRebalanceCompleted(String cacheName, Address node, int topologyId, Throwable throwable, int viewId) Marks the rebalance as complete on the sender.
void	triggerRebalance(String cacheName) Used by RebalancePolicy to start a state transfer.

Method Detail

triggerRebalance

void triggerRebalance(String cacheName)
                      throws Exception

Used by RebalancePolicy to start a state transfer.

Throws:

Exception

handleJoin

CacheTopology handleJoin(String cacheName,
                       Address joiner,
                       CacheJoinInfo joinInfo,
                       int viewId)
                         throws Exception

Updates the members list and notifies the RebalancePolicy.

Returns:

The current consistent hash.

Throws:

Exception

handleLeave

void handleLeave(String cacheName,
               Address leaver,
               int viewId)
                 throws Exception

Updates the members list and notifies the RebalancePolicy

Throws:

Exception

handleRebalanceCompleted

void handleRebalanceCompleted(String cacheName,
                            Address node,
                            int topologyId,
                            Throwable throwable,
                            int viewId)
                              throws Exception

Marks the rebalance as complete on the sender.

Throws:

Exception