Struct AsyncClient 

pub struct AsyncClient { /* private fields */ }

Hardened provider-neutral reqwest asynchronous bearer transport.

The adapter uses reqwest’s Tokio-based execution internally but does not install or own a runtime. Callers must poll it from a compatible executor.

Implementations

impl AsyncClient

pub fn credential_snapshot( &self, ) -> Result<BearerCredentialSnapshot, CredentialStateError>

Captures the current generation without exposing token bytes.

pub fn rotate_bearer_token( &self, replacement: BearerToken, ) -> Result<CredentialGeneration, CredentialUpdateError>

Atomically replaces the token while retaining immutable scope.

pub fn rotate_bearer_token_with_lifetime( &self, replacement: BearerToken, lifetime: CredentialLifetime, ) -> Result<CredentialGeneration, CredentialUpdateError>

Atomically replaces an expiring token and its complete lifetime.

pub fn rotate_bearer_token_from_mut_bytes( &self, source: &mut [u8], ) -> Result<CredentialGeneration, TokenRotationError>

Validates and rotates mutable bytes, clearing the complete source.

pub fn rotate_bearer_token_from_secret_buffer( &self, source: SecretBuffer<'_>, ) -> Result<CredentialGeneration, TokenRotationError>

Validates and rotates guarded storage, which clears on return.

pub fn rotate_bearer_token_from_mut_bytes_with_lifetime( &self, source: &mut [u8], lifetime: CredentialLifetime, ) -> Result<CredentialGeneration, TokenRotationError>

Clears mutable input and atomically installs an expiring replacement.

pub fn rotate_bearer_token_from_secret_buffer_with_lifetime( &self, source: SecretBuffer<'_>, lifetime: CredentialLifetime, ) -> Result<CredentialGeneration, TokenRotationError>

Consumes guarded input and atomically installs an expiring replacement.

pub fn refresh_bearer_token( &self, handoff: BearerRefreshHandoff, replacement: BearerToken, ) -> Result<CredentialGeneration, TokenRefreshError>

Installs a refresh only if its captured generation is still current.

pub fn refresh_bearer_token_with_lifetime( &self, handoff: BearerRefreshHandoff, replacement: BearerToken, lifetime: CredentialLifetime, ) -> Result<CredentialGeneration, TokenRefreshError>

Installs an expiring refresh if its time-qualified handoff is current.

pub fn refresh_bearer_token_from_mut_bytes( &self, handoff: BearerRefreshHandoff, source: &mut [u8], ) -> Result<CredentialGeneration, TokenRefreshError>

Validates refreshed mutable bytes, clears them, and rejects stale work.

pub fn refresh_bearer_token_from_secret_buffer( &self, handoff: BearerRefreshHandoff, source: SecretBuffer<'_>, ) -> Result<CredentialGeneration, TokenRefreshError>

Consumes guarded refreshed storage and rejects stale work.

pub fn refresh_bearer_token_from_mut_bytes_with_lifetime( &self, handoff: BearerRefreshHandoff, source: &mut [u8], lifetime: CredentialLifetime, ) -> Result<CredentialGeneration, TokenRefreshError>

Clears mutable refresh input and atomically installs its lifetime.

pub fn refresh_bearer_token_from_secret_buffer_with_lifetime( &self, handoff: BearerRefreshHandoff, source: SecretBuffer<'_>, lifetime: CredentialLifetime, ) -> Result<CredentialGeneration, TokenRefreshError>

Consumes guarded refresh input and atomically installs its lifetime.

Trait Implementations

impl AsyncAuthenticatedTransport for AsyncClient

type Error = TransportFailure<TransportError>

Transport-specific failure.

async fn send_authenticated<'transport, 'request, 'policy, 'writer, 'buffer>( &'transport self, request: AuthenticatedRequest<'request, 'policy>, response: AsyncResponseStaging<'writer, 'buffer>, ) -> Result<ResponseCompletion, Self::Error>

where 'transport: 'writer, 'request: 'writer, 'policy: 'writer, 'buffer: 'writer,

Validates scope and stages one authenticated response.

impl BoundTransport for AsyncClient

fn endpoint_identity( &self, ) -> Result<EndpointIdentity<'_>, EndpointIdentityError>

Returns the immutable normalized endpoint identity.

impl Clone for AsyncClient

fn clone(&self) -> AsyncClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AsyncClient

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

Formats the value using the given formatter.

impl ResponseStorageSanitizer for AsyncClient

fn sanitize_response_storage(&self, response_storage: &mut [u8])

Applies an additive platform-specific cleanup operation.