Struct redis_zset_ts::TimeSeries

pub struct TimeSeries<T> { /* private fields */ }

Connection to a Redis Time Series

Implementations

impl<T> TimeSeries<T>

pub fn new(namespace: &str, name: &str) -> Result<Self>

Creates a new connection to the named time series.

pub fn with_host(host: &str, namespace: &str, name: &str) -> Result<Self>

Creates a new connection to the named time series on the specified host.

pub fn with_uri(uri: &str, namespace: &str, name: &str) -> Result<Self>

Creates a new connection to the named time series on the host with the specified URI.

pub fn purge(&mut self, ts: f64) -> Result<()>

Deletes all the values in the time series before the specified time stamp.

pub fn purge_time(&mut self, ts: SystemTime) -> Result<()>

Deletes all the values in the time series before the specified time.

pub fn purge_duration(&mut self, dur: Duration) -> Result<()>

Deletes all the values in the time series except points that fall in the most recent time specified by the duration.

pub fn delete(&mut self) -> Result<()>

Removes the entire timeseries from the Redis DB.

impl<T: Serialize> TimeSeries<T>

pub fn add(&mut self, ts: f64, val: T) -> Result<()>

Adds a point to the time series.

pub fn add_now(&mut self, val: T) -> Result<()>

Adds a point to the time series, using the current time as the timestamp.

pub fn add_value<V>(&mut self, val: V) -> Result<()>

where V: Into<TimeValue<T>>,

Adds a point to the time series as a TimeValue.

pub fn add_multiple(&mut self, vals: &[TimeValue<T>]) -> Result<()>

Adds multiple points to the time series.

pub fn add_multiple_values(&mut self, vals: &[(f64, T)]) -> Result<()>

Adds multiple points to the time series from a slice of tuples.

impl<T: DeserializeOwned> TimeSeries<T>

pub fn get_range_any<R, RR>( &mut self, ts1: R, ts2: RR ) -> Result<Vec<TimeValue<T>>>

where R: ToRedisArgs, RR: ToRedisArgs,

Gets values from a time range The timestamps can be the usual floating point values, or anything that can be conbverted to a Redis argument, such as special strings like “-inf”, “+inf”, or “2.0)” to indicate open ranges.

pub fn get_range(&mut self, ts1: f64, ts2: f64) -> Result<Vec<TimeValue<T>>>

Gets values from a time range This gets the values from ts1 up to, but not including, ts2.

pub fn get_time_range( &mut self, ts1: SystemTime, ts2: SystemTime ) -> Result<Vec<TimeValue<T>>>

Gets values from a time range This gets the values from ts1 up to, but not including, ts2.

pub fn get_range_from(&mut self, ts: f64) -> Result<Vec<TimeValue<T>>>

Gets values starting from the specified time up to the latest value.

pub fn get_all(&mut self) -> Result<Vec<TimeValue<T>>>

Gets all the values in the series. This should be used with caution if the series is large.