Struct ResolvePersonIds 

pub(super) struct ResolvePersonIds;

Trait Implementations

impl RegistryBatchFlow for ResolvePersonIds

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

Claims the rows the enrolment lookup would and keeps only those whose link lacks a person id; the others are left for the enrolment lookup.

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

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

const REFUSAL: RefusalPolicy<LinkMissingPerson> = RefusalPolicy::RequestLevel

What the rows get when the study registry refused the whole request, which also decides whether a batch refused as malformed is split.

type Extra = LinkMissingPerson

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

type Request = PersonLookup

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

async fn apply_answer( conn: &mut PgConnection, row: &Claimed<LinkMissingPerson>, answer: Option<&PersonAnswer>, 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<LinkMissingPerson>], ) -> 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.