public class ClusterTopologyManagerImpl extends Object implements ClusterTopologyManager
ClusterTopologyManager
implementation.Modifier and Type | Class and Description |
---|---|
class |
ClusterTopologyManagerImpl.ClusterViewListener |
Constructor and Description |
---|
ClusterTopologyManagerImpl() |
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 |
protected void |
handleNewView(List<Address> ignored,
boolean mergeView,
int newViewId) |
void |
handleRebalanceCompleted(String cacheName,
Address node,
int topologyId,
Throwable throwable,
int viewId)
Marks the rebalance as complete on the sender.
|
void |
inject(Transport transport,
RebalancePolicy rebalancePolicy,
ExecutorService asyncTransportExecutor,
GlobalConfiguration globalConfiguration,
GlobalComponentRegistry gcr,
CacheManagerNotifier cacheManagerNotifier) |
void |
start() |
void |
stop() |
void |
triggerRebalance(String cacheName)
Used by
RebalancePolicy to start a state transfer. |
void |
updateCacheStatusAfterMerge(String cacheName,
List<Address> clusterMembers,
List<CacheTopology> partitionTopologies) |
void |
updateClusterMembers(List<Address> newClusterMembers) |
public void inject(Transport transport, RebalancePolicy rebalancePolicy, ExecutorService asyncTransportExecutor, GlobalConfiguration globalConfiguration, GlobalComponentRegistry gcr, CacheManagerNotifier cacheManagerNotifier)
public void start()
public void stop()
public void triggerRebalance(String cacheName)
ClusterTopologyManager
RebalancePolicy
to start a state transfer.triggerRebalance
in interface ClusterTopologyManager
public CacheTopology handleJoin(String cacheName, Address joiner, CacheJoinInfo joinInfo, int viewId) throws Exception
ClusterTopologyManager
RebalancePolicy
.handleJoin
in interface ClusterTopologyManager
Exception
public void handleLeave(String cacheName, Address leaver, int viewId) throws Exception
ClusterTopologyManager
RebalancePolicy
handleLeave
in interface ClusterTopologyManager
Exception
public void handleRebalanceCompleted(String cacheName, Address node, int topologyId, Throwable throwable, int viewId) throws Exception
ClusterTopologyManager
handleRebalanceCompleted
in interface ClusterTopologyManager
Exception
public void updateCacheStatusAfterMerge(String cacheName, List<Address> clusterMembers, List<CacheTopology> partitionTopologies) throws Exception
Exception
Copyright © 2014 JBoss, a division of Red Hat. All Rights Reserved.