Struct Request 

pub struct Request {
    pub auth_adapter: Arc<dyn AuthAdapter>,
    /* private fields */
}

Fields

auth_adapter: Arc<dyn AuthAdapter>

Implementations

impl Request

pub fn new( auth_adapter: Arc<dyn AuthAdapter>, proxy_tokens: Arc<ProxyTokenCache>, ) -> ClResult<Self>

pub async fn create_proxy_token( &self, tn_id: TnId, id_tag: &str, subject: Option<&str>, ) -> ClResult<Box<str>>

pub async fn get_bin( &self, tn_id: TnId, id_tag: &str, path: &str, auth: bool, ) -> ClResult<Bytes>

pub async fn get_stream( &self, tn_id: TnId, id_tag: &str, path: &str, auth: bool, ) -> ClResult<impl AsyncRead + Send + Unpin + use<>>

pub async fn get<Res>( &self, tn_id: TnId, id_tag: &str, path: &str, ) -> ClResult<Res>

where Res: DeserializeOwned,

pub async fn get_noauth<Res>( &self, tn_id: TnId, id_tag: &str, path: &str, ) -> ClResult<Res>

where Res: DeserializeOwned,

pub async fn get_public<Res>(&self, id_tag: &str, path: &str) -> ClResult<Res>

where Res: DeserializeOwned,

Make a public GET request without authentication or tenant context

pub async fn get_conditional<Res>( &self, id_tag: &str, path: &str, etag: Option<&str>, ) -> ClResult<ConditionalResult<Res>>

where Res: DeserializeOwned,

Make a conditional GET request with If-None-Match header for etag support

Returns ConditionalResult::NotModified if server returns 304, or ConditionalResult::Modified with data and new etag if content changed.

pub async fn post_public<Req, Res>( &self, id_tag: &str, path: &str, data: &Req, ) -> ClResult<Res>

where Req: Serialize, Res: DeserializeOwned,

Make a public POST request without authentication or tenant context

pub async fn post_bin( &self, _tn_id: TnId, id_tag: &str, path: &str, data: Bytes, ) -> ClResult<Bytes>

Unauthenticated POST to a remote tenant.

Callers (e.g. IDP registration/resend, action federation inbox) authenticate via signed tokens carried in the request body, not via an Authorization header — tn_id is therefore unused at the transport layer.

pub async fn post_stream<S>( &self, _tn_id: TnId, id_tag: &str, path: &str, stream: S, ) -> ClResult<Bytes>

where S: Stream<Item = Result<Frame<Bytes>, Error>> + Send + Sync + 'static,

Unauthenticated streaming POST to a remote tenant. See Self::post_bin for why no Authorization header is attached.

pub async fn post<Res>( &self, tn_id: TnId, id_tag: &str, path: &str, data: &impl Serialize, ) -> ClResult<Res>

where Res: DeserializeOwned,

pub async fn post_json_authed( &self, tn_id: TnId, id_tag: &str, path: &str, data: Bytes, ) -> ClResult<Bytes>

Authenticated JSON POST to a remote tenant. Mirrors Self::get_bin: attaches a cached proxy token in the Authorization header and retries once on 401/403 after invalidating the cached token. Branches on response status so callers see a typed Error (NotFound / Gone / PermissionDenied / NetworkError) instead of a downstream JSON- deserialization failure when the upstream returns an error envelope.

Hard-codes Content-Type: application/json; for binary authed POSTs add a separate helper that takes an explicit content-type parameter.

pub async fn post_authed<Res>( &self, tn_id: TnId, id_tag: &str, path: &str, data: &impl Serialize, ) -> ClResult<Res>

where Res: DeserializeOwned,

Typed JSON wrapper around Self::post_json_authed.

Trait Implementations

impl Clone for Request

fn clone(&self) -> Request

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Request

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.