Struct MemoryRepo 

pub struct MemoryRepo { /* private fields */ }

Implementations

impl MemoryRepo

pub fn new(driver: Box<dyn AdapterDriver>) -> Self

pub fn list_observed( &self, table: &str, query: &Query, context: &QueryContext, tracker: &mut QueryObservabilityTracker, ) -> DataResult<(Vec<StoredRow>, QueryObservation)>

pub fn list_window_observed( &self, table: &str, query: &Query, context: &QueryContext, tracker: &mut QueryObservabilityTracker, ) -> DataResult<(WindowPage, QueryObservation)>

Trait Implementations

impl OptimisticLockingRepo for MemoryRepo

fn update_with_optimistic_lock( &mut self, table: &str, id: u64, patch: Row, lock: OptimisticLock, ) -> DataResult<StoredRow>

impl Repo for MemoryRepo

fn adapter_kind(&self) -> AdapterKind

fn insert(&mut self, table: &str, data: Row) -> DataResult<StoredRow>

fn update(&mut self, table: &str, id: u64, data: Row) -> DataResult<StoredRow>

fn delete(&mut self, table: &str, id: u64) -> DataResult<()>

fn find(&self, table: &str, id: u64) -> DataResult<Option<StoredRow>>

fn list(&self, table: &str, query: &Query) -> DataResult<Vec<StoredRow>>

fn list_window(&self, table: &str, query: &Query) -> DataResult<WindowPage>

fn materialize_incremental_diff( &self, previous: &WindowPage, current: &WindowPage, ) -> IncrementalDiff

impl RepoUnitOfWork for MemoryRepo

fn transaction<T, F>(&mut self, operation: F) -> DataResult<T>

where F: FnOnce(&mut Self) -> DataResult<T>,