Struct InProcessEngineClient 

pub struct InProcessEngineClient<'a> { /* private fields */ }

The in-process client over an open store: each call is timestamped by clock (the wall clock by default; a fixture pins it).

Implementations

impl<'a> InProcessEngineClient<'a>

pub fn new(store: &'a mut Store, repo_id: &str) -> Self

pub fn with_config(self, config: Config) -> Self

The matcher thresholds every observe uses.

pub fn with_clock(self, clock: impl FnMut() -> String + 'a) -> Self

Replace the wall clock.

pub fn at(self, ts: &str) -> Self

Every call at one fixed timestamp.

pub fn store(&self) -> &Store

pub fn repo_id(&self) -> &str

Trait Implementations

impl Debug for InProcessEngineClient<'_>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl EngineClient for InProcessEngineClient<'_>

fn observe_many(&mut self, files: &[FileBytes]) -> Result<Vec<ObserveOutcome>>

Observe whole-file bytes as observed commits (echo-suppressed engine-side), one batch, then sweep the pool.

fn observe_delete(&mut self, path: &str) -> Result<DeleteOutcome>

Mirror a source-side deletion (tombstone, then sweep).

fn changes_since( &mut self, cursor: i64, limit: Option<usize>, origin: Option<&str>, ) -> Result<ChangesPage>

The repo’s change feed after cursor (§6).

fn read_doc(&mut self, path: &str) -> Result<Option<DocBytes>>

The current bytes at path, or None when no live doc reads there.

fn close(&mut self) -> Result<()>

Release the connection (the store’s lifetime is the caller’s).