Struct PostgresConnector 

pub struct PostgresConnector { /* private fields */ }

Implementations

impl PostgresConnector

pub async fn new(name: &str, dsn: &str) -> Result<Self, OversyncError>

pub fn from_pool(name: &str, pool: PgPool) -> Self

Trait Implementations

impl OriginConnector for PostgresConnector

fn name(&self) -> &str

Human-readable name of this connector instance.

fn fetch_all<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, sql: &'life1 str, key_column: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<RawRow>, OversyncError>> + Send + 'async_trait>>

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

Fetch all rows matching the query. Returns the full result set in memory.

fn fetch_into<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, sql: &'life1 str, key_column: &'life2 str, batch_size: usize, tx: Sender<Vec<RawRow>>, ) -> Pin<Box<dyn Future<Output = Result<usize, OversyncError>> + Send + 'async_trait>>

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

Stream rows in batches into a channel. Memory bounded by batch_size * channel buffer. Default: calls fetch_all, chunks, sends.

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

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