| Package | Description |
|---|---|
| software.amazon.kinesis.coordinator | |
| software.amazon.kinesis.coordinator.migration |
| Modifier and Type | Method and Description |
|---|---|
void |
DynamicMigrationComponentsInitializer.initializeClientVersionFor2x(ClientVersion fromClientVersion)
Initialize KCL with components and configuration to run 2x compatible functionality
while allowing roll-forward.
|
void |
DynamicMigrationComponentsInitializer.initializeClientVersionFor3x(ClientVersion fromClientVersion)
Initialize KCL with components and configuration to run vanilla 3x functionality.
|
void |
DynamicMigrationComponentsInitializer.initializeClientVersionFor3xWithRollback(ClientVersion fromClientVersion)
Initialize KCL with components and configuration to run vanilla 3x functionality
while allowing roll-back to 2x functionality.
|
void |
DynamicMigrationComponentsInitializer.initializeClientVersionForUpgradeFrom2x(ClientVersion fromClientVersion)
Initialize KCL with components and configuration to support upgrade from 2x.
|
| Modifier and Type | Method and Description |
|---|---|
ClientVersion |
MigrationClientVersion3xState.clientVersion() |
ClientVersion |
MigrationClientVersion2xState.clientVersion() |
ClientVersion |
MigrationClientVersionInitState.clientVersion() |
ClientVersion |
MigrationClientVersion3xWithRollbackState.clientVersion() |
ClientVersion |
MigrationClientVersionUpgradeFrom2xState.clientVersion() |
ClientVersion |
MigrationClientVersionState.clientVersion()
The associated clientVersion this state corresponds to
|
ClientVersion |
MigrationClientVersionStateInitializer.getClientVersionForInitialization(MigrationState migrationState) |
ClientVersion |
MigrationStateMachineImpl.getCurrentClientVersion() |
ClientVersion |
MigrationStateMachine.getCurrentClientVersion()
Get the ClientVersion of current state machine state.
|
static ClientVersion |
ClientVersion.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ClientVersion[] |
ClientVersion.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
void |
MigrationState.addHistoryEntry(ClientVersion lastClientVersion,
String lastModifiedBy,
long lastModifiedTimestamp) |
protected void |
MigrationClientVersion3xState.doEnter(ClientVersion fromClientVersion) |
protected void |
MigrationClientVersion2xState.doEnter(ClientVersion fromClientVersion) |
protected void |
MigrationClientVersion3xWithRollbackState.doEnter(ClientVersion fromClientVersion) |
protected void |
MigrationClientVersionUpgradeFrom2xState.doEnter(ClientVersion fromClientVersion) |
protected abstract void |
AbstractMigrationClientVersionState.doEnter(ClientVersion fromClientVersion)
State-specific enter logic.
|
void |
MigrationClientVersionInitState.enter(ClientVersion fromClientVersion) |
void |
AbstractMigrationClientVersionState.enter(ClientVersion fromClientVersion)
Template method that ensures DDB state matches this state's client version before
delegating to the state-specific
AbstractMigrationClientVersionState.doEnter(ClientVersion) logic. |
void |
MigrationClientVersionState.enter(ClientVersion fromClientVersion)
Enter the state and perform the business logic of being in this state
which includes performing any monitoring that allows the next state
transition and also initializing the KCL based on the ClientVersion.
|
void |
MigrationStateMachineImpl.transitionTo(ClientVersion nextClientVersion,
MigrationState migrationState) |
void |
MigrationStateMachine.transitionTo(ClientVersion nextClientVersion,
MigrationState state)
Peform transition from current state to the given new ClientVersion
|
MigrationState |
MigrationState.update(ClientVersion clientVersion,
String modifiedBy) |
Copyright © 2026. All rights reserved.