Struct MarketCache 

pub struct MarketCache { /* private fields */ }

Market data cache structure with fine-grained locking.

Uses DashMap instead of RwLock<HashMap> to reduce lock contention in high-concurrency scenarios. Each key-value pair has its own lock, allowing concurrent reads and writes to different keys.

Performance Characteristics

• Concurrent reads: O(1) with no blocking
• Concurrent writes to different keys: O(1) with no blocking
• Writes to the same key: Serialized per-key

Example

use ccxt_core::base_exchange::MarketCache;

let cache = MarketCache::default();
// Multiple threads can read different markets concurrently
// without blocking each other

Implementations

impl MarketCache

pub fn new() -> Self

Creates a new empty market cache.

pub fn with_capacity( markets_capacity: usize, currencies_capacity: usize, ) -> Self

Creates a new market cache with pre-allocated capacity.

Use this when you know the approximate number of markets to avoid reallocations during loading.

pub fn is_loaded(&self) -> bool

Returns whether markets have been loaded.

pub fn get_market(&self, symbol: &str) -> Option<Arc<Market>>

Gets a market by symbol.

This is a lock-free read operation.

pub fn get_market_by_id(&self, id: &str) -> Option<Arc<Market>>

Gets a market by exchange-specific ID.

This is a lock-free read operation.

pub fn get_currency(&self, code: &str) -> Option<Arc<Currency>>

Gets a currency by code.

This is a lock-free read operation.

pub fn get_currency_by_id(&self, id: &str) -> Option<Arc<Currency>>

Gets a currency by exchange-specific ID.

This is a lock-free read operation.

pub fn market_count(&self) -> usize

Returns the number of cached markets.

pub fn currency_count(&self) -> usize

Returns the number of cached currencies.

pub fn symbols(&self) -> Vec<String>

Returns a copy of all symbol names.

pub fn codes(&self) -> Vec<String>

Returns a copy of all currency codes.

pub fn ids(&self) -> Vec<String>

Returns a copy of all market IDs.

pub fn markets(&self) -> Arc<HashMap<String, Arc<Market>>>

Returns all markets as a new HashMap.

Note: This creates a new HashMap and clones all Arc references. For iteration, consider using iter_markets() instead.

pub fn iter_markets(&self) -> impl Iterator<Item = (String, Arc<Market>)> + '_

Iterates over all markets.

This is more efficient than markets() when you only need to iterate.

pub fn contains_market(&self, symbol: &str) -> bool

Checks if a market exists by symbol.

pub fn contains_currency(&self, code: &str) -> bool

Checks if a currency exists by code.

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

Sets market and currency data in the cache.

This operation clears existing data and replaces it with the new data. It’s designed to be called during market loading/refresh.

pub fn clear(&self)

Clears all cached data.

Trait Implementations

impl Clone for MarketCache

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MarketCache

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

Formats the value using the given formatter.

impl Default for MarketCache

fn default() -> Self

Returns the “default value” for a type.