Struct InMemoryFaultState 

pub struct InMemoryFaultState { /* private fields */ }

A bounded, process-local FaultStateStore.

This implementation makes the reservation ordering executable without a database. It is not durable: a restart starts from an empty state, which the contract permits because a restart may invoke fewer retries than were reserved, never more.

Implementations

impl InMemoryFaultState

pub fn new(limit: RetryStateLimit) -> Self

Constructs an empty bounded state.

Trait Implementations

impl Debug for InMemoryFaultState

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

Formats the value using the given formatter.

impl FaultStateStore for InMemoryFaultState

fn reserved_ordinal( &self, key: RetryKey, ) -> BoxFuture<'_, Result<Option<RetryOrdinal>, FaultStateError>>

Returns the ordinal already reserved for key, when one exists.

fn reserve( &self, reservation: RetryReservation, ) -> BoxFuture<'_, Result<(), FaultStateError>>

Commits one reservation, consuming its ordinal.

fn resolve(&self, key: RetryKey) -> BoxFuture<'_, Result<(), FaultStateError>>

Marks key resolved because its unit of work succeeded or was skipped.

fn clear_resolved(&self) -> BoxFuture<'_, Result<(), FaultStateError>>

Clears every resolved key in the commit that advances the checkpoint.

fn unresolved(&self) -> BoxFuture<'_, Result<u32, FaultStateError>>

Returns the number of retained unresolved keys.

fn bind( &self, _context: ChunkTransactionContext, ) -> BoxFuture<'_, Result<(), FaultStateError>>

Binds durable state to the step execution about to run.