org.infinispan.upgrade

Class RollingUpgradeManager

java.lang.Object

org.infinispan.upgrade.RollingUpgradeManager

public class RollingUpgradeManager
extends Object

This component handles the control hooks to handle migrating from one version of Infinispan to another.

Since:

5.2

Author:

Manik Surtani, Tristan Tarrant

Constructor Summary

Constructors

Constructor and Description
RollingUpgradeManager()

Method Summary

Modifier and Type	Method and Description
void	addSourceMigrator(SourceMigrator migrator) Registers a migrator for a specific data format or endpoint.
void	disconnectSource(String migratorName)
void	initialize(Cache<Object,Object> cache, TimeService timeService)
void	recordKnownGlobalKeyset()
long	synchronizeData(String migratorName)
long	synchronizeData(String migratorName, int readBatch, int threads)

Methods inherited from class java.lang.Object

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

Constructor Detail

RollingUpgradeManager

public RollingUpgradeManager()

Method Detail

initialize

public void initialize(Cache<Object,Object> cache,
                       TimeService timeService)

recordKnownGlobalKeyset

public void recordKnownGlobalKeyset()

synchronizeData

public long synchronizeData(String migratorName)
                     throws Exception

Throws:

Exception

synchronizeData

public long synchronizeData(String migratorName,
                            int readBatch,
                            int threads)
                     throws Exception

Throws:

Exception

disconnectSource

public void disconnectSource(String migratorName)
                      throws Exception

Throws:

Exception

addSourceMigrator

public void addSourceMigrator(SourceMigrator migrator)

Registers a migrator for a specific data format or endpoint. In the Infinispan ecosystem, we'd typically have one Migrator implementation for Hot Rod, one for memcached, one for REST and one for embedded/in-VM mode, and these would typically be added to the upgrade manager on first access via any of these protocols.

Parameters:

migrator -