Struct architect_api::client::symbology_loader::Client

pub struct Client { /* private fields */ }

The symbology loader client is the symbology client plus rpcs to update symbology.

Implementations

impl Client

pub async fn new(common: &Common) -> Result<Self>

Create a new symbology loader client

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

Wait for the symbology to download from the symbology server

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

ensure all previous commits have propagated locally

pub async fn set_price_in_limit_dollars( &self, product: Product, price: Decimal ) -> Result<()>

pub async fn add_product( &self, name: Chars, class: ProductClass, price_in_limit_dollars: Decimal ) -> Result<()>

pub async fn remove_product(&self, product: Product) -> Result<()>

pub async fn add_product_and_flush( &self, name: Chars, class: &ProductClass, price_in_limit_dollars: Option<Decimal> ) -> Result<Product>

pub async fn add_tradable_product( &self, base: Product, quote: Product, venue: Venue, route: Route, quote_info: Option<QuoteInfo>, trade_info: Option<TradeInfo> ) -> Result<()>

pub async fn remove_tradable_product( &self, tradable: TradableProduct ) -> Result<()>

pub async fn add_route(&self, route: Chars) -> Result<()>

pub async fn add_route_and_flush(&self, route: Chars) -> Result<Route>

pub async fn remove_route(&self, route: Route) -> Result<()>

pub async fn add_venue(&self, venue: Chars) -> Result<()>

pub async fn add_venue_and_flush(&self, venue: Chars) -> Result<Venue>

pub async fn remove_venue(&self, venue: Venue) -> Result<()>

pub async fn add_quote_symbol(&self, symbol: Chars) -> Result<()>

pub async fn add_quote_symbol_and_flush( &self, symbol: Chars ) -> Result<QuoteSymbol>

pub async fn remove_quote_symbol(&self, symbol: QuoteSymbol) -> Result<()>

pub async fn add_trading_symbol(&self, symbol: Chars) -> Result<()>

pub async fn add_trading_symbol_and_flush( &self, symbol: Chars ) -> Result<TradingSymbol>

pub async fn remove_trading_symbol(&self, symbol: TradingSymbol) -> Result<()>

pub async fn add_fiats(&self, fiats: FxHashSet<&str>) -> Result<()>

pub async fn add_venue_and_direct_route( &self, venue: &'static str ) -> Result<(Route, Venue)>