Struct LockFreeExchangeManager

pub struct LockFreeExchangeManager { /* private fields */ }

Lock-free exchange manager optimized for high-frequency operations

Implementations

impl LockFreeExchangeManager

pub fn new() -> Self

Create a new lock-free exchange manager

pub async fn add_exchange( &self, exchange_name: SmartString, client: ExchangeClient, ) -> Result<()>

Add an exchange to the manager (infrequent operation, uses lock)

pub async fn remove_exchange(&self, exchange_name: &str) -> Result<()>

Remove an exchange from the manager (infrequent operation)

pub async fn start_collection( &self, exchange_name: &str, symbols: Vec<SmartString>, data_types: Vec<DataType>, event_sender: Sender<MarketDataEvent>, ) -> Result<()>

Start collection for an exchange (mostly lock-free)

pub fn record_message(&self, exchange_name: &str, bytes: u64)

Record a message for an exchange (lock-free)

pub fn record_error(&self, exchange_name: &str)

Record an error for an exchange (lock-free)

pub fn get_connection_status(&self) -> FxHashMap<SmartString, bool>

Get connection status for all exchanges (mostly lock-free reads)

pub async fn health_check(&self) -> FxHashMap<SmartString, bool>

Perform health check on all exchanges (lock-free coordination)

pub fn get_statistics(&self) -> ExchangeManagerStats

Get comprehensive statistics (mostly lock-free reads)

pub fn request_shutdown(&self)

Request shutdown (lock-free)

pub fn is_shutdown_requested(&self) -> bool

Check if shutdown was requested (lock-free)

pub async fn shutdown(&self) -> Result<()>

Shutdown all exchanges

Trait Implementations

impl Default for LockFreeExchangeManager

fn default() -> Self

Returns the “default value” for a type.

impl Send for LockFreeExchangeManager

impl Sync for LockFreeExchangeManager