Struct SqliteCdcStorage 

pub struct SqliteCdcStorage { /* private fields */ }

Implementations

impl SqliteCdcStorage

pub fn new(config: SqliteConfig) -> Self

pub fn new_with_cache_capacity( config: SqliteConfig, cache_capacity: usize, ) -> Self

pub fn in_memory() -> Self

pub fn incremental_vacuum(&self)

pub fn shrink_memory(&self)

pub fn shutdown(&self)

pub fn compact_oldest( &self, target_size: usize, safety_lag: u64, zstd_level: u8, producer_watermark: CommitVersion, ) -> CdcStorageResult<Option<CompactBlockSummary>>

pub fn compact_all( &self, target_size: usize, zstd_level: u8, producer_watermark: CommitVersion, ) -> CdcStorageResult<Vec<CompactBlockSummary>>

Trait Implementations

impl CdcStorage for SqliteCdcStorage

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

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

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

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

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

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

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

fn find_ttl_cutoff( &self, cutoff: DateTime, ) -> CdcStorageResult<Option<CommitVersion>>

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

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

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

impl Clone for SqliteCdcStorage

fn clone(&self) -> SqliteCdcStorage

Returns a duplicate of the value.

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

Performs copy-assignment from source.