Struct SuotarClient 

pub struct SuotarClient {
    api_base_url: Url,
    authorization: SecretString,
    audit: Arc<dyn SuotarCallAudit>,
    exchanges: Arc<AtomicU64>,
}

Fields

api_base_url: Url

authorization: SecretString

audit: Arc<dyn SuotarCallAudit>

exchanges: Arc<AtomicU64>

Requests that actually left for the study registry, shared by every clone of the client. The circuit breaker reads it to tell an iteration that heard from the registry from one that found nothing to ask about; a pre-flight refusal is not counted because it never reached it.

Implementations

impl SuotarClient

pub fn new( config: &SuotarConfiguration, audit: Arc<dyn SuotarCallAudit>, ) -> Self

pub fn mock_for_test() -> Self

pub fn exchange_count(&self) -> u64

How many requests this client has sent, monotonic for the life of the process. Compare two readings to learn whether the work between them reached the study registry at all.

pub async fn resolve_persons( &self, context: SuotarCallContext, items: Vec<ResolvePersonRequestItem>, ) -> UtilResult<SuotarBatchResponse<PersonResult>>

pub async fn resolve_enrolments( &self, context: SuotarCallContext, items: Vec<ResolveEnrolmentRequestItem>, ) -> UtilResult<SuotarBatchResponse<EnrolmentResolutionResult>>

pub async fn import_attainments( &self, context: SuotarCallContext, items: Vec<ImportAttainmentRequestItem>, ) -> UtilResult<SuotarBatchResponse<ImportAttainmentResult>>

pub async fn verify_attainments( &self, context: SuotarCallContext, items: Vec<VerifyAttainmentRequestItem>, ) -> UtilResult<SuotarBatchResponse<VerifyAttainmentResult>>

pub async fn resolve_product_access_tokens( &self, context: SuotarCallContext, items: Vec<ProductAccessTokenRequestItem>, ) -> UtilResult<SuotarBatchResponse<ProductAccessTokenResult>>

pub async fn list_enrolments_by_course( &self, context: SuotarCallContext, items: Vec<ListByCourseRequestItem>, ) -> UtilResult<SuotarBatchResponse<EnrolmentsListedResult>>

async fn post_batch<T: SuotarRequestItem, R: DeserializeOwned>( &self, endpoint: SuotarEndpoint, context: SuotarCallContext, items: Vec<T>, ) -> UtilResult<SuotarBatchResponse<R>>

async fn refused<R>( &self, call_id: Option<Uuid>, error: UtilError, ) -> UtilResult<SuotarBatchResponse<R>>

Records a pre-flight refusal as the suotar_api_calls row any other failure would leave.

async fn exchange<R: DeserializeOwned>( &self, endpoint: SuotarEndpoint, request: RequestBuilder, body: Vec<u8>, sent_ids: Vec<String>, clock: Instant, ) -> (UtilResult<SuotarBatchResponse<R>>, SuotarCallFinished)

Returns the audit record alongside the result: only this function knows the status, the duration and the request-level code, and the row needs all three.

Trait Implementations

impl Clone for SuotarClient

fn clone(&self) -> SuotarClient

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.