Uses of Class
software.amazon.kinesis.coordinator.migration.MigrationState

Packages that use MigrationState

Package	Description
software.amazon.kinesis.coordinator.migration

Uses of MigrationState in software.amazon.kinesis.coordinator.migration

Fields in software.amazon.kinesis.coordinator.migration declared as MigrationState

Modifier and Type	Field and Description
protected MigrationState	AbstractMigrationClientVersionState.curentMigrationState

Methods in software.amazon.kinesis.coordinator.migration that return MigrationState

Modifier and Type	Method and Description
MigrationState	MigrationState.copy()
static MigrationState	MigrationState.deserialize(String key, HashMap<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue> attributes)
MigrationState	MigrationState.update(ClientVersion clientVersion, String modifiedBy)

Methods in software.amazon.kinesis.coordinator.migration that return types with arguments of type MigrationState

Modifier and Type	Method and Description
AbstractMap.SimpleEntry<ClientVersion,MigrationState>	MigrationClientVersionStateInitializer.getInitialState() Determine the initial client version by reading the current state from DDB and applying the configured client version policy.

Methods in software.amazon.kinesis.coordinator.migration with parameters of type MigrationState

Modifier and Type	Method and Description
void	ClientVersionChangeMonitor.ClientVersionChangeCallback.accept(MigrationState currentMigrationState)
ClientVersion	MigrationClientVersionStateInitializer.getClientVersionForInitialization(MigrationState migrationState)
void	MigrationStateMachineImpl.transitionTo(ClientVersion nextClientVersion, MigrationState migrationState)
void	MigrationStateMachine.transitionTo(ClientVersion nextClientVersion, MigrationState state) Peform transition from current state to the given new ClientVersion

Constructors in software.amazon.kinesis.coordinator.migration with parameters of type MigrationState

Constructor and Description
MigrationClientVersion2xState(MigrationStateMachine stateMachine, CoordinatorStateDAO coordinatorStateDAO, ScheduledExecutorService stateMachineThreadPool, DynamicMigrationComponentsInitializer initializer, Random random, MigrationState migrationState, String workerIdentifier)
MigrationClientVersion3xState(MigrationStateMachine stateMachine, DynamicMigrationComponentsInitializer initializer, CoordinatorStateDAO coordinatorStateDAO, MigrationState migrationState, String workerIdentifier)
MigrationClientVersion3xWithRollbackState(MigrationStateMachine stateMachine, CoordinatorStateDAO coordinatorStateDAO, ScheduledExecutorService stateMachineThreadPool, DynamicMigrationComponentsInitializer initializer, Random random, MigrationState migrationState, String workerIdentifier)
MigrationClientVersionUpgradeFrom2xState(MigrationStateMachine stateMachine, Callable<Long> timeProvider, CoordinatorStateDAO coordinatorStateDAO, ScheduledExecutorService stateMachineThreadPool, DynamicMigrationComponentsInitializer initializer, Random random, MigrationState migrationState, long flipTo3XStabilizerTimeInSeconds, String workerIdentifier)