Struct ClientCredentialsTokenProvider 

pub struct ClientCredentialsTokenProvider { /* private fields */ }

An OAUTHBEARER token provider that uses the OAuth 2 client credentials grant, as Kafka’s ClientCredentialsJwtRetriever with ClientSecretRequestFormatter does.

It keeps the token until the refresh time of Kafka’s ExpiringCredentialRefreshingLogin, then fetches a new one.

Implementations

impl ClientCredentialsTokenProvider

pub fn new(config: ClientCredentialsConfig) -> Result<Arc<Self>, String>

A provider for config.

Errors

Returns a description when the client id or secret is blank, or the endpoint is not an http or https URL, as Kafka’s ConfigException.

Trait Implementations

impl Debug for ClientCredentialsTokenProvider

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

Formats the value using the given formatter.

impl OAuthBearerTokenProvider for ClientCredentialsTokenProvider

fn token(&self) -> TokenFuture<'_>

The compact serialized token to send.

fn refresh(&self) -> TokenFuture<'_>

Fetch a new token even when a cached one has not reached its refresh time, as Kafka’s ExpiringCredentialRefreshingLogin re-logs in once its refresh timer fires. spawn_background_refresh calls this at each Self::refresh_at; a provider that caches nothing can leave the default, which is Self::token.

fn refresh_at(&self) -> RefreshFuture<'_>

The time a cached token should next be refreshed, once Self::token has fetched one. spawn_background_refresh polls this to know when to wake up and fetch proactively; a provider that caches nothing can leave the default, which never schedules a background fetch.

fn background_refresh_enabled(&self) -> bool

Whether spawn_background_refresh should run a background task for this provider.