Struct Simulation 

pub struct Simulation<A = StreamAuthorityStore<MemoryStream>, O = ProviderObjectStore<MemoryObjects>> { /* private fields */ }

Shared deterministic simulator and its two backend handles.

Implementations

impl Simulation<StreamAuthorityStore<MemoryStream>, ProviderObjectStore<MemoryObjects>>

pub fn new(options: SimulationOptions) -> Result<Self, SimulationError>

Creates a bounded simulator over fresh deterministic memory primitives.

Errors

Rejects any zero hard bound before allocating simulator state.

impl<A, O> Simulation<A, O>

pub fn wrap( authority: A, objects: O, options: SimulationOptions, ) -> Result<Self, SimulationError>

Wraps explicit backends with one bounded deterministic schedule.

This is the black-box qualification seam for future infrastructure adapters. The simulator does not inspect or replace backend state.

Errors

Rejects any zero hard bound before retaining the supplied backends.

pub fn stores(&self) -> (SimulatedAuthorityStore<A>, SimulatedObjectStore<O>)

Returns independently cloneable authority and object handles sharing one schedule.

pub fn schedule( &self, scheduled: ScheduledSimulationFault, ) -> Result<(), SimulationError>

Schedules one exact one-based interception point.

Errors

Rejects zero occurrences, incompatible behavior, duplicate identities, poisoned state, or a full bounded schedule.

pub fn schedule_next( &self, operation: SimulationOperation, fault: SimulationFault, ) -> Result<ScheduledSimulationFault, SimulationError>

Atomically schedules the next occurrence of one operation family.

This is useful for deterministic black-box runners after setup traffic. Concurrent runners should retain the returned absolute occurrence in their evidence rather than assume which request consumes it.

Errors

Rejects incompatible behavior, occurrence exhaustion, poisoned state, or a full bounded schedule.

pub fn trace(&self) -> Result<Vec<SimulationTrace>, SimulationError>

Returns the complete bounded trace collected so far.

Errors

Returns a poisoned-state failure instead of silently discarding evidence.

impl<A, O: AsyncObjectStore> Simulation<A, O>

pub async fn flush_object_visibility( &self, budget: WorkBudget, cancellation: &CancellationToken, ) -> ObjectResult<u64>

Publishes delayed immutable objects in canonical identity order.

Only one pending entry is retained outside the simulator lock at a time, so flushing does not allocate or copy the delayed object set. Bytes cloning retains the same immutable allocation until backend admission.

Errors

Returns exact immutable-store, cancellation, budget, or poisoned-state failures. Successfully published entries are removed; the first failed entry and every later entry remain pending for an idempotent retry.

Trait Implementations

impl<A: Clone, O: Clone> Clone for Simulation<A, O>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for Simulation

fn default() -> Self

Returns the “default value” for a type.