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

Class MigrationStateResource

java.lang.Object

org.graylog.plugins.views.storage.migration.state.rest.MigrationStateResource

@Path("/migration")
@RequiresAuthentication
@Consumes("application/json")
@Produces("application/json")
public class MigrationStateResource
extends Object

Constructor Summary

Constructors

Constructor	Description
MigrationStateResource(MigrationStateMachine stateMachine, jakarta.ws.rs.core.HttpHeaders httpHeaders, KafkaJournalConfiguration journalConfiguration)

Method Summary

Modifier and Type	Method	Description
JournalEstimate	getJournalEstimate()
CurrentStateInformation	resetState()
String	serialize()
CurrentStateInformation	status()
jakarta.ws.rs.core.Response	trigger(@NotNull MigrationStepRequest request)

Methods inherited from class java.lang.Object

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

Constructor Details

MigrationStateResource

@Inject
public MigrationStateResource(MigrationStateMachine stateMachine,
 @Context
 jakarta.ws.rs.core.HttpHeaders httpHeaders,
 KafkaJournalConfiguration journalConfiguration)

Method Details

trigger

@POST
@Path("/trigger")
@RequiresPermissions("datanode:migration")
public jakarta.ws.rs.core.Response trigger(@NotNull
 @NotNull MigrationStepRequest request)

status

@GET
@Path("/state")
@RequiresPermissions("datanode:migration")
public CurrentStateInformation status()

serialize

@GET
@Path("/serialize")
@RequiresPermissions("datanode:migration")
@Produces("text/plain")
public String serialize()

resetState

@DELETE
@Path("/state")
@RequiresPermissions("datanode:migration")
public CurrentStateInformation resetState()

getJournalEstimate

@GET
@Path("/journalestimate")
@RequiresPermissions("datanode:migration")
public JournalEstimate getJournalEstimate()