Struct UnifiedAuthManager

pub struct UnifiedAuthManager { /* private fields */ }

Unified authentication manager that wraps exchange-specific implementations

Implementations

impl UnifiedAuthManager

pub fn new( exchange_name: impl Into<SmartString>, adapter: Arc<dyn AuthenticationManager>, ) -> Self

Create a new unified authentication manager

pub const fn with_cache_validity(self, duration: Duration) -> Self

Set cache validity duration

pub fn clear_cache(&self)

Clear all caches

pub fn create_rest_context( &self, method: &str, path: &str, body: Option<&str>, ) -> AuthenticationContext

Create a standard REST context for simple cases

pub async fn authenticate_simple_rest( &self, method: &str, path: &str, body: Option<&str>, ) -> Result<HeaderMap>

Authenticate a simple REST request (convenience method)

pub fn get_auth_stats(&self) -> AuthenticationStats

Get authentication statistics

Trait Implementations

impl AuthenticationManager for UnifiedAuthManager

fn authenticate_rest_request<'life0, 'life1, 'async_trait>( &'life0 self, context: &'life1 AuthenticationContext, ) -> Pin<Box<dyn Future<Output = Result<AuthenticationResult>> + Send + 'async_trait>>

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

Generate authentication for a REST API request

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

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

Generate authentication for a WebSocket connection

fn authenticate_websocket_trading<'life0, 'async_trait>( &'life0 self, timestamp: Option<u64>, ) -> Pin<Box<dyn Future<Output = Result<AuthenticationResult>> + Send + 'async_trait>>

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

Generate WebSocket trading authentication (if supported)

fn is_authentication_valid(&self) -> bool

Check if authentication is still valid

fn time_until_expiration(&self) -> Option<Duration>

Get the time until authentication expires (if applicable)

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

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

Refresh authentication if needed (for JWT-based exchanges)

fn exchange_name(&self) -> &str

Get the exchange name

fn api_key(&self) -> &str

Get the API key

fn supports_websocket_trading(&self) -> bool

Check if this authentication supports WebSocket trading

fn requires_refresh(&self) -> bool

Check if this authentication requires periodic refresh

fn refresh_interval(&self) -> Option<Duration>

Get refresh interval (if applicable)