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 <dan@infinispan.org>, Mircea Markus, anistor@redhat.com

Method Summary

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 use DistributionManager.getCacheTopology() instead.
int	getFirstTopologyAsMember()	Deprecated. Since 9.4, will be removed.
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()	Deprecated. Since 9.4, will be removed.
void	start()
void	stop()
void	waitForInitialStateTransferToComplete()

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 use DistributionManager.getCacheTopology() instead.

start

void start()
    throws Exception

Throws:

Exception

waitForInitialStateTransferToComplete

void waitForInitialStateTransferToComplete()

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

@Deprecated
boolean ownsData()

Deprecated.

Since 9.4, will be removed.

Returns:

true if this node has already received the first rebalance start

getFirstTopologyAsMember

@Deprecated
int getFirstTopologyAsMember()

Deprecated.

Since 9.4, will be removed.

Returns:

The id of the first cache topology in which the local node was a member (even if it didn't own any data).

getRebalancingStatus

String getRebalancingStatus()
                     throws Exception

Throws:

Exception