Struct HisStore 

pub struct HisStore { /* private fields */ }

Thread-safe in-memory time-series store.

Maps entity IDs to sorted vectors of HisItem, ordered by timestamp.

Implementations

impl HisStore

pub fn new() -> Self

Create a new empty history store.

pub fn write(&self, id: &str, new_items: Vec<HisItem>)

Write history items for a given point ID.

Items are merged into the existing series and the result is kept sorted by timestamp. Duplicate timestamps are replaced.

pub fn read( &self, id: &str, start: Option<DateTime<FixedOffset>>, end: Option<DateTime<FixedOffset>>, ) -> Vec<HisItem>

Read history items for a point, optionally bounded by start/end.

Both bounds are inclusive. If start is None, reads from the beginning. If end is None, reads to the end.

pub fn is_empty(&self, id: &str) -> bool

Whether the store has no items for the given point.

pub fn len(&self, id: &str) -> usize

Return the count of history items stored for a given point.

Trait Implementations

impl Default for HisStore

fn default() -> Self

Returns the “default value” for a type.

impl HistoryProvider for HisStore

fn his_read<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, start: Option<DateTime<FixedOffset>>, end: Option<DateTime<FixedOffset>>, ) -> Pin<Box<dyn Future<Output = Vec<HisItem>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Read historical items for an entity within the optional time range.

fn his_write<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, items: Vec<HisItem>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Write historical items for an entity.