Package org.infinispan.upgrade

Interface TargetMigrator

All Known Implementing Classes:

HotRodTargetMigrator

public interface TargetMigrator

Performs migration operations on the target server or cluster of servers

Since:

5.2

Author:

Tristan Tarrant

Method Summary

Modifier and Type	Method	Description
void	connectSource(Cache<Object,Object> cache, StoreConfiguration configuration)	Connects the target cluster to the source cluster through a Remote Store.
void	disconnectSource(Cache<Object,Object> cache)	Disconnects the target from the source.
String	getName()	Returns the name of this migrator
boolean	isConnected(Cache<Object,Object> cache)	Check if a cluster is connected to other for doing rolling upgrades
long	synchronizeData(Cache<Object,Object> cache)	Performs the synchronization of data between source and target
long	synchronizeData(Cache<Object,Object> cache, int readBatch, int threads)	Performs the synchronization of data between source and target

Method Details

getName

String getName()

Returns the name of this migrator

synchronizeData

long synchronizeData(Cache<Object,Object> cache)
              throws CacheException

Performs the synchronization of data between source and target

Throws:

CacheException

synchronizeData

long synchronizeData(Cache<Object,Object> cache,
 int readBatch,
 int threads)
              throws CacheException

Performs the synchronization of data between source and target

Throws:

CacheException

disconnectSource

void disconnectSource(Cache<Object,Object> cache)
               throws CacheException

Disconnects the target from the source. This operation is the last step that must be performed after a rolling upgrade.

Throws:

CacheException

connectSource

void connectSource(Cache<Object,Object> cache,
 StoreConfiguration configuration)

Connects the target cluster to the source cluster through a Remote Store.

Parameters:

cache - The cache to add the store to

configuration - The configuration of the store

isConnected

boolean isConnected(Cache<Object,Object> cache)

Check if a cluster is connected to other for doing rolling upgrades

Parameters:

cache - The cache name

Returns:

true if the cache has a remote store pointing to another cluster ready to do rolling upgrades.