|
Infinispan Distribution 5.2.6.Final-redhat-2 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface LocalTopologyManager
Runs on every node and handles the communication with the ClusterTopologyManager
.
Method Summary | |
---|---|
void |
confirmRebalance(String cacheName,
int topologyId,
Throwable throwable)
Confirm that the local cache cacheName has finished receiving the new data for topology
topologyId . |
CacheTopology |
getCacheTopology(String cacheName)
|
void |
handleConsistentHashUpdate(String cacheName,
CacheTopology cacheTopology,
int viewId)
Updates the current and/or pending consistent hash, without transferring any state. |
void |
handleRebalance(String cacheName,
CacheTopology cacheTopology,
int viewId)
Performs the state transfer. |
Map<String,Object[]> |
handleStatusRequest(int viewId)
Recovers the current topology information for all running caches and returns it to the coordinator. |
CacheTopology |
join(String cacheName,
CacheJoinInfo joinInfo,
CacheTopologyHandler stm)
Forwards the join request to the coordinator. |
void |
leave(String cacheName)
Forwards the leave request to the coordinator. |
Method Detail |
---|
CacheTopology join(String cacheName, CacheJoinInfo joinInfo, CacheTopologyHandler stm) throws Exception
Exception
void leave(String cacheName)
void confirmRebalance(String cacheName, int topologyId, 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.
throwable
- null
if local rebalance ended because of an error.Map<String,Object[]> handleStatusRequest(int viewId)
viewId
- void handleConsistentHashUpdate(String cacheName, CacheTopology cacheTopology, int viewId) throws InterruptedException
InterruptedException
void handleRebalance(String cacheName, CacheTopology cacheTopology, int viewId) throws InterruptedException
InterruptedException
CacheTopology getCacheTopology(String cacheName)
|
Infinispan Distribution 5.2.6.Final-redhat-2 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |