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 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.
String	getRebalancingStatus()
StateConsumer	getStateConsumer()
StateProvider	getStateProvider()
boolean	isJoinComplete()
boolean	isStateTransferInProgress() Checks if an inbound state transfer is in progress.
default boolean	isStateTransferInProgressForKey(Object key) Deprecated. since 10.0; to be removed in next major version
void	start()
void	stop()
void	waitForInitialStateTransferToComplete() Wait for the local cache to receive initial state from the other members.

Method Detail

isJoinComplete

boolean isJoinComplete()

isStateTransferInProgress

boolean isStateTransferInProgress()

Checks if an inbound state transfer is in progress.

isStateTransferInProgressForKey

@Deprecated
default boolean isStateTransferInProgressForKey(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.

start

void start()
    throws Exception

Throws:

Exception

waitForInitialStateTransferToComplete

void waitForInitialStateTransferToComplete()

Wait for the local cache to receive initial state from the other members.

Does nothing if StateTransferConfiguration.awaitInitialTransfer() is disabled.

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.

getRebalancingStatus

String getRebalancingStatus()
                     throws Exception

Throws:

Exception

getStateConsumer

StateConsumer getStateConsumer()

getStateProvider

StateProvider getStateProvider()