Struct SimulatedAuthorityStore 

pub struct SimulatedAuthorityStore<A = StreamAuthorityStore<MemoryStream>> { /* private fields */ }

Authority backend handle controlled by one Simulation.

Trait Implementations

impl<A: AsyncAuthorityStore> AsyncAuthorityStore for SimulatedAuthorityStore<A>

async fn fork_generation_authority( &self, source: GenerationForkSource, destination_authority: AuthorityId, operation_id: OperationId, budget: WorkBudget, cancellation: &CancellationToken, ) -> AuthorityResult<CreateAuthorityOutcome>

Creates a destination authority whose canonical generation lineage is either an immutable native prefix of the source or an explicit independent lineage rooted at an unpublished authenticated generation.

async fn create_authority( &self, authority_id: AuthorityId, genesis_epoch: Epoch, budget: WorkBudget, cancellation: &CancellationToken, ) -> AuthorityResult<CreateAuthorityOutcome>

Asynchronously creates one authority.

async fn head( &self, authority_id: AuthorityId, budget: WorkBudget, cancellation: &CancellationToken, ) -> AuthorityResult<Head>

Asynchronously reads the linearizable head.

async fn compare_and_append( &self, authority_id: AuthorityId, epoch: Epoch, expected: Head, commit: ProposedCommit, budget: WorkBudget, cancellation: &CancellationToken, ) -> AuthorityResult<AppendOutcome>

Asynchronously compares and appends one durable operation.

async fn replay( &self, authority_id: AuthorityId, after: Sequence, limit: ReplayLimit, budget: WorkBudget, cancellation: &CancellationToken, ) -> AuthorityResult<Vec<DurableCommit>>

Asynchronously replays one bounded contiguous page.

async fn fence( &self, authority_id: AuthorityId, expected: Head, budget: WorkBudget, cancellation: &CancellationToken, ) -> AuthorityResult<FenceOutcome>

Asynchronously advances a writer fence.

async fn find_operation( &self, authority_id: AuthorityId, operation_id: OperationId, budget: WorkBudget, cancellation: &CancellationToken, ) -> AuthorityResult<Option<DurableCommit>>

Asynchronously resolves one idempotent operation identity.

fn supports_generation_lineage_prefix(&self) -> bool

Whether this backend can retain an immutable published-generation lineage prefix when it creates a child authority.

fn compare_and_append_guarded( &self, request: GuardedAppend, budget: WorkBudget, cancellation: &CancellationToken, ) -> impl Future<Output = AuthorityResult<AppendOutcome>> + StorageFuture

Asynchronously compares and appends under an optional operation-window permit. Backends that cannot atomically evaluate lease gates reject managed permits rather than using a read-then-write approximation.

fn reserve_publication( &self, _authority_id: AuthorityId, _expected: Head, _operation_id: OperationId, _budget: WorkBudget, _cancellation: &CancellationToken, ) -> impl Future<Output = AuthorityResult<ReservationOutcome>> + StorageFuture

Atomically acquires the exclusive publication gate at an exact head.

fn release_publication( &self, _reservation: PublicationReservation, _budget: WorkBudget, _cancellation: &CancellationToken, ) -> impl Future<Output = AuthorityResult<()>> + StorageFuture

Releases an exact publication reservation. Exact retries are idempotent.

impl<A: Clone> Clone for SimulatedAuthorityStore<A>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.