Struct CdcLog 

pub struct CdcLog { /* private fields */ }

The core CDC log — a ring buffer of events with subscriber notification.

Implementations

impl CdcLog

pub fn new(config: CdcConfig) -> Arc<Self>

Create a new CDC log with the given configuration.

pub fn emit(&self, events: Vec<CdcEvent>)

Emit a batch of CDC events (typically one per row in a transaction).

This is called from the commit path after WAL flush + group commit. Must be fast — no I/O, no allocations on the hot path (beyond the ring buffer push).

pub fn emit_one(&self, event: CdcEvent)

Emit a single event.

pub fn next_sequence(&self) -> u64

Allocate the next sequence number.

pub fn current_sequence(&self) -> u64

Get the current (latest) sequence number.

pub fn read_from( &self, from_seq: u64, max_events: usize, ) -> CdcResult<Vec<CdcEvent>>

Read events starting from from_seq (inclusive).

Returns up to max_events events. If from_seq has been evicted from the ring buffer, returns CdcError::Overrun.

pub fn wait_for_events( &self, after_seq: u64, max_events: usize, timeout: Duration, ) -> CdcResult<Vec<CdcEvent>>

Wait for new events after after_seq, with timeout.

Returns events with sequence > after_seq, blocking until at least one event is available or the timeout expires.

pub fn oldest_sequence(&self) -> u64

Get the oldest available sequence number (or 0 if empty).

pub fn len(&self) -> usize

Get the number of events in the buffer.

pub fn is_empty(&self) -> bool

Check if the buffer is empty.

pub fn shutdown(&self)

Shut down the CDC engine, waking all waiting subscribers.