Struct CachedTokenProvider 

pub struct CachedTokenProvider<T>
where
    T: Clone + Send + Sync + 'static,
{ /* private fields */ }

Cache + single-flight wrapper around a TokenRefresher.

Implementations

impl<T> CachedTokenProvider<T>

where T: Clone + Send + Sync + 'static,

pub fn new(refresher: Arc<dyn TokenRefresher<T>>) -> Self

Build with the default DEFAULT_REFRESH_BUFFER lead time.

pub fn with_refresh_buffer( refresher: Arc<dyn TokenRefresher<T>>, refresh_buffer: Duration, ) -> Self

Build with a custom refresh-buffer.

pub async fn current(&self) -> Result<T, CloudError>

Return the current valid token, refreshing if the cached value is missing or within the refresh-buffer of expiry.

Single-flight: only one caller runs the user-supplied TokenRefresher::refresh at a time. Other callers wait on a Notify for the refresh to complete and then re-check the cache. No lock is held across the user-supplied future.

pub fn invalidate(&self)

Drop the cached value. Useful when a 401 surfaces to force a reload regardless of the recorded expiry (clock skew defence).