Struct MemoryCdcStorage 

pub struct MemoryCdcStorage { /* private fields */ }

Implementations

impl MemoryCdcStorage

pub fn new() -> Self

pub fn with_entries(entries: impl IntoIterator<Item = Cdc>) -> Self

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn clear(&self)

Trait Implementations

impl CdcStorage for MemoryCdcStorage

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 MemoryCdcStorage

fn clone(&self) -> MemoryCdcStorage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for MemoryCdcStorage

fn default() -> Self

Returns the “default value” for a type.