Struct InMemoryJobRepository 

pub struct InMemoryJobRepository { /* private fields */ }

Deterministic, process-local reference implementation of JobRepository.

Each unit of work operates on an isolated snapshot and publishes it with a repository-wide compare-and-swap commit. Concurrent commits therefore have one winner; losers receive RepositoryError::ConcurrentModification and can retry from a fresh snapshot. No state survives process termination.

Implementations

impl InMemoryJobRepository

pub fn new(clock: Arc<dyn Clock>, ids: Arc<dyn IdGenerator>) -> Self

Constructs an empty repository with explicitly injected time and IDs.

pub fn inject_next_partition_aggregate_commit_unknown(&self)

Injects one lost commit response after the next partition aggregate is published.

This deterministic failure fixture is intended for conformance tests of fresh-state inspection after an ambiguous repository commit.

Trait Implementations

impl Clone for InMemoryJobRepository

fn clone(&self) -> InMemoryJobRepository

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InMemoryJobRepository

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

Formats the value using the given formatter.

impl JobRepository for InMemoryJobRepository

fn descriptor(&self) -> RepositoryDescriptor

The reference adapter implements every capability this milestone defines. It reports schema version 0 because it holds no durable metadata schema.

fn connection_capacity(&self) -> u32

Returns the finite connection budget available to one execution tree.

fn begin<'a>( &'a self, ) -> BoxFuture<'a, Result<Box<dyn RepositoryUnitOfWork + 'a>, RepositoryError>>

Begins a repository-owned unit of work.