| Package | Description |
|---|---|
| software.amazon.kinesis.coordinator.streamInfo | |
| software.amazon.kinesis.leases | |
| software.amazon.kinesis.leases.dynamodb |
| Modifier and Type | Method and Description |
|---|---|
static void |
StreamIdCache.initialize(StreamIdCacheManager cacheManager,
StreamIdOnboardingState onboardingState) |
| Modifier and Type | Method and Description |
|---|---|
StreamIdCacheManager |
LeaseManagementFactory.createStreamIdCacheManager(StreamInfoDAO streamInfoDAO,
Map<StreamIdentifier,StreamConfig> currentStreamConfigMap,
StreamIdOnboardingState streamIdOnboardingState,
boolean isMultiStreamMode,
MetricsFactory metricsFactory) |
| Modifier and Type | Method and Description |
|---|---|
default LeaseCoordinator |
LeaseManagementFactory.createLeaseCoordinator(MetricsFactory metricsFactory,
ConcurrentMap<ShardInfo,ShardConsumer> shardInfoShardConsumerMap,
StreamIdCacheManager streamIdCacheManager) |
| Modifier and Type | Method and Description |
|---|---|
StreamIdCacheManager |
DynamoDBLeaseManagementFactory.createStreamIdCacheManager(StreamInfoDAO streamInfoDAO,
Map<StreamIdentifier,StreamConfig> currentStreamConfigMap,
StreamIdOnboardingState streamIdOnboardingState,
boolean isMultiStreamMode,
MetricsFactory metricsFactory) |
| Modifier and Type | Method and Description |
|---|---|
LeaseCoordinator |
DynamoDBLeaseManagementFactory.createLeaseCoordinator(MetricsFactory metricsFactory,
ConcurrentMap<ShardInfo,ShardConsumer> shardInfoShardConsumerMap,
StreamIdCacheManager streamIdCacheManager) |
| Constructor and Description |
|---|
DynamoDBLeaseCoordinator(LeaseRefresher leaseRefresher,
String workerIdentifier,
long leaseDurationMillis,
boolean enablePriorityLeaseAssignment,
long epsilonMillis,
int maxLeasesForWorker,
int maxLeasesToStealAtOneTime,
int maxLeaseRenewerThreadCount,
long initialLeaseTableReadCapacity,
long initialLeaseTableWriteCapacity,
MetricsFactory metricsFactory,
LeaseManagementConfig.WorkerUtilizationAwareAssignmentConfig workerUtilizationAwareAssignmentConfig,
LeaseManagementConfig.GracefulLeaseHandoffConfig gracefulLeaseHandoffConfig,
ConcurrentMap<ShardInfo,ShardConsumer> shardInfoShardConsumerMap,
long leaseAssignmentIntervalMillis,
StreamIdCacheManager streamIdCacheManager)
Constructor.
|
DynamoDBLeaseTaker(LeaseRefresher leaseRefresher,
String workerIdentifier,
long leaseDurationMillis,
MetricsFactory metricsFactory,
StreamIdCacheManager streamIdCacheManager) |
Copyright © 2026. All rights reserved.