Struct UncertainRecovery 

pub(super) struct UncertainRecovery;

Looks for the attainment a submission we lost track of would have produced. The row stays submission_uncertain unless it is found: never failed, never re-imported.

Trait Implementations

impl RegistryBatchFlow for UncertainRecovery

const REFUSAL: RefusalPolicy<VerifyAttempt>

Not the shared request-level outcome either: these rows must stay uncertain whatever the call did.

async fn claim( ctx: &BatchFlowContext<'_>, conn: &mut PgConnection, limit: usize, ) -> CreditRegistrationResult<Prepared<VerifyAttempt, EnrolmentLookup>>

A row with nothing to ask about is left where it is: it is uncertain, which no answer of ours may turn into a failure, and its lease already schedules the next check.

const ALL_UNAVAILABLE_ERROR: &'static str = "Every recovery lookup came back unavailable."

The iteration’s error when every item came back unavailable.

type Extra = VerifyAttempt

What the claim read for each row alongside it, which its answer is applied with.

type Request = EnrolmentLookup

What each row asks, which also names the operation it is asked under.

async fn apply_answer( conn: &mut PgConnection, recovery: &Claimed<VerifyAttempt>, answer: Option<&EnrolmentAnswer>, audit: &ExchangeAudit, ) -> CreditRegistrationResult<Applied>

Decides what one answer, or the absence of one, does to its row and writes it, with the exchange behind it. May read and write in transactions of its own on the way.

async fn keep_in_flight( _conn: &mut PgConnection, _rows: &[&Claimed<Self::Extra>], ) -> CreditRegistrationResult<()>

Called before each send after a split, with every row the split still holds, so the ones waiting their turn are not taken for a worker that died mid-call.

async fn release_unsent( _conn: &mut PgConnection, _rows: &[&Claimed<Self::Extra>], ) -> CreditRegistrationResult<()>

Called with every row a split still holds unsent when a shutdown or an error stops the iteration, each of which would otherwise be condemned as a lost submission.