software.amazon.kinesis.coordinator.migration

Class MigrationClientVersion2xState

java.lang.Object

software.amazon.kinesis.coordinator.migration.AbstractMigrationClientVersionState

software.amazon.kinesis.coordinator.migration.MigrationClientVersion2xState

All Implemented Interfaces:

MigrationClientVersionState

@ThreadSafe
public class MigrationClientVersion2xState
extends AbstractMigrationClientVersionState

State for CLIENT_VERSION_2X. In this state, the only allowed valid transition is the roll-forward scenario which can only be performed using the KCL Migration tool. So when the state machine enters this state, a monitor is started to detect the roll-forward scenario.

Field Summary

Fields inherited from class software.amazon.kinesis.coordinator.migration.AbstractMigrationClientVersionState

coordinatorStateDAO, curentMigrationState, entered, left

Constructor Summary

Constructors

Constructor and Description
MigrationClientVersion2xState(MigrationStateMachine stateMachine, CoordinatorStateDAO coordinatorStateDAO, ScheduledExecutorService stateMachineThreadPool, DynamicMigrationComponentsInitializer initializer, Random random, MigrationState migrationState, String workerIdentifier)

Method Summary

Modifier and Type	Method and Description
ClientVersion	clientVersion() The associated clientVersion this state corresponds to
protected void	doEnter(ClientVersion fromClientVersion) State-specific enter logic.
void	leave() Invoked after the transition to another state has occurred to allow printing any helpful logs or performing cleanup.
String	toString()

Methods inherited from class software.amazon.kinesis.coordinator.migration.AbstractMigrationClientVersionState

enter

Methods inherited from class java.lang.Object

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

Constructor Detail

MigrationClientVersion2xState

public MigrationClientVersion2xState(MigrationStateMachine stateMachine,
                                     CoordinatorStateDAO coordinatorStateDAO,
                                     ScheduledExecutorService stateMachineThreadPool,
                                     DynamicMigrationComponentsInitializer initializer,
                                     Random random,
                                     MigrationState migrationState,
                                     String workerIdentifier)

Method Detail

clientVersion

public ClientVersion clientVersion()

Description copied from interface: MigrationClientVersionState

The associated clientVersion this state corresponds to

Returns:

ClientVersion that this state implements the logic for.

doEnter

protected void doEnter(ClientVersion fromClientVersion)

Description copied from class: AbstractMigrationClientVersionState

State-specific enter logic. Called after DDB state has been verified/updated.

Specified by:

doEnter in class AbstractMigrationClientVersionState

Parameters:

fromClientVersion - the client version of the previous state

leave

public void leave()

Description copied from interface: MigrationClientVersionState

Invoked after the transition to another state has occurred to allow printing any helpful logs or performing cleanup.

toString

public String toString()

Overrides:

toString in class Object