Enum UnifiedProvider

pub enum UnifiedProvider {
    BinanceFutures(Box<BinanceFuturesProvider>),
}

Unified provider interface for the monitor system

Variants

BinanceFutures(Box<BinanceFuturesProvider>)

Binance futures market provider

Implementations

impl UnifiedProvider

pub fn new(exchange_name: &str) -> Result<Self>

Create a new provider based on exchange name

pub fn name(&self) -> &str

Get the exchange name

Trait Implementations

impl ProviderExt for UnifiedProvider

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

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

Connect to the exchange

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

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

Disconnect from the exchange

fn subscribe_orderbook<'life0, 'life1, 'async_trait>( &'life0 mut self, instrument_id: &'life1 InstrumentId, depth: usize, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Subscribe to orderbook updates for an instrument

fn subscribe_trades<'life0, 'life1, 'async_trait>( &'life0 mut self, instrument_id: &'life1 InstrumentId, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Subscribe to trade updates for an instrument

fn unsubscribe_orderbook<'life0, 'life1, 'async_trait>( &'life0 mut self, instrument_id: &'life1 InstrumentId, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Unsubscribe from orderbook updates

fn unsubscribe_trades<'life0, 'life1, 'async_trait>( &'life0 mut self, instrument_id: &'life1 InstrumentId, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Unsubscribe from trade updates

fn is_connected(&self) -> bool

Check if connected

fn connection_stats(&self) -> ConnectionStats

Get connection statistics

fn run_with_handler<'life0, 'async_trait>( &'life0 mut self, handler: Box<dyn DataHandler + Send + Sync>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Run the provider with a data handler

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

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

Fetch available instruments