Crate faucet_sink_sqs 

faucet-sink-sqs

AWS SQS sink connector for faucet-stream: batched SendMessageBatch writes (≤10 entries / ≤1 MiB per request, 256 KiB where a queue still enforces the older limit), bounded concurrent in-flight requests, per-entry partial-failure retry, optional FIFO message_group_id / message_deduplication_id, and DLQ-routable per-record outcomes.

Delivery is at-least-once: an ambiguous whole-request failure that is retried can double-write messages that actually landed. On a FIFO queue set message_deduplication_id_field (or enable content-based dedup on the queue) so replays within the 5-minute dedup window converge.

Structs

SqsSink

AWS SQS sink. See the crate README for semantics.

SqsSinkConfig

Configuration for SqsSink.

Enums

SqsCredentials

How to authenticate with AWS SQS.

Constants

DESCRIPTOR

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

MAX_BATCH_BYTES

SQS hard limit: 1 MiB total payload per SendMessageBatch request.

MAX_ENTRIES_PER_REQUEST

SQS hard limit: SendMessageBatch accepts at most 10 entries per request.

MAX_MESSAGE_BYTES

SQS hard limit: 1 MiB per message body. A queue whose MaximumMessageSize is lower rejects larger entries per row.

Functions

build_client

Build an aws_sdk_sqs::Client from region / endpoint / credentials.