public interface StateTransferManager
Modifier and Type | Method and Description |
---|---|
Map<Address,Response> |
forwardCommandIfNeeded(TopologyAffectedCommand command,
Set<Object> affectedKeys,
Address origin)
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() |
String |
getRebalancingStatus() |
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,
int rebalanceId) |
boolean |
ownsData() |
void |
start() |
void |
stop() |
boolean isJoinComplete()
boolean isStateTransferInProgress()
boolean isStateTransferInProgressForKey(Object key)
key
- CacheTopology getCacheTopology()
void stop()
Map<Address,Response> forwardCommandIfNeeded(TopologyAffectedCommand command, Set<Object> affectedKeys, Address origin)
void notifyEndOfRebalance(int topologyId, int rebalanceId)
boolean ownsData()
int getFirstTopologyAsMember()
Copyright © 2023 JBoss, a division of Red Hat. All rights reserved.