public interface StateTransferManager
Modifier and Type | Method and Description |
---|---|
void |
forwardCommandIfNeeded(TopologyAffectedCommand command,
Set<Object> affectedKeys,
Address origin,
boolean sync)
If there is an state transfer happening at the moment, this method forwards the supplied
command to the nodes that are new owners of the data, in order to assure consistency.
|
CacheTopology |
getCacheTopology() |
int |
getFirstTopologyAsMember() |
boolean |
isJoinComplete() |
boolean |
isStateTransferInProgress()
Checks if an inbound state transfer is in progress.
|
boolean |
isStateTransferInProgressForKey(Object key)
Checks if an inbound state transfer is in progress for a given key.
|
void |
notifyEndOfRebalance(int topologyId) |
void |
start() |
void |
stop() |
boolean isJoinComplete()
boolean isStateTransferInProgress()
boolean isStateTransferInProgressForKey(Object key)
key
- CacheTopology getCacheTopology()
void stop()
void forwardCommandIfNeeded(TopologyAffectedCommand command, Set<Object> affectedKeys, Address origin, boolean sync)
void notifyEndOfRebalance(int topologyId)
int getFirstTopologyAsMember()
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.