Package org.graylog.plugins.views.storage.migration.state.actions

Class MigrationActionsImpl

java.lang.Object

org.graylog.plugins.views.storage.migration.state.actions.MigrationActionsImpl

All Implemented Interfaces:

MigrationActions

public class MigrationActionsImpl
extends Object
implements MigrationActions

Constructor Summary

Constructors

Constructor

Description

MigrationActionsImpl(MigrationStateMachineContext stateMachineContext, ClusterConfigService clusterConfigService, NodeService<DataNodeDto> nodeService, CaKeystore caKeystore, DataNodeCommandService dataNodeCommandService, RemoteReindexingMigrationAdapter migrationService, ClusterProcessingControlFactory clusterProcessingControlFactory, PreflightConfigService preflightConfigService, com.codahale.metrics.MetricRegistry metricRegistry, DatanodeRestApiProxy datanodeProxy, ElasticsearchVersionProvider searchVersionProvider, List<URI> elasticsearchHosts, NotificationService notificationService, FeatureFlags featureFlags)

Method Summary

Modifier and Type	Method	Description
boolean	allDatanodesAvailable()
boolean	allDatanodesPrepared()
boolean	caAndRenewalPolicyExist()
boolean	caDoesNotExist()
void	calculateTrafficEstimate()
boolean	compatibleDatanodesRunning()
boolean	directoryCompatibilityCheckOk()
void	finishRemoteReindexMigration()
void	getElasticsearchHosts()
boolean	isCompatibleInPlaceMigrationVersion()
boolean	isOldClusterStopped()
boolean	isRemoteReindexingFinished()
boolean	isRemoteReindexMigrationEnabled()
void	provisionAndStartDataNodes()
void	provisionDataNodes()
boolean	provisioningFinished()
void	reindexUpgradeSelected()
boolean	renewalPolicyDoesNotExist()
void	requestMigrationStatus()
void	rollingUpgradeSelected()
void	runDirectoryCompatibilityCheck()
void	setPreflightFinished()
void	startDataNodes()
void	startMessageProcessing()
void	startRemoteReindex()
void	stopDatanodes()
void	stopMessageProcessing()
void	verifyRemoteIndexerConnection()

Methods inherited from class java.lang.Object

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

Constructor Details

MigrationActionsImpl

@Inject
public MigrationActionsImpl(MigrationStateMachineContext stateMachineContext,
 ClusterConfigService clusterConfigService,
 NodeService<DataNodeDto> nodeService,
 CaKeystore caKeystore,
 DataNodeCommandService dataNodeCommandService,
 RemoteReindexingMigrationAdapter migrationService,
 ClusterProcessingControlFactory clusterProcessingControlFactory,
 PreflightConfigService preflightConfigService,
 com.codahale.metrics.MetricRegistry metricRegistry,
 DatanodeRestApiProxy datanodeProxy,
 ElasticsearchVersionProvider searchVersionProvider,
 @Named("elasticsearch_hosts")
 List<URI> elasticsearchHosts,
 NotificationService notificationService,
 FeatureFlags featureFlags)

Method Details

runDirectoryCompatibilityCheck

public void runDirectoryCompatibilityCheck()

Specified by:

runDirectoryCompatibilityCheck in interface MigrationActions

isOldClusterStopped

public boolean isOldClusterStopped()

Specified by:

isOldClusterStopped in interface MigrationActions

rollingUpgradeSelected

public void rollingUpgradeSelected()

Specified by:

rollingUpgradeSelected in interface MigrationActions

directoryCompatibilityCheckOk

public boolean directoryCompatibilityCheckOk()

Specified by:

directoryCompatibilityCheckOk in interface MigrationActions

reindexUpgradeSelected

public void reindexUpgradeSelected()

Specified by:

reindexUpgradeSelected in interface MigrationActions

stopMessageProcessing

public void stopMessageProcessing()

Specified by:

stopMessageProcessing in interface MigrationActions

startMessageProcessing

public void startMessageProcessing()

Specified by:

startMessageProcessing in interface MigrationActions

caDoesNotExist

public boolean caDoesNotExist()

Specified by:

caDoesNotExist in interface MigrationActions

renewalPolicyDoesNotExist

public boolean renewalPolicyDoesNotExist()

Specified by:

renewalPolicyDoesNotExist in interface MigrationActions

caAndRenewalPolicyExist

public boolean caAndRenewalPolicyExist()

Specified by:

caAndRenewalPolicyExist in interface MigrationActions

compatibleDatanodesRunning

public boolean compatibleDatanodesRunning()

Specified by:

compatibleDatanodesRunning in interface MigrationActions

provisionDataNodes

public void provisionDataNodes()

Specified by:

provisionDataNodes in interface MigrationActions

provisionAndStartDataNodes

public void provisionAndStartDataNodes()

Specified by:

provisionAndStartDataNodes in interface MigrationActions

provisioningFinished

public boolean provisioningFinished()

Specified by:

provisioningFinished in interface MigrationActions

allDatanodesPrepared

public boolean allDatanodesPrepared()

Specified by:

allDatanodesPrepared in interface MigrationActions

startDataNodes

public void startDataNodes()

Specified by:

startDataNodes in interface MigrationActions

allDatanodesAvailable

public boolean allDatanodesAvailable()

Specified by:

allDatanodesAvailable in interface MigrationActions

setPreflightFinished

public void setPreflightFinished()

Specified by:

setPreflightFinished in interface MigrationActions

startRemoteReindex

public void startRemoteReindex()

Specified by:

startRemoteReindex in interface MigrationActions

requestMigrationStatus

public void requestMigrationStatus()

Specified by:

requestMigrationStatus in interface MigrationActions

calculateTrafficEstimate

public void calculateTrafficEstimate()

Specified by:

calculateTrafficEstimate in interface MigrationActions

verifyRemoteIndexerConnection

public void verifyRemoteIndexerConnection()

Specified by:

verifyRemoteIndexerConnection in interface MigrationActions

isCompatibleInPlaceMigrationVersion

public boolean isCompatibleInPlaceMigrationVersion()

Specified by:

isCompatibleInPlaceMigrationVersion in interface MigrationActions

getElasticsearchHosts

public void getElasticsearchHosts()

Specified by:

getElasticsearchHosts in interface MigrationActions

isRemoteReindexingFinished

public boolean isRemoteReindexingFinished()

Specified by:

isRemoteReindexingFinished in interface MigrationActions

stopDatanodes

public void stopDatanodes()

Specified by:

stopDatanodes in interface MigrationActions

finishRemoteReindexMigration

public void finishRemoteReindexMigration()

Specified by:

finishRemoteReindexMigration in interface MigrationActions

isRemoteReindexMigrationEnabled

public boolean isRemoteReindexMigrationEnabled()

Specified by:

isRemoteReindexMigrationEnabled in interface MigrationActions