Struct PostgresBootstrapProvider 

pub struct PostgresBootstrapProvider { /* private fields */ }

Bootstrap provider for PostgreSQL sources

This provider takes its configuration directly at construction time, following the instance-based plugin architecture.

Implementations

impl PostgresBootstrapProvider

pub fn new(postgres_config: PostgresBootstrapConfig) -> Self

Create a new PostgreSQL bootstrap provider with the given configuration

pub fn builder() -> PostgresBootstrapProviderBuilder

Create a builder for PostgresBootstrapProvider

Trait Implementations

impl BootstrapProvider for PostgresBootstrapProvider

fn bootstrap<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, request: BootstrapRequest, context: &'life1 BootstrapContext, event_tx: BootstrapEventSender, _settings: Option<&'life2 SourceSubscriptionSettings>, ) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + 'async_trait>>

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

Perform bootstrap operation for the given request Sends bootstrap events to the provided channel Returns the number of elements sent