Struct CdcSubscriber 

pub struct CdcSubscriber { /* private fields */ }

A subscriber that tracks its position in the CDC log.

Implementations

impl CdcSubscriber

pub fn new(log: Arc<CdcLog>, from_seq: u64) -> Self

Create a subscriber starting from the given sequence number. Use 0 to start from the beginning of the buffer.

pub fn from_latest(log: Arc<CdcLog>) -> Self

Create a subscriber starting from the current (latest) position.

pub fn with_tables(self, tables: Vec<String>) -> Self

Filter events to only include the given tables.

pub fn poll(&mut self, max_events: usize) -> CdcResult<Vec<CdcEvent>>

Poll for new events (non-blocking).

pub fn next_batch( &mut self, max_events: usize, timeout: Duration, ) -> CdcResult<Vec<CdcEvent>>

Wait for new events (blocking with timeout).

pub fn position(&self) -> u64

Get the subscriber’s current position.