@MBean(objectName="RollingUpgradeManager", description="Handles the migration of data when upgrading between versions.") public class RollingUpgradeManager extends Object
Constructor and Description |
---|
RollingUpgradeManager() |
Modifier and Type | Method and Description |
---|---|
void |
disconnectSource(String migratorName) |
void |
start() |
long |
synchronizeData(String migratorName) |
long |
synchronizeData(String migratorName,
int readBatch,
int threads) |
public void start()
@ManagedOperation(description="Synchronizes data from source clusters to target clusters with the specified migrator.", displayName="Synchronizes data from source clusters to target clusters with the specified migrator.") public long synchronizeData(@Parameter(name="migratorName",description="Specifies the name of the migrator to use. Set hotrod as the value unless using custom migrators.") String migratorName) throws Exception
Exception
@ManagedOperation(description="Synchronizes data from source clusters to target clusters with the specified migrator.", displayName="Synchronizes data from source clusters to target clusters with the specified migrator.") public long synchronizeData(@Parameter(name="migratorName",description="Specifies the name of the migrator to use. Set hotrod as the value unless using custom migrators.") String migratorName, @Parameter(name="readBatch",description="Specifies how many entries to read at a time from source clusters. Default is 10000.") int readBatch, @Parameter(name="threads",description="Specifies the number of threads to use per node when writing data to target clusters. Defaults to number of available processors.") int threads) throws Exception
Exception
@ManagedOperation(description="Disconnects target clusters from source clusters.", displayName="Disconnects target clusters from source clusters.") public void disconnectSource(@Parameter(name="migratorName",description="Specifies the name of the migrator to use. Set hotrod as the value unless using custom migrators.") String migratorName) throws Exception
Exception
Copyright © 2021 JBoss by Red Hat. All rights reserved.