Struct cxmr_broker::Broker

pub struct Broker { /* fields omitted */ }

Exchanges broker.

Methods

impl Broker

pub fn new(accounts: Vec<BrokerAccount>, exchanges: BrokerExchanges) -> Self

Creates new broker.

pub fn new_simulation(exchanges: BrokerExchanges) -> Self

Creates new broker for simulation.

pub fn accounts(&self) -> &[BrokerAccount]

Returns all broker accounts.

pub fn orders(&self) -> &OrderMap

Returns all broker orders.

pub fn exchanges(&self) -> Vec<&ExchangeBroker>

Returns all exchanges brokers.

pub fn get(&self, exchange: &Exchange) -> Option<&ExchangeBroker>

Returns broker exchange by it's identifier.

pub fn get_market(&self, market: Market) -> Option<&MarketBroker>

Gets market by exchange and currency pair.

pub fn get_market_mut(&mut self, market: Market) -> Option<&mut MarketBroker>

Gets market by exchange and currency pair.

pub fn get_ask_price(&self, market: Market) -> Option<u64>

Gets ask price on a market.

pub fn get_bid_price(&self, market: Market) -> Option<u64>

Gets bid price on a market.

pub fn update(&mut self, events: Events) -> Result<Events, Error>

Updates order book and accounts.

pub fn update_private<'a, I>(&mut self, acc: &str, events: Vec<UserEvent>) where
    I: Iterator<Item = &'a UserEvent>, 

Updates order book and accounts.

pub fn user_data_key(&self, name: &str) -> Option<String>

Returns user data stream key for account, if any.

pub fn set_user_data_key(&mut self, name: String, key: String)

Sets user data stream key for account.

pub fn insert_orders(&mut self, account: String, orders: Vec<MarketOrder>)

Inserts orders under account name.

pub fn update_from_row(
    &mut self,
    market: Market,
    row: &EventData
) -> Result<(), Error>

Updates market order books from data rows.

pub fn update_from_rows(
    &mut self,
    market: Market,
    rows: &Vec<EventData>
) -> Result<(), Error>

Updates market order books from data rows.

pub fn update_orderbook(
    &mut self,
    market: Market,
    orderbook: OrderBook
) -> Result<(), Error>

Updates market order books.

pub fn into_shared(self) -> SharedBroker

Wraps broker in an Arc and RwLock.