Struct VerifyPoll 

pub(super) struct VerifyPoll;

Polls the rows that have something to poll by.

Trait Implementations

impl RegistryBatchFlow for VerifyPoll

const REFUSAL: RefusalPolicy<VerifyAttempt>

Deliberately not the shared request-level outcome: a failure to ask proves nothing was or was not created, and moving the row towards failed_retryable would let an admin resubmit it. The iteration still reports the refusal, and the gate still records it.

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

A row stuck without a submitted attainment id is leased like the rest, so it is not claimed again every iteration, but never sent; it is flagged for an admin and counted as failed.

const ALL_UNAVAILABLE_ERROR: &'static str = "Every verify poll 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 = VerificationRequest

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

async fn apply_answer( conn: &mut PgConnection, poll: &Claimed<VerifyAttempt>, answer: Option<&VerificationAnswer>, 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.