Uses of Class
software.amazon.kinesis.leases.exceptions.InvalidStateException

Packages that use InvalidStateException

Package	Description
software.amazon.kinesis.checkpoint.dynamodb
software.amazon.kinesis.coordinator
software.amazon.kinesis.coordinator.delegate
software.amazon.kinesis.coordinator.migration
software.amazon.kinesis.coordinator.streamInfo
software.amazon.kinesis.leases
software.amazon.kinesis.leases.dynamodb
software.amazon.kinesis.leases.exceptions
software.amazon.kinesis.lifecycle
software.amazon.kinesis.worker.metricstats
software.amazon.kinesis.worker.metricstats.delegate

Uses of InvalidStateException in software.amazon.kinesis.checkpoint.dynamodb

Methods in software.amazon.kinesis.checkpoint.dynamodb that throw InvalidStateException

Modifier and Type	Method and Description
boolean	DynamoDBCheckpointer.setCheckpoint(String leaseKey, ExtendedSequenceNumber checkpoint, UUID concurrencyToken)

Uses of InvalidStateException in software.amazon.kinesis.coordinator

Methods in software.amazon.kinesis.coordinator that throw InvalidStateException

Modifier and Type	Method and Description
boolean	CoordinatorStateDAO.createCoordinatorStateIfNotExists(@NonNull CoordinatorState state) Create a coordinator state if it does not already exist.
void	StreamInfoManager.createStreamInfo(StreamIdentifier streamIdentifier) Creates new streamInfo
boolean	CoordinatorStateDAO.deleteCoordinatorState(@NonNull String key) Delete a coordinator state by key.
void	StreamInfoManager.deleteStreamInfo(StreamIdentifier streamIdentifier) Deletes StreamInfo if it does exist.
CoordinatorState	CoordinatorStateDAO.getCoordinatorState(@NonNull String key) Get a single CoordinatorState by key.
void	CoordinatorStateDAO.initialize() Initialize the DAO for write operations.
List<CoordinatorState>	CoordinatorStateDAO.listCoordinatorState() List all coordinator states.
List<CoordinatorState>	CoordinatorStateDAO.listCoordinatorStateByEntityType(EntityType.CoordinatorStateType entityType) List coordinator states by entity type.
boolean	CoordinatorStateDAO.updateCoordinatorStateWithExpectation(@NonNull CoordinatorState state, Map<String,software.amazon.awssdk.services.dynamodb.model.ExpectedAttributeValue> expectations) Update a coordinator state with expectations.

Uses of InvalidStateException in software.amazon.kinesis.coordinator.delegate

Methods in software.amazon.kinesis.coordinator.delegate that throw InvalidStateException

Modifier and Type	Method and Description
boolean	LegacyTableCoordinatorStateDAODelegate.createCoordinatorStateIfNotExists(CoordinatorState state)
boolean	CoordinatorStateDAODelegate.createCoordinatorStateIfNotExists(CoordinatorState state) Create a new CoordinatorState if it does not exist.
boolean	LegacyTableCoordinatorStateDAODelegate.deleteCoordinatorState(String key)
boolean	CoordinatorStateDAODelegate.deleteCoordinatorState(@NonNull String key) Create a new CoordinatorState if it does not exist.
CoordinatorState	LegacyTableCoordinatorStateDAODelegate.getCoordinatorState(String key)
CoordinatorState	CoordinatorStateDAODelegate.getCoordinatorState(@NonNull String key)
List<CoordinatorState>	LegacyTableCoordinatorStateDAODelegate.listCoordinatorState()
List<CoordinatorState>	CoordinatorStateDAODelegate.listCoordinatorState() List all the CoordinatorState from the DDB table synchronously
List<CoordinatorState>	LegacyTableCoordinatorStateDAODelegate.listCoordinatorStateByEntityType(EntityType.CoordinatorStateType entityType)
List<CoordinatorState>	CoordinatorStateDAODelegate.listCoordinatorStateByEntityType(EntityType.CoordinatorStateType entityType) List all the CoordinatorState from the DDB table synchronously
boolean	LegacyTableCoordinatorStateDAODelegate.updateCoordinatorStateWithExpectation(CoordinatorState state, Map<String,software.amazon.awssdk.services.dynamodb.model.ExpectedAttributeValue> expectations)
boolean	CoordinatorStateDAODelegate.updateCoordinatorStateWithExpectation(@NonNull CoordinatorState state, Map<String,software.amazon.awssdk.services.dynamodb.model.ExpectedAttributeValue> expectations) Update fields of the given coordinator state in DynamoDB.

Uses of InvalidStateException in software.amazon.kinesis.coordinator.migration

Methods in software.amazon.kinesis.coordinator.migration that throw InvalidStateException

Modifier and Type	Method and Description
void	ClientVersionChangeMonitor.ClientVersionChangeCallback.accept(MigrationState currentMigrationState)
void	TableMigrationStateMachine.handleLeaderLockResult(boolean isLeader) Called after leader election to handle table migration state transitions that require leader ownership.
void	TableMigrationStateMachineImpl.handleLeaderLockResult(boolean isLeader)
void	TableMigrationStateMachine.initialize() Initialize the table migration state machine.
void	TableMigrationStateMachineImpl.initialize() Initialize TableMigrationStateMachine, there can be dependency exception when updating TableMigrationState in DDB or InvalidStateException when 2 phase deployment is not followed.
void	MigrationStateMachine.transitionTo(ClientVersion nextClientVersion, MigrationState state) Peform transition from current state to the given new ClientVersion

Uses of InvalidStateException in software.amazon.kinesis.coordinator.streamInfo

Methods in software.amazon.kinesis.coordinator.streamInfo that throw InvalidStateException

Modifier and Type	Method and Description
boolean	StreamInfoDAO.createStreamInfo(StreamIdentifier streamIdentifier) Create a new StreamInfo if it does not exist.
boolean	StreamInfoDAO.deleteStreamInfo(String key) Deletes StreamInfo if it does exist.
String	StreamIdCacheManager.get(StreamIdentifier streamIdentifier) Get a value from streamIdCache
StreamInfo	StreamInfoDAO.getStreamInfo(String key)
List<StreamInfo>	StreamInfoDAO.listStreamInfo() List all the StreamInfo from the DDB table synchronously

Uses of InvalidStateException in software.amazon.kinesis.leases

Methods in software.amazon.kinesis.leases that throw InvalidStateException

Modifier and Type	Method and Description
default boolean	LeaseRefresher.assignLease(Lease lease, String newOwner) Assigns given lease to newOwner owner by incrementing its leaseCounter and setting its owner field.
boolean	HierarchicalShardSyncer.checkAndCreateLeaseForNewShards(@NonNull ShardDetector shardDetector, LeaseRefresher leaseRefresher, InitialPositionInStreamExtended initialPosition, List<software.amazon.awssdk.services.kinesis.model.Shard> latestShards, boolean ignoreUnexpectedChildShards, MetricsScope scope, boolean isLeaseTableEmpty) Provide a pre-collected list of shards to avoid calling ListShards API
boolean	HierarchicalShardSyncer.checkAndCreateLeaseForNewShards(@NonNull ShardDetector shardDetector, LeaseRefresher leaseRefresher, InitialPositionInStreamExtended initialPosition, MetricsScope scope, boolean ignoreUnexpectedChildShards, boolean isLeaseTableEmpty) Check and create leases for any new shards (e.g.
LeaseCleanupManager.LeaseCleanupResult	LeaseCleanupManager.cleanupLease(LeasePendingDeletion leasePendingDeletion, boolean timeToCheckForCompletedShard, boolean timeToCheckForGarbageShard)
Lease	HierarchicalShardSyncer.createLeaseForChildShard(software.amazon.awssdk.services.kinesis.model.ChildShard childShard, StreamIdentifier streamIdentifier)
boolean	LeaseRefresher.createLeaseIfNotExists(Lease lease) Create a new lease.
void	LeaseRefresher.deleteAll() Delete all leases from DynamoDB.
void	LeaseRefresher.deleteLease(Lease lease) Delete the given lease from DynamoDB.
List<Lease>	LeaseDiscoverer.discoverNewLeases() Identifies the leases that are assigned to the current worker but are not being tracked and processed by the current worker.
boolean	LeaseRefresher.evictLease(Lease lease) Evict the current owner of lease by setting owner to null.
ExtendedSequenceNumber	LeaseRefresher.getCheckpoint(String leaseKey) Gets the current checkpoint of the shard.
Lease	LeaseRefresher.getLease(String leaseKey)
void	LeaseRenewer.initialize() Bootstrap initial set of leases from the LeaseRefresher (e.g.
default boolean	LeaseRefresher.initiateGracefulLeaseHandoff(Lease lease, String newOwner) Initiates a graceful handoff of the given lease to the specified new owner, allowing the current owner to complete its processing before transferring ownership.
boolean	LeaseRefresher.isLeaseTableEmpty() Check (synchronously) if there are any leases in the lease table.
default List<String>	LeaseRefresher.listLeaseKeysForWorker(String workerIdentifier) List all leases for a given workerIdentifier synchronously.
List<Lease>	LeaseRefresher.listLeases() List all objects in table synchronously.
List<Lease>	LeaseRefresher.listLeasesForStream(StreamIdentifier streamIdentifier) List all leases for a given stream synchronously.
default Map.Entry<List<Lease>,List<String>>	LeaseRefresher.listLeasesParallely(ExecutorService threadPool, int parallelismFactor) List all leases from the storage parallely and deserialize into Lease objects.
boolean	LeaseRefresher.renewLease(Lease lease) Renew a lease by incrementing the lease counter.
void	LeaseRenewer.renewLeases() Attempt to renew all currently held leases.
void	LeaseCoordinator.runLeaseRenewer() Runs a single iteration of the lease renewer - used by integration tests.
void	LeaseCoordinator.runLeaseTaker() Runs a single iteration of the lease taker - used by integration tests.
Map<EntityType,EntityDAO.EntityScanList>	EntityDAO.scanAllEntities() Scan all entities from the lease table and group them by their EntityType.
Map<EntityType,EntityDAO.EntityScanList>	EntityDAO.scanEntities(EntityType... entityTypes) Scan entities from the lease table filtered to only the specified entity types.
void	LeaseCoordinator.start(MigrationAdaptiveLeaseAssignmentModeProvider leaseAssignmentModeProvider) Start background LeaseHolder and LeaseTaker threads.
boolean	LeaseRefresher.takeLease(Lease lease, String owner) Take a lease for the given owner by incrementing its leaseCounter and setting its owner field.
Map<String,Lease>	LeaseTaker.takeLeases() Compute the set of leases available to be taken and attempt to take them.
boolean	LeaseRefresher.updateLease(Lease lease) Update application-specific fields of the given lease in DynamoDB.
boolean	LeaseCoordinator.updateLease(Lease lease, UUID concurrencyToken, String operation, String singleStreamShardId) Updates application-specific lease values in DynamoDB.
boolean	LeaseRenewer.updateLease(Lease lease, UUID concurrencyToken, String operation, String singleStreamShardId) Update application-specific fields in a currently held lease.
default void	LeaseRefresher.updateLeaseWithMetaInfo(Lease lease, UpdateField updateField) Update application-specific fields of the given lease in DynamoDB.

Uses of InvalidStateException in software.amazon.kinesis.leases.dynamodb

Methods in software.amazon.kinesis.leases.dynamodb that throw InvalidStateException

Modifier and Type	Method and Description
boolean	DynamoDBLeaseRefresher.assignLease(Lease lease, String newOwner) Assigns given lease to newOwner owner by incrementing its leaseCounter and setting its owner field.
protected DependencyException	DynamoDBLeaseRefresher.convertAndRethrowExceptions(String operation, String leaseKey, Exception e)
boolean	DynamoDBLeaseRefresher.createLeaseIfNotExists(@NonNull Lease lease) Create a new lease.
void	DynamoDBLeaseRefresher.deleteAll() Delete all leases from DynamoDB.
void	DynamoDBLeaseRefresher.deleteLease(@NonNull Lease lease) Delete the given lease from DynamoDB.
List<Lease>	DynamoDBLeaseDiscoverer.discoverNewLeases()
boolean	DynamoDBLeaseRefresher.evictLease(@NonNull Lease lease) Evict the current owner of lease by setting owner to null.
ExtendedSequenceNumber	DynamoDBLeaseRefresher.getCheckpoint(String leaseKey) Gets the current checkpoint of the shard.
Lease	DynamoDBLeaseRefresher.getLease(@NonNull String leaseKey)
void	DynamoDBLeaseRenewer.initialize() Bootstrap initial set of leases from the LeaseRefresher (e.g.
boolean	DynamoDBLeaseRefresher.initiateGracefulLeaseHandoff(Lease lease, String newOwner) Initiates a graceful handoff of the given lease to the specified new owner, allowing the current owner to complete its processing before transferring ownership.
boolean	DynamoDBLeaseRefresher.isLeaseTableEmpty() Check (synchronously) if there are any leases in the lease table.
List<String>	DynamoDBLeaseRefresher.listLeaseKeysForWorker(String workerIdentifier) List all leases for a given workerIdentifier synchronously.
List<Lease>	DynamoDBLeaseRefresher.listLeases() List all objects in table synchronously.
List<Lease>	DynamoDBLeaseRefresher.listLeasesForStream(StreamIdentifier streamIdentifier) List all leases for a given stream synchronously.
Map.Entry<List<Lease>,List<String>>	DynamoDBLeaseRefresher.listLeasesParallely(ExecutorService parallelScanExecutorService, int parallelScanTotalSegment)
boolean	DynamoDBLeaseRefresher.renewLease(@NonNull Lease lease) Renew a lease by incrementing the lease counter.
void	DynamoDBLeaseRenewer.renewLeases() Attempt to renew all currently held leases.
void	DynamoDBLeaseCoordinator.runLeaseRenewer()
void	DynamoDBLeaseCoordinator.runLeaseTaker()
Map<EntityType,EntityDAO.EntityScanList>	DynamoDBLeaseTableDao.scanAllEntities()
Map<EntityType,EntityDAO.EntityScanList>	DynamoDBLeaseTableDao.scanEntities(EntityType... entityTypes)
void	DynamoDBLeaseCoordinator.start(MigrationAdaptiveLeaseAssignmentModeProvider leaseAssignmentModeProvider)
boolean	DynamoDBLeaseRefresher.takeLease(@NonNull Lease lease, @NonNull String owner) Take a lease for the given owner by incrementing its leaseCounter and setting its owner field.
Map<String,Lease>	DynamoDBLeaseTaker.takeLeases() Compute the set of leases available to be taken and attempt to take them.
boolean	DynamoDBLeaseRefresher.updateLease(@NonNull Lease lease) Update application-specific fields of the given lease in DynamoDB.
boolean	DynamoDBLeaseRenewer.updateLease(Lease lease, UUID concurrencyToken, @NonNull String operation, String singleStreamShardId) Update application-specific fields in a currently held lease.
boolean	DynamoDBLeaseCoordinator.updateLease(Lease lease, UUID concurrencyToken, String operation, String singleStreamShardId)
void	DynamoDBLeaseRefresher.updateLeaseWithMetaInfo(Lease lease, UpdateField updateField)

Uses of InvalidStateException in software.amazon.kinesis.leases.exceptions

Methods in software.amazon.kinesis.leases.exceptions that throw InvalidStateException

Modifier and Type	Method and Description
static void	ShardSyncer.checkAndCreateLeasesForNewShards(@NonNull ShardDetector shardDetector, LeaseRefresher leaseRefresher, InitialPositionInStreamExtended initialPosition, boolean ignoreUnexpectedChildShards, MetricsScope scope) Deprecated.

Uses of InvalidStateException in software.amazon.kinesis.lifecycle

Methods in software.amazon.kinesis.lifecycle that throw InvalidStateException

Modifier and Type	Method and Description
static void	LeaseGracefulShutdownHandler.attemptLeaseTransfer(Lease lease, LeaseCoordinator leaseCoordinator)

Uses of InvalidStateException in software.amazon.kinesis.worker.metricstats

Methods in software.amazon.kinesis.worker.metricstats that throw InvalidStateException

Modifier and Type	Method and Description
boolean	WorkerMetricStatsDAO.deleteMetrics(WorkerMetricStats workerMetrics) Delete the worker metric stats entry with a conditional check on lastUpdateTime.
List<WorkerMetricStats>	WorkerMetricStatsDAO.getAllWorkerMetricStats() Get all worker metric stats by combining results from both delegates.
void	WorkerMetricStatsDAO.updateMetrics(WorkerMetricStats workerMetrics) Update (or create) the worker metric stats for a given worker.

Uses of InvalidStateException in software.amazon.kinesis.worker.metricstats.delegate

Methods in software.amazon.kinesis.worker.metricstats.delegate that throw InvalidStateException

Modifier and Type	Method and Description
boolean	WorkerMetricStatsDAODelegate.deleteMetrics(WorkerMetricStats workerMetrics) Delete the worker metric stats entry with a conditional check on lastUpdateTime.
boolean	LegacyTableWorkerMetricStatsDAODelegate.deleteMetrics(WorkerMetricStats workerMetrics)
abstract List<WorkerMetricStats>	WorkerMetricStatsDAODelegate.getAllWorkerMetricStats() Retrieve all worker metric stats entries from the backing table
List<WorkerMetricStats>	LegacyTableWorkerMetricStatsDAODelegate.getAllWorkerMetricStats() Retrieve all worker metric stats entries from the backing table.
List<WorkerMetricStats>	LeaseTableWorkerMetricStatsDAODelegate.getAllWorkerMetricStats() Retrieve all worker metric stats entries from the backing table, filtered by entityType = WORKER_METRIC_STATS.
void	WorkerMetricStatsDAODelegate.updateMetrics(WorkerMetricStats workerMetrics) Update (or create) the worker metric stats for a given worker.
void	LegacyTableWorkerMetricStatsDAODelegate.updateMetrics(WorkerMetricStats workerMetrics)
void	LeaseTableWorkerMetricStatsDAODelegate.updateMetrics(WorkerMetricStats workerMetrics)