//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> |