Struct CachedCredentialsProvider 

pub struct CachedCredentialsProvider { /* private fields */ }

Expiration-aware provider that coalesces concurrent refresh requests.

A refresh is performed while holding a Tokio mutex. Concurrent callers wait for that single refresh and then consume the same cached result, preventing refresh storms. If an early refresh fails, credentials that have not actually expired are returned until a later call can retry.

Implementations

impl CachedCredentialsProvider

pub fn new(provider: Arc<dyn CredentialsProvider>) -> Self

Wraps a provider and refreshes expiring credentials one minute early.

pub fn with_refresh_before( provider: Arc<dyn CredentialsProvider>, refresh_before: Duration, ) -> Self

Wraps a provider with a custom early-refresh window.

pub async fn invalidate(&self)

Clears the current cache entry so the next request refreshes it.

Trait Implementations

impl CredentialsProvider for CachedCredentialsProvider

fn provide_credentials<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Credentials, S3Error>> + Send + 'async_trait>>

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

Resolves credentials for a request.

impl Debug for CachedCredentialsProvider

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

Formats the value using the given formatter.