Struct MemoryStore 

pub struct MemoryStore { /* private fields */ }

In-memory time-series store (for testing and real-time buffers).

Implementations

impl MemoryStore

pub fn new() -> Self

pub fn bulk_insert( &mut self, channel: &str, samples: Vec<Sample>, ) -> Result<(), TsError>

Bulk-insert a pre-built sample vector.

pub fn at( &self, channel: &str, timestamp: f64, ) -> Result<Option<Sample>, TsError>

Value at a specific timestamp (exact match, no interpolation).

pub fn interpolate(&self, channel: &str, timestamp: f64) -> Result<f64, TsError>

Linear interpolation at a specific timestamp.

pub fn resample_mean( &self, channel: &str, t_start: f64, t_end: f64, window_s: f64, ) -> Result<Vec<Sample>, TsError>

Downsample by taking mean over windows of width window_s.

pub fn apply_range_check( &mut self, channel: &str, lo: f64, hi: f64, flag: u8, ) -> Result<usize, TsError>

Flag samples outside [lo, hi] with given quality code.

pub fn to_csv(&self, channel: &str) -> Result<String, TsError>

Export channel to (timestamp, value) CSV-format string.

Trait Implementations

impl Clone for MemoryStore

fn clone(&self) -> MemoryStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MemoryStore

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

Formats the value using the given formatter.

impl Default for MemoryStore

fn default() -> MemoryStore

Returns the “default value” for a type.

impl TimeSeriesStore for MemoryStore

fn create_channel(&mut self, channel: Channel)

Create or register a channel.

fn channel_info(&self, name: &str) -> Option<&Channel>

Return channel metadata.

fn channel_names(&self) -> Vec<String>

List all channel names.

fn append( &mut self, channel: &str, timestamp: f64, value: f64, ) -> Result<(), TsError>

Append a single sample.

fn append_with_quality( &mut self, channel: &str, timestamp: f64, value: f64, quality: u8, ) -> Result<(), TsError>

Append a sample with quality flag.

fn range( &self, channel: &str, t_start: f64, t_end: f64, ) -> Result<Vec<Sample>, TsError>

Retrieve all samples in [t_start, t_end].

fn latest(&self, channel: &str, n: usize) -> Result<Vec<Sample>, TsError>

Retrieve the latest N samples.

fn len(&self, channel: &str) -> Result<usize, TsError>

Count of samples in a channel.

fn is_empty(&self, channel: &str) -> Result<bool, TsError>

True if the channel has no samples.

fn stats( &self, channel: &str, t_start: f64, t_end: f64, ) -> Result<TsStats, TsError>

Statistics over a time range.