| Constructor and Description |
|---|
CoordinatorStateDAO(software.amazon.awssdk.services.dynamodb.DynamoDbAsyncClient dynamoDbAsyncClient,
CoordinatorConfig.CoordinatorStateTableConfig coordinatorStateTableConfig,
String leaseTableName,
TableMigrationStatusProvider tableMigrationStatusProvider) |
| Constructor and Description |
|---|
MigrationAwareLAMDataManager(EntityDAO entityDAO,
WorkerMetricStatsDAO workerMetricsDAO,
TableMigrationStatusProvider tableMigrationStatusProvider,
Consumer<TableMigrationSummary> migrationSummaryConsumer,
LeaseManagementConfig.WorkerUtilizationAwareAssignmentConfig config,
ExecutorService executorService) |
| Constructor and Description |
|---|
TableMigrationStateMachineImpl(TableMigrationStatusProvider statusProvider,
CoordinatorStateDAO coordinatorStateDAO,
String workerId,
CoordinatorConfig coordinatorConfig,
ExecutorService migrationExecutor) |
| Constructor and Description |
|---|
WorkerMetricStatsDAO(software.amazon.awssdk.services.dynamodb.DynamoDbAsyncClient dynamoDbAsyncClient,
LeaseManagementConfig.WorkerMetricsTableConfig workerMetricsTableConfig,
String leaseTableName,
Long workerMetricsReporterFrequencyMillis,
TableMigrationStatusProvider tableMigrationStatusProvider) |
Copyright © 2026. All rights reserved.