Enum CdcStore 

pub enum CdcStore {
    Memory(MemoryCdcStorage),
}

CDC storage abstraction enum.

Provides a unified interface over different CDC storage backends. Currently supports in-memory storage, with room for future backends.

Variants

Memory(MemoryCdcStorage)

In-memory CDC storage backed by a BTreeMap.

Implementations

impl CdcStore

pub fn memory() -> Self

Create an in-memory CDC store.

pub fn write(&self, cdc: &Cdc) -> CdcStorageResult<()>

Write a CDC entry.

pub fn read(&self, version: CommitVersion) -> CdcStorageResult<Option<Cdc>>

Read a CDC entry by version.

pub fn read_range( &self, start: Bound<CommitVersion>, end: Bound<CommitVersion>, batch_size: u64, ) -> CdcStorageResult<CdcBatch>

Read CDC entries in a version range.

pub fn count(&self, version: CommitVersion) -> CdcStorageResult<usize>

Count CDC changes at a specific version.

pub fn min_version(&self) -> CdcStorageResult<Option<CommitVersion>>

Get the minimum (oldest) CDC version in storage.

pub fn max_version(&self) -> CdcStorageResult<Option<CommitVersion>>

Get the maximum (newest) CDC version in storage.

pub fn delete_before( &self, version: CommitVersion, ) -> CdcStorageResult<DropBeforeResult>

Delete all CDC entries with version strictly less than the given version.

Trait Implementations

impl CdcStorage for CdcStore

fn write(&self, cdc: &Cdc) -> CdcStorageResult<()>

Write a CDC entry (fully resolved values).

fn read(&self, version: CommitVersion) -> CdcStorageResult<Option<Cdc>>

Read a CDC entry by version.

fn read_range( &self, start: Bound<CommitVersion>, end: Bound<CommitVersion>, batch_size: u64, ) -> CdcStorageResult<CdcBatch>

Read CDC entries in a version range.

fn count(&self, version: CommitVersion) -> CdcStorageResult<usize>

Count CDC changes at a specific version.

fn min_version(&self) -> CdcStorageResult<Option<CommitVersion>>

Get the minimum (oldest) CDC version in storage.

fn max_version(&self) -> CdcStorageResult<Option<CommitVersion>>

Get the maximum (newest) CDC version in storage.

fn drop_before( &self, version: CommitVersion, ) -> CdcStorageResult<DropBeforeResult>

Delete all CDC entries with version strictly less than the given version. Returns the count and entry information for stats tracking.

fn exists(&self, version: CommitVersion) -> CdcStorageResult<bool>

Check if a CDC entry exists at the given version.

fn range( &self, start: Bound<CommitVersion>, end: Bound<CommitVersion>, ) -> CdcStorageResult<CdcBatch>

Convenience method with default batch size.

fn scan(&self, batch_size: u64) -> CdcStorageResult<CdcBatch>

Scan all CDC entries with the given batch size.

impl Clone for CdcStore

fn clone(&self) -> CdcStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.