Skip to content

//tempest2/app.cash.tempest2/AsyncLogicalDb

AsyncLogicalDb

[jvm]\ interface AsyncLogicalDb : AsyncLogicalTable.Factory

A collection of tables that implement the DynamoDB best practice of putting multiple item types into the same storage table. This makes it possible to perform aggregate operations and transactions on those item types.

Types

Name Summary
Companion [jvm]
object Companion

Functions

Name Summary
batchLoad [jvm]
open suspend fun batchLoad(vararg keys: Any, consistentReads: Boolean = false, maxPageSize: Int = MAX_BATCH_READ): ItemSet
open suspend fun batchLoad(keys: Iterable<Any>, consistentReads: Boolean = false, maxPageSize: Int = MAX_BATCH_READ): ItemSet
[jvm]
open suspend fun batchLoad(keys: KeySet, consistentReads: Boolean = false, maxPageSize: Int = MAX_BATCH_READ, returnConsumedCapacity: ReturnConsumedCapacity = ReturnConsumedCapacity.NONE): ItemSet
Retrieves multiple items from multiple tables using their primary keys.
batchLoadAsync [jvm]
open fun batchLoadAsync(keys: Iterable<Any>): Publisher<ItemSet>
open fun batchLoadAsync(keys: KeySet, consistentReads: Boolean, returnConsumedCapacity: ReturnConsumedCapacity = ReturnConsumedCapacity.NONE): Publisher<ItemSet>
open fun batchLoadAsync(vararg keys: Any, consistentReads: Boolean, returnConsumedCapacity: ReturnConsumedCapacity = ReturnConsumedCapacity.NONE): Publisher<ItemSet>
open fun batchLoadAsync(keys: Iterable<Any>, consistentReads: Boolean, returnConsumedCapacity: ReturnConsumedCapacity = ReturnConsumedCapacity.NONE): Publisher<ItemSet>
abstract fun batchLoadAsync(keys: KeySet, consistentReads: Boolean, maxPageSize: Int, returnConsumedCapacity: ReturnConsumedCapacity = ReturnConsumedCapacity.NONE): Publisher<ItemSet>
batchWrite [jvm]
@CheckReturnValue
open suspend fun batchWrite(writeSet: BatchWriteSet, maxPageSize: Int = MAX_BATCH_WRITE): BatchWriteResult
Saves and deletes the objects given using one or more calls to the DynamoDbClient.batchWriteItem API. Callers should always check the returned BatchWriteResult because this method returns normally even if some writes were not performed.
batchWriteAsync [jvm]
abstract fun batchWriteAsync(writeSet: BatchWriteSet, maxPageSize: Int = MAX_BATCH_WRITE): CompletableFuture<BatchWriteResult>
logicalTable [jvm]
abstract fun <T : AsyncLogicalTable<RI>, RI : Any> logicalTable(tableName: String, tableType: KClass<T>): T
transactionLoad [jvm]
open suspend fun transactionLoad(keys: KeySet): ItemSet
Transactionally loads objects specified by transactionLoadRequest by calling DynamoDbClient.transactGetItems API.
[jvm]
open suspend fun transactionLoad(vararg keys: Any): ItemSet
open suspend fun transactionLoad(keys: Iterable<Any>): ItemSet
transactionLoadAsync [jvm]
abstract fun transactionLoadAsync(keys: KeySet): CompletableFuture<ItemSet>
open fun transactionLoadAsync(vararg keys: Any): CompletableFuture<ItemSet>
open fun transactionLoadAsync(keys: Iterable<Any>): CompletableFuture<ItemSet>
transactionWrite [jvm]
open suspend fun transactionWrite(writeSet: TransactionWriteSet)
Transactionally writes objects specified by transactionWriteRequest by calling DynamoDbClient.transactWriteItems API.
transactionWriteAsync [jvm]
abstract fun transactionWriteAsync(writeSet: TransactionWriteSet): CompletableFuture<Void>