Struct PostgresFaultState 

pub struct PostgresFaultState { /* private fields */ }

Durable PostgreSQL retry-reservation state for one step execution.

A reservation is one short metadata-only transaction that runs after a known rollback and before backoff. It reads the retained state under a row lock, requires the supplied ordinal to follow the persisted one, and advances the phase retry count, the acknowledged rollback count, and the retained envelope with an optimistic version check. A stale or concurrent writer loses instead of spending the same ordinal twice.

The retained state is cleared by the enlisted chunk commit, because the commit that advances the checkpoint supersedes the whole generation.

Implementations

impl PostgresFaultState

pub fn new(repository: PostgresJobRepository, policy: &FaultPolicy) -> Self

Constructs durable state for the step that installs policy.

The runtime binds the step execution before the first chunk attempt.

Trait Implementations

impl Debug for PostgresFaultState

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

Formats the value using the given formatter.

impl FaultStateStore for PostgresFaultState

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

Binds durable state to the step execution about to run.

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.