Struct my_iot::db::Db

pub struct Db {
    connection: Connection,
    _cache: CHashMap<String, Reading>,
}

A database connection.

Fields

connection: Connection

Wrapped SQLite connection.

_cache: CHashMap<String, Reading>

Readings cache. Stores the latest reading for each sensor.

Methods

impl Db

pub fn new<P: AsRef<Path>>(path: P) -> Result<Db, Error>

Create a new database connection.

impl Db

Readings persistence.

pub fn insert_reading(&self, reading: &Reading) -> Result<(), Error>

Insert reading into database.

pub fn select_latest_readings(&self) -> Result<Vec<Reading>, Error>

Select latest reading for each sensor.

pub fn select_size(&self) -> Result<u64, Error>

Select database size in bytes.

pub fn select_last_reading(
    &self,
    sensor: &str
) -> Result<Option<Reading>, Error>

Select the very last sensor reading.

pub fn select_readings(
    &self,
    sensor: &str,
    since: &DateTime<Local>
) -> Result<Vec<Reading>, Error>

Select the latest sensor readings within the given time interval.

impl Db

Key-value store.

pub fn get<K, V>(&self, key: K) -> Result<Option<V>, Error> where
    K: AsRef<str>,
    V: SqliteTypeName + FromSql, 

Get an item from the key-value store.

pub fn set<K, V, E>(&self, key: K, value: V, expires_at: E) -> Result<(), Error> where
    K: AsRef<str>,
    V: SqliteTypeName + ToSql,
    E: Into<DateTime<Local>>, 

Set item in generic key-value store.