Struct PostgresSource 

pub struct PostgresSource { /* private fields */ }

Implementations

impl PostgresSource

pub fn connect(url: &str) -> Result<Self>

Connect with no transport security (legacy path). Prefer Self::connect_with_tls for production workloads so credentials and result sets are not visible on the wire.

pub fn connect_with_tls(url: &str, tls: Option<&TlsConfig>) -> Result<Self>

Connect honoring the user’s TlsConfig. When tls.mode is [TlsMode::Disable] this falls back to Self::connect.

Trait Implementations

impl Source for PostgresSource

fn sample_pressure(&mut self) -> Option<u64>

Governor pressure proxy: pg_stat_bgwriter.checkpoints_req — the same monotonic counter the adaptive batch loop samples. Rising between samples means the source is checkpointing harder under write pressure.

fn export( &mut self, request: &ExportRequest<'_>, sink: &mut dyn BatchSink, ) -> Result<()>

Execute request.query and stream batches into sink.

fn query_scalar(&mut self, sql: &str) -> Result<Option<String>>

fn type_mappings( &mut self, query: &str, column_overrides: &ColumnOverrides, ) -> Result<Vec<TypeMapping>>

Return TypeMapping for every column in query without fetching rows.