Package org.infinispan.statetransfer
Interface StateTransferManager
-
- All Known Implementing Classes:
StateTransferManagerImpl
public interface StateTransferManager
A component that manages the state transfer when the topology of the cluster changes.- Since:
- 5.1
- Author:
- Dan Berindei
, Mircea Markus, anistor@redhat.com
-
-
Method Summary
All Methods Instance Methods Abstract Methods Deprecated Methods Modifier and Type Method 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()
Deprecated.Since 9.3, please useDistributionManager.getCacheTopology()
instead.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.boolean
ownsData()
void
start()
void
stop()
-
-
-
Method Detail
-
isJoinComplete
boolean isJoinComplete()
-
isStateTransferInProgress
boolean isStateTransferInProgress()
Checks if an inbound state transfer is in progress.
-
isStateTransferInProgressForKey
boolean isStateTransferInProgressForKey(Object key)
Checks if an inbound state transfer is in progress for a given key.- Parameters:
key
-- Returns:
-
getCacheTopology
@Deprecated CacheTopology getCacheTopology()
Deprecated.Since 9.3, please useDistributionManager.getCacheTopology()
instead.
-
stop
void stop()
-
forwardCommandIfNeeded
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.
-
ownsData
boolean ownsData()
- Returns:
- true if this node has already received the first rebalance start
-
getFirstTopologyAsMember
int getFirstTopologyAsMember()
- Returns:
- The id of the first cache topology in which the local node was a member (even if it didn't own any data).
-
-