Crate faucet_source_redshift 

faucet-source-redshift

Amazon Redshift query source connector for the faucet-stream ecosystem.

Redshift is PostgreSQL wire-compatible, so this source connects through sqlx’s Postgres driver, executes a configurable SQL query, and streams the result rows as serde_json::Value records with O(batch_size) memory. It supports full and incremental (bookmark-based) replication.

Re-exports

pub use config::RedshiftReplication;

pub use config::RedshiftSourceConfig;

pub use stream::RedshiftSource;

Modules

config

Amazon Redshift source configuration.

convert

Row decoding and parameter binding for the Redshift source.

stream

Amazon Redshift query source 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.

Traits

Source

A source fetches records from an external system.