Trait CdcSource 

pub trait CdcSource {
    type Error: Error + Send + Sync + 'static;

    // Required method
    fn next_batch(&mut self) -> Result<Option<Vec<CdcEvent>>, Self::Error>;
}

Batch-oriented CDC source boundary.

Decision (Phase 1): batch-first boundary avoids forcing async/runtime choice into the crate.

Required Associated Types

type Error: Error + Send + Sync + 'static

Required Methods

fn next_batch(&mut self) -> Result<Option<Vec<CdcEvent>>, Self::Error>

Fetch the next batch of CDC events.

• Ok(None) means “clean end” (source exhausted / stopped).
• Ok(Some(batch)) yields a non-empty batch.

Implementors