Struct OAuth2Manager 

pub struct OAuth2Manager { /* private fields */ }

AuthManager implementing the OAuth2 client-credentials flow used by Iceberg REST catalogs.

A configured token is used directly; otherwise credential is exchanged for a token at the token endpoint and cached. The cached token is shared across sessions so it survives the config handshake.

Implementations

impl OAuth2Manager

pub fn new(token_endpoint: impl Into<String>) -> Self

Creates a manager exchanging credentials at token_endpoint, with no token or credential configured. Combine with the with_* methods:

let manager = OAuth2Manager::new("https://auth.example.com/v1/oauth/tokens")
    .with_credential(Some("client-id".into()), "client-secret".into());

pub fn with_token(self, token: impl Into<String>) -> Self

Sets a bearer token used directly (takes precedence over credential).

pub fn with_credential( self, client_id: Option<String>, client_secret: String, ) -> Self

Sets the client credential exchanged for a token at the token endpoint.

pub fn with_extra_headers(self, headers: HeaderMap) -> Self

Sets extra headers sent with token requests.

pub fn with_extra_oauth_params(self, params: HashMap<String, String>) -> Self

Adds extra OAuth2 form parameters (e.g. scope, audience), merged onto the defaults: provide a scope entry to replace the default catalog scope.

Trait Implementations

impl AuthManager for OAuth2Manager

fn init_session<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, client: &'life1 HttpClient, props: &'life2 HashMap<String, String>, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn AuthSession>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Session used for the initial /v1/config handshake, given the user-supplied properties.

fn catalog_session<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, client: &'life1 HttpClient, props: &'life2 HashMap<String, String>, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn AuthSession>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Session used for all subsequent catalog requests, given the properties merged from the user configuration and the server’s config response.

impl Debug for OAuth2Manager

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

Formats the value using the given formatter.