Package org.graylog2.indexer.datanode

Class RemoteReindexMigrationServiceImpl

java.lang.Object

org.graylog2.indexer.datanode.RemoteReindexMigrationServiceImpl

All Implemented Interfaces:

RemoteReindexMigrationService

public class RemoteReindexMigrationServiceImpl
extends Object
implements RemoteReindexMigrationService

Field Summary

Fields

Modifier and Type	Field	Description
static final String	COLLECTION_NAME

Constructor Summary

Constructors

Constructor	Description
RemoteReindexMigrationServiceImpl(MongoCollections mongoCollections)

Method Summary

Modifier and Type	Method	Description
void	appendLogEntry(String migrationId, LogEntry log)
void	assignTask(String migrationID, String indexName, String taskId)
Optional<String>	getLatestMigrationId()
Optional<MigrationConfiguration>	getMigration(String migrationId)
MigrationConfiguration	saveMigration(MigrationConfiguration migrationConfiguration)

Methods inherited from class java.lang.Object

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

Field Details

COLLECTION_NAME

public static final String COLLECTION_NAME

See Also:

• Constant Field Values

Constructor Details

RemoteReindexMigrationServiceImpl

@Inject
public RemoteReindexMigrationServiceImpl(MongoCollections mongoCollections)

Method Details

getMigration

public Optional<MigrationConfiguration> getMigration(String migrationId)

Specified by:

getMigration in interface RemoteReindexMigrationService

saveMigration

public MigrationConfiguration saveMigration(MigrationConfiguration migrationConfiguration)

Specified by:

saveMigration in interface RemoteReindexMigrationService

assignTask

public void assignTask(String migrationID,
 String indexName,
 String taskId)

Specified by:

assignTask in interface RemoteReindexMigrationService

appendLogEntry

public void appendLogEntry(String migrationId,
 LogEntry log)

Specified by:

appendLogEntry in interface RemoteReindexMigrationService

getLatestMigrationId

public Optional<String> getLatestMigrationId()

Specified by:

getLatestMigrationId in interface RemoteReindexMigrationService