|
Infinispan Distribution 5.2.6.Final-redhat-2 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.infinispan.topology.ClusterTopologyManagerImpl
public class ClusterTopologyManagerImpl
The ClusterTopologyManager
implementation.
Nested Class Summary | |
---|---|
class |
ClusterTopologyManagerImpl.ClusterViewListener
|
Constructor Summary | |
---|---|
ClusterTopologyManagerImpl()
|
Method Summary | |
---|---|
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> newMembers,
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)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public ClusterTopologyManagerImpl()
Method Detail |
---|
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) throws Exception
ClusterTopologyManager
RebalancePolicy
to start a state transfer.
triggerRebalance
in interface ClusterTopologyManager
Exception
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
protected void handleNewView(List<Address> newMembers, boolean mergeView, int newViewId)
public void updateCacheStatusAfterMerge(String cacheName, List<Address> clusterMembers, List<CacheTopology> partitionTopologies) throws Exception
Exception
public void updateClusterMembers(List<Address> newClusterMembers) throws Exception
Exception
|
Infinispan Distribution 5.2.6.Final-redhat-2 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |