public interface ClusterTopologyManager
Modifier and Type | Method and Description |
---|---|
void |
broadcastRebalanceStart(String cacheName,
CacheTopology cacheTopology,
boolean totalOrder,
boolean distributed) |
void |
broadcastStableTopologyUpdate(String cacheName,
CacheTopology cacheTopology,
boolean totalOrder,
boolean distributed) |
void |
broadcastTopologyUpdate(String cacheName,
CacheTopology cacheTopology,
AvailabilityMode availabilityMode,
boolean totalOrder,
boolean distributed) |
void |
forceAvailabilityMode(String cacheName,
AvailabilityMode availabilityMode) |
void |
forceRebalance(String cacheName) |
RebalancingStatus |
getRebalancingStatus(String cacheName)
Retrieves the rebalancing status of a cache
|
void |
handleClusterView(boolean isMerge,
int viewId)
Install a new cluster view.
|
CacheStatusResponse |
handleJoin(String cacheName,
Address joiner,
CacheJoinInfo joinInfo,
int viewId)
Signals that a new member is joining the cache.
|
void |
handleLeave(String cacheName,
Address leaver,
int viewId)
Signals that a member is leaving the cache.
|
void |
handleRebalanceCompleted(String cacheName,
Address node,
int topologyId,
Throwable throwable,
int viewId)
Marks the rebalance as complete on the sender.
|
boolean |
isRebalancingEnabled() |
boolean |
isRebalancingEnabled(String cacheName)
Returns whether rebalancing is enabled or disabled for this container.
|
void |
setRebalancingEnabled(boolean enabled)
Globally enables or disables whether automatic rebalancing should occur.
|
void |
setRebalancingEnabled(String cacheName,
boolean enabled)
Enables or disables rebalancing for the specified cache
|
CacheStatusResponse handleJoin(String cacheName, Address joiner, CacheJoinInfo joinInfo, int viewId) throws Exception
CacheStatusResponse.cacheTopology
is the current cache topology before the node joined.
If the node is the first to join the cache, the returned topology does include the joiner,
and it is never null
.Exception
void handleLeave(String cacheName, Address leaver, int viewId) throws Exception
Exception
void handleRebalanceCompleted(String cacheName, Address node, int topologyId, Throwable throwable, int viewId) throws Exception
Exception
void handleClusterView(boolean isMerge, int viewId)
void broadcastRebalanceStart(String cacheName, CacheTopology cacheTopology, boolean totalOrder, boolean distributed)
void broadcastTopologyUpdate(String cacheName, CacheTopology cacheTopology, AvailabilityMode availabilityMode, boolean totalOrder, boolean distributed)
void broadcastStableTopologyUpdate(String cacheName, CacheTopology cacheTopology, boolean totalOrder, boolean distributed)
boolean isRebalancingEnabled()
boolean isRebalancingEnabled(String cacheName)
void setRebalancingEnabled(boolean enabled)
void setRebalancingEnabled(String cacheName, boolean enabled)
RebalancingStatus getRebalancingStatus(String cacheName)
void forceRebalance(String cacheName)
void forceAvailabilityMode(String cacheName, AvailabilityMode availabilityMode)
Copyright © 2016 JBoss, a division of Red Hat. All rights reserved.