t
com.github.j5ik2o.reactive.aws.dynamodb.akka
DynamoDbAkkaClient
Companion object DynamoDbAkkaClient
trait DynamoDbAkkaClient extends AnyRef
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- DynamoDbAkkaClient
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Abstract Value Members
- abstract val underlying: DynamoDbAsyncClient
Concrete Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
- def batchGetItemFlow(parallelism: Int = DefaultParallelism): Flow[BatchGetItemRequest, BatchGetItemResponse, NotUsed]
- def batchGetItemPaginatorFlow: Flow[BatchGetItemRequest, BatchGetItemResponse, NotUsed]
- def batchGetItemSource(batchGetItemRequest: BatchGetItemRequest, parallelism: Int = DefaultParallelism): Source[BatchGetItemResponse, NotUsed]
- def batchWriteItemFlow(parallelism: Int = DefaultParallelism): Flow[BatchWriteItemRequest, BatchWriteItemResponse, NotUsed]
- def batchWriteItemSource(batchWriteItemRequest: BatchWriteItemRequest, parallelism: Int = DefaultParallelism): Source[BatchWriteItemResponse, NotUsed]
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
- def createBackupFlow(parallelism: Int = DefaultParallelism): Flow[CreateBackupRequest, CreateBackupResponse, NotUsed]
- def createBackupSource(createBackupRequest: CreateBackupRequest, parallelism: Int = DefaultParallelism): Source[CreateBackupResponse, NotUsed]
- def createGlobalTableFlow(parallelism: Int = DefaultParallelism): Flow[CreateGlobalTableRequest, CreateGlobalTableResponse, NotUsed]
- def createGlobalTableSource(createGlobalTableRequest: CreateGlobalTableRequest, parallelism: Int = DefaultParallelism): Source[CreateGlobalTableResponse, NotUsed]
- def createTableFlow(parallelism: Int = DefaultParallelism): Flow[CreateTableRequest, CreateTableResponse, NotUsed]
- def createTableSource(createTableRequest: CreateTableRequest, parallelism: Int = DefaultParallelism): Source[CreateTableResponse, NotUsed]
- def deleteBackupFlow(parallelism: Int = DefaultParallelism): Flow[DeleteBackupRequest, DeleteBackupResponse, NotUsed]
- def deleteBackupSource(deleteBackupRequest: DeleteBackupRequest, parallelism: Int = DefaultParallelism): Source[DeleteBackupResponse, NotUsed]
- def deleteItemFlow(parallelism: Int = DefaultParallelism): Flow[DeleteItemRequest, DeleteItemResponse, NotUsed]
- def deleteItemSource(deleteItemRequest: DeleteItemRequest, parallelism: Int = DefaultParallelism): Source[DeleteItemResponse, NotUsed]
- def deleteTableFlow(parallelism: Int = DefaultParallelism): Flow[DeleteTableRequest, DeleteTableResponse, NotUsed]
- def deleteTableSource(deleteTableRequest: DeleteTableRequest, parallelism: Int = DefaultParallelism): Source[DeleteTableResponse, NotUsed]
- def describeBackupFlow(parallelism: Int = DefaultParallelism): Flow[DescribeBackupRequest, DescribeBackupResponse, NotUsed]
- def describeBackupSource(describeBackupRequest: DescribeBackupRequest, parallelism: Int = DefaultParallelism): Source[DescribeBackupResponse, NotUsed]
- def describeContinuousBackupsFlow(parallelism: Int = DefaultParallelism): Flow[DescribeContinuousBackupsRequest, DescribeContinuousBackupsResponse, NotUsed]
- def describeContinuousBackupsSource(describeContinuousBackupsRequest: DescribeContinuousBackupsRequest, parallelism: Int = DefaultParallelism): Source[DescribeContinuousBackupsResponse, NotUsed]
- def describeEndpointsFlow(parallelism: Int = DefaultParallelism): Flow[DescribeEndpointsRequest, DescribeEndpointsResponse, NotUsed]
- def describeEndpointsSource(): Source[DescribeEndpointsResponse, NotUsed]
- def describeEndpointsSource(describeEndpointsRequest: DescribeEndpointsRequest, parallelism: Int = DefaultParallelism): Source[DescribeEndpointsResponse, NotUsed]
- def describeGlobalTableFlow(parallelism: Int = DefaultParallelism): Flow[DescribeGlobalTableRequest, DescribeGlobalTableResponse, NotUsed]
- def describeGlobalTableSettingsFlow(parallelism: Int = DefaultParallelism): Flow[DescribeGlobalTableSettingsRequest, DescribeGlobalTableSettingsResponse, NotUsed]
- def describeGlobalTableSettingsSource(describeGlobalTableSettingsRequest: DescribeGlobalTableSettingsRequest, parallelism: Int = DefaultParallelism): Source[DescribeGlobalTableSettingsResponse, NotUsed]
- def describeGlobalTableSource(describeGlobalTableRequest: DescribeGlobalTableRequest, parallelism: Int = DefaultParallelism): Source[DescribeGlobalTableResponse, NotUsed]
- def describeLimitsFlow(parallelism: Int = DefaultParallelism): Flow[DescribeLimitsRequest, DescribeLimitsResponse, NotUsed]
- def describeLimitsSource(): Source[DescribeLimitsResponse, NotUsed]
- def describeLimitsSource(describeLimitsRequest: DescribeLimitsRequest, parallelism: Int = DefaultParallelism): Source[DescribeLimitsResponse, NotUsed]
- def describeTableFlow(parallelism: Int = DefaultParallelism): Flow[DescribeTableRequest, DescribeTableResponse, NotUsed]
- def describeTableSource(describeTableRequest: DescribeTableRequest, parallelism: Int = DefaultParallelism): Source[DescribeTableResponse, NotUsed]
- def describeTimeToLiveFlow(parallelism: Int = DefaultParallelism): Flow[DescribeTimeToLiveRequest, DescribeTimeToLiveResponse, NotUsed]
- def describeTimeToLiveSource(describeTimeToLiveRequest: DescribeTimeToLiveRequest, parallelism: Int = DefaultParallelism): Source[DescribeTimeToLiveResponse, NotUsed]
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def getItemFlow(parallelism: Int = DefaultParallelism): Flow[GetItemRequest, GetItemResponse, NotUsed]
- def getItemSource(getItemRequest: GetItemRequest, parallelism: Int = DefaultParallelism): Source[GetItemResponse, NotUsed]
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def listBackupsFlow(parallelism: Int = DefaultParallelism): Flow[ListBackupsRequest, ListBackupsResponse, NotUsed]
- def listBackupsSource(): Source[ListBackupsResponse, NotUsed]
- def listBackupsSource(listBackupsRequest: ListBackupsRequest, parallelism: Int = DefaultParallelism): Source[ListBackupsResponse, NotUsed]
- def listGlobalTablesFlow(parallelism: Int = DefaultParallelism): Flow[ListGlobalTablesRequest, ListGlobalTablesResponse, NotUsed]
- def listGlobalTablesSource(): Source[ListGlobalTablesResponse, NotUsed]
- def listGlobalTablesSource(listGlobalTablesRequest: ListGlobalTablesRequest, parallelism: Int = DefaultParallelism): Source[ListGlobalTablesResponse, NotUsed]
- def listTablesFlow(parallelism: Int = DefaultParallelism): Flow[ListTablesRequest, ListTablesResponse, NotUsed]
- def listTablesPaginatorFlow: Flow[ListTablesRequest, ListTablesResponse, NotUsed]
- def listTablesPaginatorSource: Source[ListTablesResponse, NotUsed]
- def listTablesSource(): Source[ListTablesResponse, NotUsed]
- def listTablesSource(listTablesRequest: ListTablesRequest, parallelism: Int = DefaultParallelism): Source[ListTablesResponse, NotUsed]
- def listTagsOfResourceFlow(parallelism: Int = DefaultParallelism): Flow[ListTagsOfResourceRequest, ListTagsOfResourceResponse, NotUsed]
- def listTagsOfResourceSource(listTagsOfResourceRequest: ListTagsOfResourceRequest, parallelism: Int = DefaultParallelism): Source[ListTagsOfResourceResponse, NotUsed]
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def putItemFlow(parallelism: Int = DefaultParallelism): Flow[PutItemRequest, PutItemResponse, NotUsed]
- def putItemSource(putItemRequest: PutItemRequest, parallelism: Int = DefaultParallelism): Source[PutItemResponse, NotUsed]
- def queryFlow(parallelism: Int = DefaultParallelism): Flow[QueryRequest, QueryResponse, NotUsed]
- def queryPaginatorFlow: Flow[QueryRequest, QueryResponse, NotUsed]
- def querySource(queryRequest: QueryRequest, parallelism: Int = DefaultParallelism): Source[QueryResponse, NotUsed]
- def restoreTableFromBackupFlow(parallelism: Int = DefaultParallelism): Flow[RestoreTableFromBackupRequest, RestoreTableFromBackupResponse, NotUsed]
- def restoreTableFromBackupSource(restoreTableFromBackupRequest: RestoreTableFromBackupRequest, parallelism: Int = DefaultParallelism): Source[RestoreTableFromBackupResponse, NotUsed]
- def restoreTableToPointInTimeFlow(parallelism: Int = DefaultParallelism): Flow[RestoreTableToPointInTimeRequest, RestoreTableToPointInTimeResponse, NotUsed]
- def restoreTableToPointInTimeSource(restoreTableToPointInTimeRequest: RestoreTableToPointInTimeRequest, parallelism: Int = DefaultParallelism): Source[RestoreTableToPointInTimeResponse, NotUsed]
- def scanFlow(parallelism: Int = DefaultParallelism): Flow[ScanRequest, ScanResponse, NotUsed]
- def scanPaginatorFlow: Flow[ScanRequest, ScanResponse, NotUsed]
- def scanSource(scanRequest: ScanRequest, parallelism: Int = DefaultParallelism): Source[ScanResponse, NotUsed]
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
- def tagResourceFlow(parallelism: Int = DefaultParallelism): Flow[TagResourceRequest, TagResourceResponse, NotUsed]
- def tagResourceSource(tagResourceRequest: TagResourceRequest, parallelism: Int = DefaultParallelism): Source[TagResourceResponse, NotUsed]
-
def
toString(): String
- Definition Classes
- AnyRef → Any
- def transactGetItemsFlow(parallelism: Int = DefaultParallelism): Flow[TransactGetItemsRequest, TransactGetItemsResponse, NotUsed]
- def transactGetItemsSource(transactGetItemsRequest: TransactGetItemsRequest, parallelism: Int = DefaultParallelism): Source[TransactGetItemsResponse, NotUsed]
- def transactWriteItemsFlow(parallelism: Int = DefaultParallelism): Flow[TransactWriteItemsRequest, TransactWriteItemsResponse, NotUsed]
- def transactWriteItemsSource(transactWriteItemsRequest: TransactWriteItemsRequest, parallelism: Int = DefaultParallelism): Source[TransactWriteItemsResponse, NotUsed]
- def untagResourceFlow(parallelism: Int = DefaultParallelism): Flow[UntagResourceRequest, UntagResourceResponse, NotUsed]
- def untagResourceSource(untagResourceRequest: UntagResourceRequest, parallelism: Int = DefaultParallelism): Source[UntagResourceResponse, NotUsed]
- def updateContinuousBackupsFlow(parallelism: Int = DefaultParallelism): Flow[UpdateContinuousBackupsRequest, UpdateContinuousBackupsResponse, NotUsed]
- def updateContinuousBackupsSource(updateContinuousBackupsRequest: UpdateContinuousBackupsRequest, parallelism: Int = DefaultParallelism): Source[UpdateContinuousBackupsResponse, NotUsed]
- def updateGlobalTableFlow(parallelism: Int = DefaultParallelism): Flow[UpdateGlobalTableRequest, UpdateGlobalTableResponse, NotUsed]
- def updateGlobalTableSettingsFlow(parallelism: Int = DefaultParallelism): Flow[UpdateGlobalTableSettingsRequest, UpdateGlobalTableSettingsResponse, NotUsed]
- def updateGlobalTableSettingsSource(updateGlobalTableSettingsRequest: UpdateGlobalTableSettingsRequest, parallelism: Int = DefaultParallelism): Source[UpdateGlobalTableSettingsResponse, NotUsed]
- def updateGlobalTableSource(updateGlobalTableRequest: UpdateGlobalTableRequest, parallelism: Int = DefaultParallelism): Source[UpdateGlobalTableResponse, NotUsed]
- def updateItemFlow(parallelism: Int = DefaultParallelism): Flow[UpdateItemRequest, UpdateItemResponse, NotUsed]
- def updateItemSource(updateItemRequest: UpdateItemRequest, parallelism: Int = DefaultParallelism): Source[UpdateItemResponse, NotUsed]
- def updateTableFlow(parallelism: Int = DefaultParallelism): Flow[UpdateTableRequest, UpdateTableResponse, NotUsed]
- def updateTableSource(updateTableRequest: UpdateTableRequest, parallelism: Int = DefaultParallelism): Source[UpdateTableResponse, NotUsed]
- def updateTimeToLiveFlow(parallelism: Int = DefaultParallelism): Flow[UpdateTimeToLiveRequest, UpdateTimeToLiveResponse, NotUsed]
- def updateTimeToLiveSource(updateTimeToLiveRequest: UpdateTimeToLiveRequest, parallelism: Int = DefaultParallelism): Source[UpdateTimeToLiveResponse, NotUsed]
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )