public interface LocalTopologyManager
ClusterTopologyManager
.Modifier and Type | Method and Description |
---|---|
void |
confirmRebalance(String cacheName,
int topologyId,
int rebalanceId,
Throwable throwable)
Confirm that the local cache
cacheName has finished receiving the new data for topology
topologyId . |
AvailabilityMode |
getCacheAvailability(String cacheName)
Retrieves the availability state of a cache.
|
CacheTopology |
getCacheTopology(String cacheName) |
PersistentUUID |
getPersistentUUID()
Returns the local UUID of this node.
|
RebalancingStatus |
getRebalancingStatus(String cacheName)
Retrieve the rebalancing status for the specified cache
|
CacheTopology |
getStableCacheTopology(String cacheName) |
void |
handleRebalance(String cacheName,
CacheTopology cacheTopology,
int viewId,
Address sender)
Performs the state transfer.
|
void |
handleStableTopologyUpdate(String cacheName,
CacheTopology cacheTopology,
Address sender,
int viewId)
Update the stable cache topology.
|
ManagerStatusResponse |
handleStatusRequest(int viewId)
Recovers the current topology information for all running caches and returns it to the coordinator.
|
void |
handleTopologyUpdate(String cacheName,
CacheTopology cacheTopology,
AvailabilityMode availabilityMode,
int viewId,
Address sender)
Updates the current and/or pending consistent hash, without transferring any state.
|
boolean |
isCacheRebalancingEnabled(String cacheName)
Checks whether rebalancing is enabled for the specified cache.
|
boolean |
isRebalancingEnabled()
Checks whether rebalancing is enabled for the entire cluster.
|
boolean |
isTotalOrderCache(String cacheName)
Checks if the cache defined by
cacheName is using total order. |
CacheTopology |
join(String cacheName,
CacheJoinInfo joinInfo,
CacheTopologyHandler stm,
PartitionHandlingManager phm)
Forwards the join request to the coordinator.
|
void |
leave(String cacheName)
Forwards the leave request to the coordinator.
|
void |
setCacheAvailability(String cacheName,
AvailabilityMode availabilityMode)
Updates the availability state of a cache (for the entire cluster).
|
void |
setCacheRebalancingEnabled(String cacheName,
boolean enabled)
Enable or disable rebalancing for the specified cache.
|
void |
setRebalancingEnabled(boolean enabled)
Enable or disable rebalancing in the entire cluster.
|
CacheTopology join(String cacheName, CacheJoinInfo joinInfo, CacheTopologyHandler stm, PartitionHandlingManager phm) throws Exception
Exception
void leave(String cacheName)
void confirmRebalance(String cacheName, int topologyId, int rebalanceId, Throwable throwable)
cacheName
has finished receiving the new data for topology
topologyId
.
The coordinator can change during the state transfer, so we make the rebalance RPC async and we send the response as a different command.
cacheName
- the name of the cachetopologyId
- the current topology id of the node at the time the rebalance is completed. This must be >= than the one when rebalance starts.rebalanceId
- throwable
- null
unless local rebalance ended because of an error.ManagerStatusResponse handleStatusRequest(int viewId)
viewId
- void handleTopologyUpdate(String cacheName, CacheTopology cacheTopology, AvailabilityMode availabilityMode, int viewId, Address sender) throws InterruptedException
InterruptedException
void handleStableTopologyUpdate(String cacheName, CacheTopology cacheTopology, Address sender, int viewId)
void handleRebalance(String cacheName, CacheTopology cacheTopology, int viewId, Address sender) throws InterruptedException
InterruptedException
CacheTopology getCacheTopology(String cacheName)
CacheTopology getStableCacheTopology(String cacheName)
boolean isTotalOrderCache(String cacheName)
cacheName
is using total order.
If this component is not running or the cacheName
is not defined, it returns false
.true
if the cache is using the total order protocol, false
otherwise.boolean isRebalancingEnabled() throws Exception
Exception
boolean isCacheRebalancingEnabled(String cacheName) throws Exception
Exception
void setRebalancingEnabled(boolean enabled) throws Exception
Exception
void setCacheRebalancingEnabled(String cacheName, boolean enabled) throws Exception
Exception
RebalancingStatus getRebalancingStatus(String cacheName) throws Exception
Exception
AvailabilityMode getCacheAvailability(String cacheName)
void setCacheAvailability(String cacheName, AvailabilityMode availabilityMode) throws Exception
Exception
PersistentUUID getPersistentUUID()
Copyright © 2023 JBoss, a division of Red Hat. All rights reserved.