Struct QueuedRepository 

pub struct QueuedRepository<R, L = InMemoryAsyncLockManager> { /* private fields */ }

Repository wrapper that serializes access with process-local per-stream locks.

Locking reads (get and get_many) intentionally keep matching locks held after returning. Call commit to release those locks after a successful write, or call abort/unlock when the loaded entity is no longer being written. Dropping a loaded entity without commit or abort leaves its in-memory lock held until an explicit unlock.

Commit releases held locks only after the inner repository succeeds. On commit errors, locks remain held so callers can inspect state, retry, or explicitly abort.

Implementations

impl<R> QueuedRepository<R>

pub fn new(inner: R) -> Self

impl<R, L> QueuedRepository<R, L>

pub fn inner(&self) -> &R

Access the inner repository.

pub fn lock_manager(&self) -> &L

Access the lock manager.

impl<R, L: AsyncLockManager> QueuedRepository<R, L>

pub fn with_async_lock_manager(inner: R, lock_manager: L) -> Self

Create a QueuedRepository with a custom async lock manager.

Trait Implementations

impl<R, L> AsyncGetAllWithOpts for QueuedRepository<R, L>

where R: AsyncGetStream, L: AsyncLockManager,

fn get_streams_with<'a>( &'a self, identities: &'a [StreamIdentity], opts: ReadOpts, ) -> impl Future<Output = Result<Vec<Entity>, RepositoryError>> + Send + 'a

impl<R, L> AsyncGetStream for QueuedRepository<R, L>

where R: AsyncGetStream, L: AsyncLockManager,

fn get_stream<'a>( &'a self, identity: &'a StreamIdentity, ) -> impl Future<Output = Result<Option<Entity>, RepositoryError>> + Send + 'a

fn get_streams<'a>( &'a self, identities: &'a [StreamIdentity], ) -> impl Future<Output = Result<Vec<Entity>, RepositoryError>> + Send + 'a

impl<R, L> AsyncGetWithOpts for QueuedRepository<R, L>

where R: AsyncGetStream, L: AsyncLockManager,

fn get_stream_with<'a>( &'a self, identity: &'a StreamIdentity, opts: ReadOpts, ) -> impl Future<Output = Result<Option<Entity>, RepositoryError>> + Send + 'a

impl<R, L> AsyncInboxStore for QueuedRepository<R, L>

where R: AsyncInboxStore, L: AsyncLockManager,

fn inbox_contains_async<'a>( &'a self, consumer: &'a str, message_id: &'a str, ) -> impl Future<Output = Result<bool, RepositoryError>> + Send + 'a

impl<R, L> AsyncReadModelWritePlanStore for QueuedRepository<R, L>

where R: AsyncReadModelWritePlanStore, L: AsyncLockManager,

fn read_model_capabilities_async(&self) -> ReadModelAdapterCapabilities

fn commit_write_plan_async( &self, plan: ReadModelWritePlan, ) -> impl Future<Output = Result<ReadModelCommitOutcome, ReadModelError>> + Send + '_

impl<R, L> AsyncRelationalReadModelQueryStore for QueuedRepository<R, L>

where R: AsyncRelationalReadModelQueryStore, L: AsyncLockManager,

fn read_model_query_capabilities_async(&self) -> ReadModelQueryCapabilities

fn load_graph_async( &self, request: ReadModelLoadRequest, ) -> impl Future<Output = Result<ReadModelLoadGraph, ReadModelError>> + Send + '_

impl<R, L> AsyncSnapshotStore for QueuedRepository<R, L>

where R: AsyncSnapshotStore, L: AsyncLockManager,

fn get_snapshot_async<'a>( &'a self, identity: &'a StreamIdentity, ) -> impl Future<Output = Result<Option<SnapshotRecord>, RepositoryError>> + Send + 'a

fn save_snapshot_async<'a>( &'a self, identity: &'a StreamIdentity, record: SnapshotRecord, ) -> impl Future<Output = Result<(), RepositoryError>> + Send + 'a

fn delete_snapshot_async<'a>( &'a self, identity: &'a StreamIdentity, ) -> impl Future<Output = Result<bool, RepositoryError>> + Send + 'a

impl<R, L> AsyncTransactionalCommit for QueuedRepository<R, L>

where R: AsyncTransactionalCommit, L: AsyncLockManager,

fn commit_batch_async<'a>( &'a self, batch: AsyncCommitBatch<'a>, ) -> impl Future<Output = Result<(), RepositoryError>> + Send + 'a

impl<R, L: AsyncLockManager> AsyncUnlockableRepository for QueuedRepository<R, L>

where R: Send + Sync,

fn unlock<'a>( &'a self, identity: &'a StreamIdentity, ) -> impl Future<Output = Result<(), RepositoryError>> + Send + 'a

Release the lock held for a stream.

fn abort<'a>( &'a self, identity: &'a StreamIdentity, ) -> impl Future<Output = Result<(), RepositoryError>> + Send + 'a

Release a lock for an aborted load (alias for unlock).

impl<R: Clone, L> Clone for QueuedRepository<R, L>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.