| Package | Description |
|---|---|
| software.amazon.kinesis.coordinator.streamInfo | |
| software.amazon.kinesis.leases | |
| software.amazon.kinesis.leases.dynamodb |
| Modifier and Type | Method and Description |
|---|---|
static StreamIdOnboardingState |
StreamIdOnboardingState.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static StreamIdOnboardingState[] |
StreamIdOnboardingState.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
StreamIdCache.initialize(StreamIdCacheManager cacheManager,
StreamIdOnboardingState onboardingState) |
| Constructor and Description |
|---|
StreamIdCacheManager(ScheduledExecutorService scheduledExecutorService,
StreamInfoDAO streamInfoDAO,
Map<StreamIdentifier,StreamConfig> currentStreamConfigMap,
StreamIdOnboardingState streamIdOnboardingState,
boolean isMultiStreamMode,
@NotNull MetricsFactory metricsFactory) |
| Modifier and Type | Method and Description |
|---|---|
StreamIdCacheManager |
LeaseManagementFactory.createStreamIdCacheManager(StreamInfoDAO streamInfoDAO,
Map<StreamIdentifier,StreamConfig> currentStreamConfigMap,
StreamIdOnboardingState streamIdOnboardingState,
boolean isMultiStreamMode,
MetricsFactory metricsFactory) |
StreamInfoManager |
LeaseManagementFactory.createStreamInfoManager(Map<StreamIdentifier,StreamConfig> currentStreamConfigMap,
StreamInfoDAO streamInfoDAO,
MetricsFactory metricsFactory,
boolean isMultiStreamMode,
long streamInfoBackfillIntervalMillis,
StreamInfoMode streamInfoMode,
StreamIdOnboardingState streamIdOnboardingState) |
| Modifier and Type | Method and Description |
|---|---|
StreamIdCacheManager |
DynamoDBLeaseManagementFactory.createStreamIdCacheManager(StreamInfoDAO streamInfoDAO,
Map<StreamIdentifier,StreamConfig> currentStreamConfigMap,
StreamIdOnboardingState streamIdOnboardingState,
boolean isMultiStreamMode,
MetricsFactory metricsFactory) |
StreamInfoManager |
DynamoDBLeaseManagementFactory.createStreamInfoManager(Map<StreamIdentifier,StreamConfig> currentStreamConfigMap,
StreamInfoDAO streamInfoDAO,
MetricsFactory metricsFactory,
boolean isMultiStreamMode,
long streamInfoBackfillIntervalMillis,
StreamInfoMode streamInfoMode,
StreamIdOnboardingState streamIdOnboardingState) |
Copyright © 2026. All rights reserved.