faucet_sink_dynamodb/lib.rs
1#![cfg_attr(docsrs, feature(doc_cfg))]
2
3//! # faucet-sink-dynamodb
4//!
5//! Amazon DynamoDB sink connector for
6//! [faucet-stream](https://github.com/faucet-hq/faucet-stream): batched
7//! `BatchWriteItem` writes (≤ 25 items / 16 MB per request) with
8//! unprocessed-item retry, `write_mode: append | upsert | delete` keyed on
9//! the table key schema, per-row outcomes for the DLQ via
10//! `write_batch_partial`, and optional conditional writes
11//! (`condition_expression`) for idempotent re-delivery.
12
13mod config;
14mod plan;
15mod sink;
16#[cfg(test)]
17mod test_support;
18
19pub use config::{
20 DynamoDbSinkConfig, MAX_BATCH_ITEMS, MAX_ITEM_BYTES, MAX_REQUEST_BYTES, OnConditionFailure,
21};
22pub use sink::DynamoDbSink;
23
24pub use faucet_common_dynamodb::{DynamoDbCredentials, RetryPolicy, ValueFormat, build_client};
25
26mod descriptor;
27pub use descriptor::DESCRIPTOR;