Struct BlockingStore 

pub struct BlockingStore { /* private fields */ }

Synchronous mirror of Store.

Cheap to clone: only the inner Store handle is Arc-shared. The runtime driver is shared through Arc as well, so cloned handles all drive the same runtime.

Implementations

impl BlockingStore

pub fn new(store: Store) -> Result<Self>

Build a BlockingStore that owns a dedicated current_thread tokio runtime.

Fails only if the runtime cannot be constructed (rare — typically an exhausted file descriptor budget). See the crate-level docs for the nested-runtime pitfall.

pub fn with_handle(store: Store, handle: Handle) -> Self

Build a BlockingStore that drives calls on the caller’s runtime, identified by a Handle.

Prefer this constructor when the surrounding process already owns a tokio runtime — reusing the handle avoids spawning a second one.

pub fn as_async(&self) -> &Store

Access the underlying async Store. Useful when a caller needs to mix async and blocking paths, or hand the async handle to a concurrently-running task.

pub fn append( &self, stream: &StreamId, kind: &str, patch: Patch, meta: Value, ) -> Result<Seq, StoreError>

See Store::append.

pub fn import_event( &self, stream: &StreamId, kind: &str, patch: Patch, meta: Value, at: Timestamp, ) -> Result<Seq, StoreError>

See Store::import_event.

pub fn state(&self, stream: &StreamId) -> Result<Value, StoreError>

See Store::state.

pub fn state_at(&self, stream: &StreamId, at: Seq) -> Result<Value, StoreError>

See Store::state_at.

pub fn revert(&self, stream: &StreamId, to: Seq) -> Result<Seq, StoreError>

See Store::revert.

pub fn read( &self, stream: &StreamId, from: Seq, limit: usize, ) -> Result<Vec<Event>, StoreError>

See Store::read.

pub fn read_by_meta( &self, stream: &StreamId, field: &str, value: &Value, from: Seq, limit: usize, ) -> Result<Vec<Event>, StoreError>

See Store::read_by_meta.

pub fn head(&self, stream: &StreamId) -> Result<Option<Seq>, StoreError>

See Store::head.

pub fn seq_at_time( &self, stream: &StreamId, at: Timestamp, ) -> Result<Option<Seq>, StoreError>

See Store::seq_at_time.

pub fn streams(&self) -> Result<Vec<StreamId>, StoreError>

See Store::streams.

pub fn label_set( &self, stream: &StreamId, label: &Label, at: Seq, ) -> Result<(), StoreError>

See Store::label_set.

pub fn label_resolve( &self, stream: &StreamId, label: &Label, ) -> Result<Seq, StoreError>

See Store::label_resolve.

pub fn labels(&self, stream: &StreamId) -> Result<Vec<(Label, Seq)>, StoreError>

See Store::labels.

pub fn label_delete( &self, stream: &StreamId, label: &Label, ) -> Result<bool, StoreError>

See Store::label_delete.

pub fn materialize_to_sink( &self, stream: &StreamId, sink_id: &str, at: Option<Seq>, ) -> Result<Seq, StoreError>

See Store::materialize_to_sink.

pub fn catch_up(&self, sink_id: &str) -> Result<CatchUpReport, StoreError>

See Store::catch_up.

pub fn rebuild(&self, sink_id: &str) -> Result<CatchUpReport, StoreError>

See Store::rebuild.

Trait Implementations

impl Clone for BlockingStore

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.