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

Methods

Modifier and Type	Method and Description
Map<Address,Response>	forwardCommandIfNeeded(TopologyAffectedCommand command, Set<Object> affectedKeys, Address origin, boolean sync) 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()
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)
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

CacheTopology getCacheTopology()

start

void start()
           throws Exception

Throws:

Exception

stop

void stop()

forwardCommandIfNeeded

Map<Address,Response> forwardCommandIfNeeded(TopologyAffectedCommand command,
                                           Set<Object> affectedKeys,
                                           Address origin,
                                           boolean sync)

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.

notifyEndOfRebalance

void notifyEndOfRebalance(int topologyId)

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).