Skip to main content

Crate faucet_sink_redshift

Crate faucet_sink_redshift 

Source
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 with COPY … FROM 's3://…' IAM_ROLE '…', then delete the staged object. Redshift’s recommended, fastest bulk-load path.
  • insert — multi-row INSERT 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§

RedshiftConnection
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§

FaucetError
All possible errors returned by faucet-stream.
RedshiftCredentials
How to authenticate with Amazon Redshift.
RedshiftTlsMode
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.