Struct PostgresSink 

pub struct PostgresSink { /* private fields */ }

Available on crate feature sink-postgres only.

A sink that writes JSON records to a PostgreSQL table.

Implementations

impl PostgresSink

pub async fn new( config: PostgresSinkConfig, ) -> Result<PostgresSink, FaucetError>

Create a new PostgreSQL sink. Establishes a connection pool.

Trait Implementations

impl Sink for PostgresSink

fn check<'life0, 'life1, 'async_trait>( &'life0 self, ctx: &'life1 CheckContext, ) -> Pin<Box<dyn Future<Output = Result<CheckReport, FaucetError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, PostgresSink: 'async_trait,

Preflight connectivity probe (faucet doctor).

Acquires a connection from the existing pool and runs SELECT 1. This is non-mutating and idempotent — it validates that the database is reachable and the credentials are accepted without writing anything.

fn write_batch<'life0, 'life1, 'async_trait>( &'life0 self, records: &'life1 [Value], ) -> Pin<Box<dyn Future<Output = Result<usize, FaucetError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, PostgresSink: 'async_trait,

Write records to PostgreSQL.

When config.batch_size > 0 and the input slice is larger than batch_size, the slice is split into chunks of batch_size rows and each chunk is sent as a separate multi-row INSERT. When config.batch_size == 0, the entire slice is sent in a single INSERT — useful when upstream StreamPages are already sized for Postgres’ per-statement bind-parameter limit (~65 535 / num_columns in AutoMap mode).

fn config_schema(&self) -> Value

Return a JSON Schema describing the configuration this sink accepts.

fn flush<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), FaucetError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Flush any buffered data to the destination.

fn write_batch_partial<'life0, 'life1, 'async_trait>( &'life0 self, records: &'life1 [Value], ) -> Pin<Box<dyn Future<Output = Result<Vec<Result<(), FaucetError>>, FaucetError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Write a batch and report per-row outcomes.

fn connector_name(&self) -> &'static str

Stable identifier used as the connector label on metrics and the connector attribute on spans. See Source::connector_name.