Struct my_iot::core::persistence::Db

pub struct Db {
    connection: Connection,
}

A database connection.

Fields

connection: Connection

Wrapped SQLite connection.

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 upsert_reading(&self, message: &Message) -> Result<(), Error>

Insert or replace reading into database.

pub fn select_actuals(&self) -> Result<Vec<Message>, 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<Message>, Error>

Select the very last sensor reading.

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

Select the latest sensor readings within the given time interval.