software.amazon.kinesis.leases

Interface LeaseManagementFactory

All Known Implementing Classes:

DynamoDBLeaseManagementFactory

public interface LeaseManagementFactory

Method Summary

Modifier and Type	Method and Description
LeaseCleanupManager	createLeaseCleanupManager(MetricsFactory metricsFactory)
LeaseCoordinator	createLeaseCoordinator(MetricsFactory metricsFactory)
default LeaseCoordinator	createLeaseCoordinator(MetricsFactory metricsFactory, ConcurrentMap<ShardInfo,ShardConsumer> shardInfoShardConsumerMap) Deprecated.
default LeaseCoordinator	createLeaseCoordinator(MetricsFactory metricsFactory, ConcurrentMap<ShardInfo,ShardConsumer> shardInfoShardConsumerMap, StreamIdCacheManager streamIdCacheManager)
DynamoDBLeaseRefresher	createLeaseRefresher()
default ShardDetector	createShardDetector() Deprecated. This method is never invoked, please remove implementation of this method as it will be removed in future releases.
default ShardDetector	createShardDetector(StreamConfig streamConfig)
default ShardSyncTaskManager	createShardSyncTaskManager(MetricsFactory metricsFactory) Deprecated. This method is never invoked, please remove implementation of this method as it will be removed in future releases.
default ShardSyncTaskManager	createShardSyncTaskManager(MetricsFactory metricsFactory, StreamConfig streamConfig) Deprecated. This method is never invoked, please remove implementation of this method as it will be removed in future releases.
default ShardSyncTaskManager	createShardSyncTaskManager(MetricsFactory metricsFactory, StreamConfig streamConfig, DeletedStreamListProvider deletedStreamListProvider) Deprecated.
default ShardSyncTaskManager	createShardSyncTaskManager(MetricsFactory metricsFactory, StreamConfig streamConfig, DeletedStreamListProvider deletedStreamListProvider, StreamInfoManager streamInfoManager)
StreamIdCacheManager	createStreamIdCacheManager(StreamInfoDAO streamInfoDAO, Map<StreamIdentifier,StreamConfig> currentStreamConfigMap, StreamIdOnboardingState streamIdOnboardingState, boolean isMultiStreamMode, MetricsFactory metricsFactory)
StreamInfoManager	createStreamInfoManager(Map<StreamIdentifier,StreamConfig> currentStreamConfigMap, StreamInfoDAO streamInfoDAO, MetricsFactory metricsFactory, boolean isMultiStreamMode, long streamInfoBackfillIntervalMillis, StreamInfoMode streamInfoMode, StreamIdOnboardingState streamIdOnboardingState)

Method Detail

createLeaseCoordinator

LeaseCoordinator createLeaseCoordinator(MetricsFactory metricsFactory)

createLeaseCoordinator

@Deprecated
default LeaseCoordinator createLeaseCoordinator(MetricsFactory metricsFactory,
                                                            ConcurrentMap<ShardInfo,ShardConsumer> shardInfoShardConsumerMap)

Deprecated.

createLeaseCoordinator

default LeaseCoordinator createLeaseCoordinator(MetricsFactory metricsFactory,
                                                ConcurrentMap<ShardInfo,ShardConsumer> shardInfoShardConsumerMap,
                                                StreamIdCacheManager streamIdCacheManager)

createShardSyncTaskManager

@Deprecated
default ShardSyncTaskManager createShardSyncTaskManager(MetricsFactory metricsFactory)

Deprecated. This method is never invoked, please remove implementation of this method as it will be removed in future releases.

createShardSyncTaskManager

@Deprecated
default ShardSyncTaskManager createShardSyncTaskManager(MetricsFactory metricsFactory,
                                                                    StreamConfig streamConfig)

Deprecated. This method is never invoked, please remove implementation of this method as it will be removed in future releases.

createShardSyncTaskManager

@Deprecated
default ShardSyncTaskManager createShardSyncTaskManager(MetricsFactory metricsFactory,
                                                                    StreamConfig streamConfig,
                                                                    DeletedStreamListProvider deletedStreamListProvider)

Deprecated.

createShardSyncTaskManager

default ShardSyncTaskManager createShardSyncTaskManager(MetricsFactory metricsFactory,
                                                        StreamConfig streamConfig,
                                                        DeletedStreamListProvider deletedStreamListProvider,
                                                        StreamInfoManager streamInfoManager)

createLeaseRefresher

DynamoDBLeaseRefresher createLeaseRefresher()

createShardDetector

@Deprecated
default ShardDetector createShardDetector()

Deprecated. This method is never invoked, please remove implementation of this method as it will be removed in future releases.

createShardDetector

default ShardDetector createShardDetector(StreamConfig streamConfig)

createLeaseCleanupManager

LeaseCleanupManager createLeaseCleanupManager(MetricsFactory metricsFactory)

createStreamIdCacheManager

StreamIdCacheManager createStreamIdCacheManager(StreamInfoDAO streamInfoDAO,
                                                Map<StreamIdentifier,StreamConfig> currentStreamConfigMap,
                                                StreamIdOnboardingState streamIdOnboardingState,
                                                boolean isMultiStreamMode,
                                                MetricsFactory metricsFactory)

createStreamInfoManager

StreamInfoManager createStreamInfoManager(Map<StreamIdentifier,StreamConfig> currentStreamConfigMap,
                                          StreamInfoDAO streamInfoDAO,
                                          MetricsFactory metricsFactory,
                                          boolean isMultiStreamMode,
                                          long streamInfoBackfillIntervalMillis,
                                          StreamInfoMode streamInfoMode,
                                          StreamIdOnboardingState streamIdOnboardingState)