Struct modio_logger_db::Datastore

pub struct Datastore { /* private fields */ }

Implementations

impl Datastore

pub async fn metadata_get_names(&self) -> Result<Vec<Metadata>, Error>

pub async fn metadata_get_units(&self) -> Result<Vec<Metadata>, Error>

pub async fn metadata_get_descriptions(&self) -> Result<Vec<Metadata>, Error>

pub async fn metadata_get_enum(&self) -> Result<Vec<Metadata>, Error>

pub async fn get_metadata(&self, key: &str) -> Result<Option<Metadata>, Error>

pub async fn get_all_metadata(&self) -> Result<Vec<Metadata>, Error>

pub async fn metadata_set_name(
    &self,
    key: &str,
    name: String
) -> Result<(), Error>

Set the name for a sensor If the name was already set, replaces it.

pub async fn metadata_set_unit(
    &self,
    key: &str,
    unit: String
) -> Result<(), Error>

Set the unit for an key. If the unit is already set, will return some kind of Error.

pub async fn metadata_set_description(
    &self,
    key: &str,
    description: String
) -> Result<(), Error>

Set the description for a sensor If the description was already set, replaces it.

pub async fn metadata_set_mode(
    &self,
    key: &str,
    mode: SensorMode
) -> Result<(), Error>

Set the mode for a sensor. (ReadOnly, ReadWrite, WriteOnly) If the mode was already set, replaces it.

pub async fn metadata_set_enum(
    &self,
    key: &str,
    value_map: ValueMap
) -> Result<(), Error>

Set the enum (lookup table) for a sensor If the enum was already set, replaces it.

impl Datastore

pub async fn new(pool: SqlitePool) -> Result<Self, Error>

Construct a datastore Takes an pre-configured and migrated DB pool and opens a temp buffer.

Errors

Any SQLx Error is returned.

pub fn pool(&self) -> SqlitePool

pub async fn insert(
    &self,
    key: &str,
    value: &str,
    time: i64,
    timefail: bool
) -> Result<(), Error>

Insert a single data-point into the database or buffer

Errors

Any SQL error.

pub async fn insert_bulk(
    &self,
    data: Vec<Metric>,
    timefail: bool
) -> Result<(), Error>

Insert a batch of data-points into the datastore Stores all the keys to permanent storage, but may buffer actual log values.

Errors

Any SQL error.

impl Datastore

pub async fn should_persist(&self) -> Result<bool, Error>

Check if we should persist data to disk according to heurestic

Errors

Any SQL errors are returned.

pub async fn should_persist_age(&self) -> Result<bool, Error>

Check if we should persist data to disk according to age heurestic

Errors

Any SQL errors are returned.

pub async fn should_persist_key(&self, key: &str) -> Result<bool, Error>

Check if we need to persist data to have current data for this key

Errors

Key missing or other SQL error.

pub async fn persist_data(&self) -> Result<(), Error>

impl Datastore

pub async fn get_batch(&self, size: u32) -> Result<Vec<TXMetric>, Error>

pub async fn get_internal_batch(&self, size: u32) -> Result<Vec<TXMetric>, Error>

pub async fn drop_batch(&self, ids: &[i64]) -> Result<(), Error>

impl Datastore

pub async fn fix_timefail(&self, adjust: f32) -> Result<(), Error>

impl Datastore

pub async fn get_last_datapoint(&self, key: &str) -> Result<Metric, Error>

pub async fn get_latest_logdata(&self) -> Result<Vec<Metric>, Error>

impl Datastore

pub async fn has_transaction(&self, token: &str) -> Result<bool, Error>

pub async fn transaction_add(
    &self,
    key: &str,
    expected: &str,
    target: &str,
    token: &str
) -> Result<(), Error>

pub async fn transaction_get(
    &self,
    prefix: &str
) -> Result<Vec<Transaction>, Error>

pub async fn transaction_fail(
    &self,
    transaction_id: i64,
    timefail: bool
) -> Result<u64, Error>

pub async fn transaction_pass(
    &self,
    transaction_id: i64,
    timefail: bool
) -> Result<u64, Error>

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

Fail all pending transactions

impl Datastore

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

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

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

pub async fn need_vacuum_or_shrink(&self) -> Result<usize, Error>

impl Datastore

pub async fn temporary() -> Datastore

Trait Implementations

impl Drop for Datastore

fn drop(&mut self)

Executes the destructor for this type.