Struct InstrumentStore 

pub struct InstrumentStore { /* private fields */ }

Local instrument storage with initialization tracking.

Provides add/find/get_all operations for instrument caching. Not thread-safe by itself; wrap in Arc<RwLock<InstrumentStore>> when sharing across async tasks or WebSocket handlers.

Storage preserves insertion order because adapters publish instruments to the data engine straight from this store, and that emission sequence must hold across runs. The map keeps the ahash hasher so ordered iteration costs nothing on lookup.

Implementations

impl InstrumentStore

pub fn new() -> Self

Creates a new empty instrument store.

pub fn add(&mut self, instrument: InstrumentAny)

Adds an instrument to the store, replacing any existing entry with the same ID.

pub fn add_bulk(&mut self, instruments: Vec<InstrumentAny>)

Adds multiple instruments to the store.

pub fn find(&self, instrument_id: &InstrumentId) -> Option<&InstrumentAny>

Returns the instrument for the given ID, if found.

pub fn contains(&self, instrument_id: &InstrumentId) -> bool

Returns whether the store contains the given instrument ID.

pub fn get_all(&self) -> &IndexMap<InstrumentId, InstrumentAny, RandomState>

Returns all instruments as a map keyed by instrument ID.

pub fn list_all(&self) -> Vec<&InstrumentAny>

Returns all instruments as a vector.

pub fn count(&self) -> usize

Returns the number of instruments in the store.

pub fn is_empty(&self) -> bool

Returns whether the store is empty.

pub fn is_initialized(&self) -> bool

Returns whether the store has been marked as initialized.

pub fn set_initialized(&mut self)

Marks the store as initialized.

pub fn clear(&mut self)

Clears all instruments and resets initialization state.

Trait Implementations

impl Debug for InstrumentStore

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

Formats the value using the given formatter.

impl Default for InstrumentStore

fn default() -> InstrumentStore

Returns the “default value” for a type.