Struct MemoryStore 

pub struct MemoryStore { /* private fields */ }

Implementations

impl MemoryStore

pub fn new() -> Self

pub fn with_clock(clock: impl Fn() -> i64 + Send + Sync + 'static) -> Self

A store whose “now” comes from clock (microseconds since the epoch). Commit times are still strictly increasing if the clock stands still or goes backwards.

pub fn with_retention(self, retention: Duration) -> Self

How long old versions stay readable after they are overwritten.

Trait Implementations

impl Default for MemoryStore

fn default() -> Self

Returns the “default value” for a type.

impl Store for MemoryStore

fn latest_read_time(&self, database: &str) -> ReadTime

A read time that sees every commit made so far.

fn earliest_read_time(&self, database: &str) -> ReadTime

The oldest read time still served; older versions may have been dropped.

fn get( &self, database: &str, path: &ResourcePath, at: ReadTime, ) -> Option<Arc<StoredDocument>>

fn list_collection( &self, database: &str, collection: &ResourcePath, at: ReadTime, options: ListOptions<'_>, visit: &mut dyn FnMut(ListItem<'_>) -> ControlFlow<()>, )

Like Store::scan_collection, with paging and missing documents.

fn scan_collection_group( &self, database: &str, parent: &ResourcePath, collection_id: &str, at: ReadTime, visit: &mut Visit<'_>, )

Every document under parent (a document path, or the root) whose collection ID is collection_id, at any depth, ordered by full path.

fn scan_descendants( &self, database: &str, parent: &ResourcePath, at: ReadTime, visit: &mut Visit<'_>, )

Every document below parent (a document path, or the root), at any depth, ordered by path. parent itself is not included.

fn list_collection_ids( &self, database: &str, parent: &ResourcePath, at: ReadTime, ) -> Vec<String>

IDs of the collections directly under parent that contain at least one document at any depth, in UTF-8 order.

fn commit( &self, database: &str, write: &mut dyn FnMut(&mut dyn WriteBatch) -> Result<(), StoreError>, ) -> Result<Commit, StoreError>

Runs write as one atomic commit.

fn clear_database(&self, database: &str) -> ReadTime

Drops every document of database and every older version, at a time after its last commit, which it returns: later commits are later still, so listeners can order the clear among them.

fn database_names(&self) -> Vec<String>

The databases that hold or held documents.

fn clear(&self)

Drops every database.

fn scan_collection( &self, database: &str, collection: &ResourcePath, at: ReadTime, visit: &mut Visit<'_>, )

The documents directly in collection (not in its subcollections).