Struct BaseExchange 

pub struct BaseExchange {
    pub config: ExchangeConfig,
    pub http_client: HttpClient,
    pub market_cache: Arc<RwLock<MarketCache>>,
    pub market_loading_lock: Arc<Mutex<()>>,
    pub capabilities: ExchangeCapabilities,
    pub urls: HashMap<String, String>,
    pub timeframes: HashMap<String, String>,
    pub precision_mode: PrecisionMode,
}

Base exchange implementation

Fields

config: ExchangeConfig

Exchange configuration

http_client: HttpClient

HTTP client for API requests

market_cache: Arc<RwLock<MarketCache>>

Thread-safe market data cache

market_loading_lock: Arc<Mutex<()>>

Mutex to serialize market loading operations

capabilities: ExchangeCapabilities

Exchange capability flags

urls: HashMap<String, String>

API endpoint URLs

timeframes: HashMap<String, String>

Timeframe mappings

precision_mode: PrecisionMode

Precision mode for price/amount formatting

Implementations

impl BaseExchange

pub fn new(config: ExchangeConfig) -> Result<BaseExchange, Error>

Creates a new exchange instance

pub async fn load_markets( &self, reload: bool, ) -> Result<Arc<HashMap<String, Arc<Market>>>, Error>

Loads market data from the exchange

pub async fn load_markets_with_loader<F, Fut>( &self, reload: bool, loader: F, ) -> Result<Arc<HashMap<String, Arc<Market>>>, Error>

where F: FnOnce() -> Fut, Fut: Future<Output = Result<(Vec<Market>, Option<Vec<Currency>>), Error>>,

Loads market data with a custom loader function

pub async fn set_markets( &self, markets: Vec<Market>, currencies: Option<Vec<Currency>>, ) -> Result<Arc<HashMap<String, Arc<Market>>>, Error>

Sets market and currency data in the cache

pub async fn market(&self, symbol: &str) -> Result<Arc<Market>, Error>

Gets market information by trading symbol

pub async fn market_by_id(&self, id: &str) -> Result<Arc<Market>, Error>

Gets market information by exchange-specific market ID

pub async fn currency(&self, code: &str) -> Result<Arc<Currency>, Error>

Gets currency information by currency code

pub async fn symbols(&self) -> Result<Vec<String>, Error>

Gets all available trading symbols

pub fn throttle(&self) -> Result<(), Error>

👎Deprecated since 0.2.0: Rate limiting is now handled internally by HttpClient. This method is a no-op.

Applies rate limiting if enabled (deprecated, now handled by HttpClient)

pub fn check_required_credentials(&self) -> Result<(), Error>

Checks that required API credentials are configured

pub fn nonce(&self) -> i64

Gets a nonce value (current timestamp in milliseconds)

pub fn build_query_string(&self, params: &HashMap<String, Value>) -> String

Builds a URL query string from parameters

pub fn parse_json(&self, response: &str) -> Result<Value, Error>

Parses a JSON response string

pub fn handle_http_error(&self, status_code: u16, response: &str) -> Error

Handles HTTP error responses

pub fn safe_string(&self, dict: &Value, key: &str) -> Option<String>

Safely extracts a string value from a JSON object

pub fn safe_integer(&self, dict: &Value, key: &str) -> Option<i64>

Safely extracts an integer value from a JSON object

pub fn safe_float(&self, dict: &Value, key: &str) -> Option<f64>

Safely extracts a float value from a JSON object

pub fn safe_bool(&self, dict: &Value, key: &str) -> Option<bool>

Safely extracts a boolean value from a JSON object

pub fn parse_ticker( &self, ticker_data: &Value, market: Option<&Market>, ) -> Result<Ticker, Error>

Parses raw ticker data from exchange API response

pub fn parse_trade( &self, trade_data: &Value, market: Option<&Market>, ) -> Result<Trade, Error>

Parses raw trade data from exchange API response

pub fn parse_order( &self, order_data: &Value, market: Option<&Market>, ) -> Result<Order, Error>

Parses raw order data from exchange API response

pub fn parse_balance(&self, balance_data: &Value) -> Result<Balance, Error>

Parses raw balance data from exchange API response

pub fn parse_order_book( &self, orderbook_data: &Value, timestamp: Option<i64>, ) -> Result<OrderBook, Error>

Parses raw order book data from exchange API response

pub async fn calculate_fee( &self, symbol: &str, _order_type: OrderType, _side: OrderSide, amount: Decimal, price: Decimal, taker_or_maker: Option<&str>, ) -> Result<Fee, Error>

Calculates trading fee for a given order

pub async fn amount_to_precision( &self, symbol: &str, amount: Decimal, ) -> Result<Decimal, Error>

Converts an amount to the precision required by the market

pub async fn price_to_precision( &self, symbol: &str, price: Decimal, ) -> Result<Decimal, Error>

Converts a price to the precision required by the market

pub async fn cost_to_precision( &self, symbol: &str, cost: Decimal, ) -> Result<Decimal, Error>

Converts a cost to the precision required by the market

pub async fn calculate_cost( &self, symbol: &str, amount: Decimal, price: Decimal, ) -> Result<Decimal, Error>

Calculates the cost of a trade

Trait Implementations

impl Clone for BaseExchange

fn clone(&self) -> BaseExchange

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for BaseExchange

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

Formats the value using the given formatter.