Skip to main content

faucet_sink_postgres/
lib.rs

1#![cfg_attr(docsrs, feature(doc_cfg))]
2
3//! # faucet-sink-postgres
4//!
5//! PostgreSQL sink connector for the faucet-stream ecosystem.
6//!
7//! Writes `serde_json::Value` records to a PostgreSQL table using `jsonb`
8//! columns or dynamic column mapping. Append-mode writes can opt into the
9//! `COPY … FROM STDIN` bulk-load fast-path via `write_method: copy`
10//! (typically 5–10× faster than multi-row `INSERT` — issue #308).
11
12pub mod config;
13mod copy;
14pub mod sink;
15
16pub use faucet_core::{FaucetError, Sink};
17
18pub use config::{PostgresColumnMapping, PostgresSinkConfig, PostgresWriteMethod};
19pub use sink::PostgresSink;