Struct SimulatedExchange 

pub struct SimulatedExchange { /* private fields */ }

A simulated exchange for testing.

Implementations

impl SimulatedExchange

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

Creates a new simulated exchange.

pub fn set_latency(&mut self, ms: u64)

Sets the simulated latency.

pub fn fail_next_with(&self, error: ExchangeError)

Makes the next operation fail with the given error.

pub fn add_instrument( &self, symbol: impl Into<String>, name: impl Into<String>, price: Decimal, lot_size: u32, )

Adds an instrument to the market.

pub fn create_account( &self, account_id: impl Into<String>, initial_cash: Decimal, )

Creates an account with initial cash.

pub fn add_position(&self, account_id: &str, position: Position)

Adds a position to an account.

pub fn set_price(&self, symbol: &str, price: Decimal)

Sets the price for an instrument.

pub fn set_market_status(&self, status: MarketStatus)

Sets the market status for all instruments.

pub fn tick(&self)

Advances the market by one tick.

pub fn market(&self) -> Arc<RwLock<MarketManager>>

Gets a reference to the market manager.

Trait Implementations

impl Debug for SimulatedExchange

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

Formats the value using the given formatter.

impl ExchangeProvider for SimulatedExchange

fn info(&self) -> &ExchangeInfo

Returns information about this exchange.

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

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

Tests the connection and authentication.

fn get_wallet<'life0, 'life1, 'async_trait>( &'life0 self, account_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = ExchangeResult<Wallet>> + Send + 'async_trait>>

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

Gets account information and current positions (wallet).

fn get_instrument<'life0, 'life1, 'async_trait>( &'life0 self, symbol: &'life1 str, ) -> Pin<Box<dyn Future<Output = ExchangeResult<Instrument>> + Send + 'async_trait>>

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

Gets information about a specific instrument.

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

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

Gets a list of all available instruments.

fn get_market_data<'life0, 'life1, 'async_trait>( &'life0 self, symbol: &'life1 str, ) -> Pin<Box<dyn Future<Output = ExchangeResult<MarketData>> + Send + 'async_trait>>

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

Gets current market data for an instrument.

fn get_order_book<'life0, 'life1, 'async_trait>( &'life0 self, symbol: &'life1 str, depth: u32, ) -> Pin<Box<dyn Future<Output = ExchangeResult<OrderBook>> + Send + 'async_trait>>

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

Gets the order book for an instrument.

fn place_order<'life0, 'life1, 'async_trait>( &'life0 self, account_id: &'life1 str, order: Order, ) -> Pin<Box<dyn Future<Output = ExchangeResult<Order>> + Send + 'async_trait>>

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

Places an order.

fn cancel_order<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, account_id: &'life1 str, order_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = ExchangeResult<Order>> + Send + 'async_trait>>

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

Cancels an order.

fn get_order<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, account_id: &'life1 str, order_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = ExchangeResult<Order>> + Send + 'async_trait>>

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

Gets the current status of an order.

fn get_active_orders<'life0, 'life1, 'async_trait>( &'life0 self, account_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = ExchangeResult<Vec<Order>>> + Send + 'async_trait>>

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

Gets all active orders.

fn id(&self) -> &str

Returns the exchange identifier.

fn name(&self) -> &str

Returns the exchange name.

fn get_market_data_batch<'life0, 'life1, 'async_trait>( &'life0 self, symbols: &'life1 [String], ) -> Pin<Box<dyn Future<Output = ExchangeResult<Vec<MarketData>>> + Send + 'async_trait>>

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

Gets market data for multiple instruments.

fn is_market_open<'life0, 'life1, 'async_trait>( &'life0 self, symbol: &'life1 str, ) -> Pin<Box<dyn Future<Output = ExchangeResult<bool>> + Send + 'async_trait>>

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

Checks if the market is currently open for a symbol.

fn market_buy<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, account_id: &'life1 str, symbol: &'life2 str, lots: u32, ) -> Pin<Box<dyn Future<Output = ExchangeResult<Order>> + Send + 'async_trait>>

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

Creates a market buy order.

fn market_sell<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, account_id: &'life1 str, symbol: &'life2 str, lots: u32, ) -> Pin<Box<dyn Future<Output = ExchangeResult<Order>> + Send + 'async_trait>>

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

Creates a market sell order.