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

Class MigrationStateMachineImpl

java.lang.Object

org.graylog.plugins.views.storage.migration.state.machine.MigrationStateMachineImpl

All Implemented Interfaces:

MigrationStateMachine

public class MigrationStateMachineImpl
extends Object
implements MigrationStateMachine

Constructor Summary

Constructors

Constructor	Description
MigrationStateMachineImpl(com.github.oxo42.stateless4j.StateMachine<MigrationState,MigrationStep> stateMachine, DatanodeMigrationPersistence persistenceService, MigrationStateMachineContext context)

Method Summary

Modifier and Type	Method	Description
MigrationStateMachineContext	getContext()
MigrationState	getState()
List<MigrationStep>	nextSteps()
void	reset()	The state machine is configured to obtain from and persist state via the underlying persistence service.
void	saveContext()
String	serialize()
CurrentStateInformation	trigger(MigrationStep step, Map<String,Object> args)

Methods inherited from class java.lang.Object

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

Constructor Details

MigrationStateMachineImpl

public MigrationStateMachineImpl(com.github.oxo42.stateless4j.StateMachine<MigrationState,MigrationStep> stateMachine,
 DatanodeMigrationPersistence persistenceService,
 MigrationStateMachineContext context)

Method Details

trigger

public CurrentStateInformation trigger(MigrationStep step,
 Map<String,Object> args)

Specified by:

trigger in interface MigrationStateMachine

saveContext

public void saveContext()

Specified by:

saveContext in interface MigrationStateMachine

getContext

public MigrationStateMachineContext getContext()

Specified by:

getContext in interface MigrationStateMachine

getState

public MigrationState getState()

Specified by:

getState in interface MigrationStateMachine

nextSteps

public List<MigrationStep> nextSteps()

Specified by:

nextSteps in interface MigrationStateMachine

serialize

public String serialize()

Specified by:

serialize in interface MigrationStateMachine

reset

public void reset()

The state machine is configured to obtain from and persist state via the underlying persistence service. If we change the state in the persistence, it will be automatically changed in the state machine as well.

Specified by:

reset in interface MigrationStateMachine

See Also:

• MigrationStateMachineBuilder.buildFromPersistedState(DatanodeMigrationPersistence, MigrationActions)