faucet-sink-postgres 1.4.0

PostgreSQL sink connector for the faucet-stream ecosystem
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

#![cfg_attr(docsrs, feature(doc_cfg))]

//! # faucet-sink-postgres
//!
//! PostgreSQL sink connector for the faucet-stream ecosystem.
//!
//! Writes `serde_json::Value` records to a PostgreSQL table using `jsonb`
//! columns or dynamic column mapping. Append-mode writes can opt into the
//! `COPY … FROM STDIN` bulk-load fast-path via `write_method: copy`
//! (typically 5–10× faster than multi-row `INSERT` — issue #308).

pub mod config;
mod copy;
pub mod sink;

pub use faucet_core::{FaucetError, Sink};

pub use config::{PostgresColumnMapping, PostgresSinkConfig, PostgresWriteMethod};
pub use sink::PostgresSink;