Crate faucet_sink_dynamodb 

faucet-sink-dynamodb

Amazon DynamoDB sink connector for faucet-stream: batched BatchWriteItem writes (≤ 25 items / 16 MB per request) with unprocessed-item retry, write_mode: append | upsert | delete keyed on the table key schema, per-row outcomes for the DLQ via write_batch_partial, and optional conditional writes (condition_expression) for idempotent re-delivery.

Structs

DynamoDbSink

Amazon DynamoDB sink. See the crate README for semantics.

DynamoDbSinkConfig

Configuration for DynamoDbSink.

RetryPolicy

Retry/backoff settings exposed on both connector configs.

Enums

DynamoDbCredentials

How to authenticate with AWS DynamoDB (and DynamoDB Streams).

OnConditionFailure

What a failed condition_expression means.

ValueFormat

How records carry attribute values: plain JSON (the default) or DynamoDB’s typed attribute JSON ({"pk": {"S": "a"}, "tags": {"SS": [..]}}). typed keeps sets, binaries and numbers of any precision exactly, so a DynamoDB-to-DynamoDB copy round-trips every attribute type.

Constants

DESCRIPTOR

The connector’s static descriptor (RFC 0013): its capabilities, answered from config alone.

MAX_BATCH_ITEMS

BatchWriteItem’s per-request item ceiling.

MAX_ITEM_BYTES

DynamoDB’s per-item size ceiling.

MAX_REQUEST_BYTES

BatchWriteItem’s per-request size ceiling.

Functions

build_client

Build an aws_sdk_dynamodb::Client. endpoint_url overrides the endpoint for DynamoDB Local / LocalStack / VPC endpoints. No network I/O.