Struct Import 

struct Import;

Trait Implementations

impl SuotarBatchPhase for Import

const ALL_TRANSIENT_ERROR: &'static str = "Every item of the batch came back transiently unavailable."

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

type Row = CreditRegistration

A row to send for, with whatever its preflight read alongside it.

type Item = ImportAttainmentRequestItem

The request item, which is also what the audit log records as sent.

type Result = ImportAttainmentResult

The endpoint’s per-item result body.

async fn prepare( &mut self, _ctx: &PhaseContext<'_>, conn: &mut PgConnection, scope: &PhaseScope, ) -> Result<Prepared<Self::Row, Self::Item>>

Claims 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.

fn registration(row: &Self::Row) -> &CreditRegistration

fn request_item_id(row: &Self::Row) -> String

What the row was addressed as, and so how its answer is found again.

fn sent_student_number(row: &Self::Row) -> Option<&str>

The student number this row’s request carried, where it carried one: a number the registry rejects may only cost the link it was sent under.

async fn send( &self, ctx: &PhaseContext<'_>, rows: &[Self::Row], items: Vec<Self::Item>, ) -> Result<SuotarBatchResponse<Self::Result>, UtilError>

async fn apply( &self, conn: &mut PgConnection, row: &Self::Row, item: Option<&SuotarResponseItem<Self::Result>>, event: OutcomeEvent<'_>, ) -> Result<bool>

Applies one answer, or the absence of one, to its row. Returns whether the row ended up in a failure state; errors with PreconditionFailed if another writer moved the row meanwhile.

async fn apply_request_rejection( &self, conn: &mut PgConnection, row: &Self::Row, request: &Value, error: &UtilError, ) -> Result<bool>

What one row gets when the study registry rejected the whole request.