Expand description
§faucet-sink-redshift
Amazon Redshift sink connector for the faucet-stream ecosystem.
Two load paths, chosen by write_strategy:
copy(default) — stage each page to S3 (JSONL or CSV) and bulk-load it withCOPY … FROM 's3://…' IAM_ROLE '…', then delete the staged object. Redshift’s recommended, fastest bulk-load path.insert— multi-rowINSERT INTO … VALUES (…), (…). Portable and needs no S3, but slower for bulk data.
Append-only: Redshift has no ON CONFLICT and COPY cannot upsert.
Re-exports§
pub use config::RedshiftCopyFormat;pub use config::RedshiftSinkConfig;pub use config::RedshiftWriteStrategy;pub use sink::RedshiftSink;
Modules§
- config
- Amazon Redshift sink configuration.
- copy
- Pure SQL / payload builders for the Redshift sink.
- sink
- Amazon Redshift sink implementation.
Structs§
- Redshift
Connection - A Redshift connection: endpoint, database, user, credentials, and a TLS
toggle. Flattened (
#[serde(flatten)]) into both the source and sink configs so the connection fields appear at the config top level.
Enums§
- Faucet
Error - All possible errors returned by faucet-stream.
- Redshift
Credentials - How to authenticate with Amazon Redshift.
- Redshift
TlsMode - How a Redshift connection uses TLS.
Constants§
- DESCRIPTOR
- The connector’s static descriptor (RFC 0013): its capabilities, answered from config alone.
Traits§
- Sink
- A sink writes records to an external system.