Struct RefreshTokenSource 

pub struct RefreshTokenSource { /* private fields */ }

A TokenSource automatically refreshing the token before it expires.

Implementations

impl RefreshTokenSource

pub fn builder<T>( name: impl Into<String>, token_refresher: T, ) -> RefreshTokenSourceBuilder<T>

where T: TokenRefresher,

Creates a builder for a RefreshTokenSource.

pub fn new( name: String, token_refresher: impl TokenRefresher, refresh_retry_delay: Duration, refresh_threshold: Duration, min_token_lifetime: Duration, initial_token: Option<TokenWithExpiry>, ) -> RefreshTokenSource

Creates a new RefreshTokenSource.

Arguments

• name - Name of the token source, used for logging.
• refresh_function - Function to refresh the token.
• refresh_retry_delay - Delay between retries if the refresh function fails.
• refresh_threshold - Duration before the token’s expiry when a refresh should be attempted.
• refresh_timeout - Duration to wait for a refresh to complete when get_token is called.
• initial_token - Optional pre-fetched token to publish immediately on startup.

Trait Implementations

impl TokenSource for RefreshTokenSource

fn watch( &self, ) -> Receiver<Option<Result<String, Box<dyn Error + Send + Sync>>>>

Returns a watch receiver that always holds the latest valid token.

fn get_token<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<String, Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

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

Gets a token, possibly refreshing it.

fn format_header(&self, token: String) -> String

Formats the token for use in an Authorization header.