Struct PostgresWalSource 

pub struct PostgresWalSource { /* private fields */ }

Implementations

impl PostgresWalSource

pub fn scripted( config: PostgresSourceConfig, database_name: impl Into<String>, events: impl IntoIterator<Item = LogicalEvent>, ) -> Result<Self, ConnectError>

pub async fn connect(config: PostgresSourceConfig) -> Result<Self, ConnectError>

Trait Implementations

impl Debug for PostgresWalSource

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Source<Bytes, Bytes> for PostgresWalSource

fn poll<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<Option<ConnectRecord<Bytes, Bytes>>, ConnectError>> + Send + 'async_trait>>

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

Pull the next record, advancing the source’s read position.

fn checkpoint(&self) -> Option<SourceOffset>

Snapshot the current read position so the runtime can persist it.

fn seek<'life0, 'async_trait>( &'life0 mut self, offset: SourceOffset, ) -> Pin<Box<dyn Future<Output = Result<(), ConnectError>> + Send + 'async_trait>>

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

Restore the read position to a previously checkpointed offset. Called once, before the first poll, on startup and after a rebalance. A source with no stored offset is not sought and starts from its configured default position.

fn acknowledge<'life0, 'life1, 'async_trait>( &'life0 mut self, offset: &'life1 SourceOffset, ) -> Pin<Box<dyn Future<Output = Result<(), ConnectError>> + Send + 'async_trait>>

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

Acknowledge that offset is durable end-to-end.

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

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

Release any resources held by the source (connections, file handles). The default is a no-op. After close, the source is not polled again.