Crate faucet_sink_postgres 

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.

Re-exports

pub use config::PostgresColumnMapping;

pub use config::PostgresSinkConfig;

pub use sink::PostgresSink;

Modules

config

PostgreSQL sink configuration.

sink

PostgreSQL sink implementation.

Enums

FaucetError

All possible errors returned by faucet-stream.

Traits

Sink

A sink writes records to an external system.