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
java.util.Map<Address,Response>	forwardCommandIfNeeded(org.infinispan.commands.TopologyAffectedCommand command, java.util.Set<java.lang.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.
java.lang.String	getRebalancingStatus()
StateConsumer	getStateConsumer()
StateProvider	getStateProvider()
boolean	isJoinComplete()
boolean	isStateTransferInProgress()	Checks if an inbound state transfer is in progress.
default boolean	isStateTransferInProgressForKey(java.lang.Object key)	Deprecated. since 10.0; to be removed in next major version
void	start()
void	stop()
void	waitForInitialStateTransferToComplete()

Method Detail

isJoinComplete

boolean isJoinComplete()

isStateTransferInProgress

boolean isStateTransferInProgress()

Checks if an inbound state transfer is in progress.

isStateTransferInProgressForKey

@Deprecated
default boolean isStateTransferInProgressForKey(java.lang.Object key)

Deprecated.

since 10.0; to be removed in next major version

Checks if an inbound state transfer is in progress for a given key.

Parameters:

key -

Returns:

start

void start()
    throws java.lang.Exception

Throws:

java.lang.Exception

waitForInitialStateTransferToComplete

void waitForInitialStateTransferToComplete()

stop

void stop()

forwardCommandIfNeeded

java.util.Map<Address,Response> forwardCommandIfNeeded(org.infinispan.commands.TopologyAffectedCommand command,
                                                             java.util.Set<java.lang.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.

getRebalancingStatus

java.lang.String getRebalancingStatus()
                               throws java.lang.Exception

Throws:

java.lang.Exception

getStateConsumer

StateConsumer getStateConsumer()

getStateProvider

StateProvider getStateProvider()