Struct PgSuotarCallAudit 

pub struct PgSuotarCallAudit {
    pool: PgPool,
    is_waiting_item: fn(SuotarEndpoint, &str) -> bool,
}

Audits every headless_lms_utils::services::suotar::SuotarClient call.

Owns a pool rather than borrowing the caller’s connection: the row is committed while the request is in flight and must survive whatever the caller’s transaction does next.

Fields

pool: PgPool

is_waiting_item: fn(SuotarEndpoint, &str) -> bool

Implementations

impl PgSuotarCallAudit

pub fn new( pool: PgPool, is_waiting_item: fn(SuotarEndpoint, &str) -> bool, ) -> Self

is_waiting_item says whether an error item’s code only means “not yet”, which is logged as pending rather than as an error.

Trait Implementations

impl SuotarCallAudit for PgSuotarCallAudit

fn started<'life0, 'async_trait>( &'life0 self, started: SuotarCallStarted, ) -> Pin<Box<dyn Future<Output = Option<Uuid>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns the row id, which travels out as CORRELATION_ID_HEADER. None means the row could not be written; the call goes out anyway.

fn finished<'life0, 'async_trait>( &'life0 self, call_id: Uuid, finished: SuotarCallFinished, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,