Struct Import 

struct Import;

Trait Implementations

impl RegistryBatchFlow for Import

const ALL_UNAVAILABLE_ERROR: &'static str = "Every item of the batch timed out in Sisu or came back unavailable."

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

const REFUSAL: RefusalPolicy<()> = 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 = ()

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

type Request = AttainmentSubmission

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

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

Claims at most limit rows and decides what may be asked about them. Whatever has to be true before the request leaves is written here, in the caller’s transaction.

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