Enum CdcStore 

pub enum CdcStore {
    Memory(MemoryCdcStorage),
    Sqlite(SqliteCdcStorage),
}

Variants

Memory(MemoryCdcStorage)

Sqlite(SqliteCdcStorage)

Implementations

impl CdcStore

pub fn memory() -> Self

pub fn sqlite(config: SqliteConfig) -> Self

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

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

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

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

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

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

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

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

Trait Implementations

impl CdcStorage for CdcStore

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 CdcStore

fn clone(&self) -> CdcStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.