Package org.infinispan.persistence.remote.upgrade

Class HotRodTargetMigrator

java.lang.Object

org.infinispan.persistence.remote.upgrade.HotRodTargetMigrator

All Implemented Interfaces:

TargetMigrator

@MetaInfServices
public class HotRodTargetMigrator
extends Object
implements TargetMigrator

Constructor Summary

Constructors

Constructor	Description
HotRodTargetMigrator()

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

HotRodTargetMigrator

public HotRodTargetMigrator()

Method Details

getName

public String getName()

Description copied from interface: TargetMigrator

Returns the name of this migrator

Specified by:

getName in interface TargetMigrator

synchronizeData

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

Description copied from interface: TargetMigrator

Performs the synchronization of data between source and target

Specified by:

synchronizeData in interface TargetMigrator

Throws:

CacheException

synchronizeData

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

Description copied from interface: TargetMigrator

Performs the synchronization of data between source and target

Specified by:

synchronizeData in interface TargetMigrator

Throws:

CacheException

disconnectSource

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

Description copied from interface: TargetMigrator

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

Specified by:

disconnectSource in interface TargetMigrator

Throws:

CacheException

connectSource

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

Description copied from interface: TargetMigrator

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

Specified by:

connectSource in interface TargetMigrator

Parameters:

cache - The cache to add the store to

configuration - The configuration of the store

isConnected

public boolean isConnected(Cache<Object,Object> cache)

Description copied from interface: TargetMigrator

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

Specified by:

isConnected in interface TargetMigrator

Parameters:

cache - The cache name

Returns:

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