Struct SuotarClient 

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

Fields

api_base_url: Url

authorization: SecretString

audit: Arc<dyn SuotarCallAudit>

allow_http: bool

Whether a plain-http api_base_url is sent to rather than refused. Only TEST_MODE or the test-only new_allowing_http sets it: production must never reach Suotar over http.

Implementations

impl SuotarClient

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

The client for the configured Suotar. Build it at startup: it builds the shared HTTP client, which panics if it cannot.

pub async fn post<E: BatchEndpoint>( &self, context: SuotarCallContext, items: Vec<E::Item>, ) -> Result<SuotarBatchResponse<E::Result>, SuotarError>

Sends one batch to E’s endpoint. An empty batch is not sent.

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

Finishes the suotar_api_calls row of a call that never left, tagged so the health rules can tell our own refusal from Suotar being unreachable.

async fn exchange<R: DeserializeOwned>( &self, endpoint: SuotarEndpoint, request: RequestBuilder, body: Vec<u8>, sent_ids: Vec<String>, clock: Instant, ) -> (Result<SuotarBatchResponse<R>, SuotarError>, 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.