http4k-connect-amazon-dynamodb-fake/org.http4k.connect.amazon.dynamodb.endpoints

Package-level declarations

Types

FakeS3BucketSource

data class FakeS3BucketSource(val name: String, val csv: String)

TryModifyItem

fun interface TryModifyItem<T> : Function2<T, DynamoTable, UpdateResult>

UpdateResult

sealed interface UpdateResult

The result of an update operation

Functions

asItemResult

fun Item.asItemResult(): Map<String, Map<String, Any>>

batchExecuteStatement

fun AwsJsonFake.batchExecuteStatement(tables: Storage<DynamoTable>): RoutingHttpHandler

batchGetItem

fun AwsJsonFake.batchGetItem(tables: Storage<DynamoTable>): RoutingHttpHandler

batchWriteItem

fun AwsJsonFake.batchWriteItem(tables: Storage<DynamoTable>): RoutingHttpHandler

comparator

fun List<KeySchema>?.comparator(ascending: Boolean): Comparator<Item>

condition

fun Item.condition(expression: String?, expressionAttributeNames: TokensToNames?, expressionAttributeValues: TokensToValues?): Map<AttributeName, AttributeValue>?

Apply the conditional expression to the Item. If the condition is null or resolves to true returns the item, or returns null.

convert

inline fun <OUT : Any> convert(input: Any): OUT

createTable

fun AwsJsonFake.createTable(tables: Storage<DynamoTable>): RoutingHttpHandler

deleteItem

fun AwsJsonFake.deleteItem(tables: Storage<DynamoTable>): RoutingHttpHandler

deleteTable

fun AwsJsonFake.deleteTable(tables: Storage<DynamoTable>): RoutingHttpHandler

describeImport

fun AwsJsonFake.describeImport(tableImports: List<ImportTableDescription>): RoutingHttpHandler

describeTable

fun AwsJsonFake.describeTable(tables: Storage<DynamoTable>): RoutingHttpHandler

executeStatement

fun AwsJsonFake.executeStatement(tables: Storage<DynamoTable>): RoutingHttpHandler

executeTransaction

fun AwsJsonFake.executeTransaction(tables: Storage<DynamoTable>): RoutingHttpHandler

filterNullKeys

fun List<KeySchema>?.filterNullKeys(): (Item) -> Boolean

getItem

fun AwsJsonFake.getItem(tables: Storage<DynamoTable>): RoutingHttpHandler

importTable

fun AwsJsonFake.importTable(tables: Storage<DynamoTable>, addTableImport: (ImportTableDescription) -> Unit, availableS3Buckets: () -> List<FakeS3BucketSource>, clock: Clock): RoutingHttpHandler

key

fun Item.key(schema: List<KeySchema>): Key

keySchema

fun TableDescription.keySchema(indexName: IndexName? = null): List<KeySchema>?

listImports

fun AwsJsonFake.listImports(tableImports: List<ImportTableDescription>): RoutingHttpHandler

listTables

fun AwsJsonFake.listTables(tables: Storage<DynamoTable>): RoutingHttpHandler

project

fun Item.project(projectionExpression: String?, expressionAttributeNames: TokensToNames?): Item

Transform the input item by applying the projection to the fields in it.

putItem

fun AwsJsonFake.putItem(tables: Storage<DynamoTable>): RoutingHttpHandler

query

fun AwsJsonFake.query(tables: Storage<DynamoTable>): RoutingHttpHandler

scan

fun AwsJsonFake.scan(tables: Storage<DynamoTable>): RoutingHttpHandler

transactGetItems

fun AwsJsonFake.transactGetItems(tables: Storage<DynamoTable>): RoutingHttpHandler

transactWriteItems

fun AwsJsonFake.transactWriteItems(tables: Storage<DynamoTable>): RoutingHttpHandler

update

fun Item.update(expression: String?, expressionAttributeNames: TokensToNames?, expressionAttributeValues: TokensToValues?): Map<AttributeName, AttributeValue>

updateItem

fun AwsJsonFake.updateItem(tables: Storage<DynamoTable>): RoutingHttpHandler

updateTable

fun AwsJsonFake.updateTable(tables: Storage<DynamoTable>): RoutingHttpHandler