Struct SharedSeriesMap 

pub struct SharedSeriesMap<T: DataPoint> { /* private fields */ }

Arc<RwLock<HashMap<Key, Arc<RwLock<Series<T>>>>>> — MLC dual-read pattern.

Outer RwLock guards the map structure (only locked briefly during get_or_create). Inner RwLock per-series allows independent reads/writes across keys without serializing on the map mutex.

Implementations

impl<T: DataPoint> SharedSeriesMap<T>

pub fn new(default_capacity: usize) -> Self

pub async fn get_or_create(&self, key: SeriesKey) -> Arc<RwLock<Series<T>>>

Return existing series or create + insert an empty one.

pub async fn get(&self, key: &SeriesKey) -> Option<Arc<RwLock<Series<T>>>>

pub async fn remove(&self, key: &SeriesKey) -> Option<Arc<RwLock<Series<T>>>>

pub async fn len(&self) -> usize

pub async fn keys(&self) -> Vec<SeriesKey>

Trait Implementations

impl<T: DataPoint> Clone for SharedSeriesMap<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.