Struct Db 

pub struct Db<Sel, T, VP>
where
    Sel: Clone + Eq + Hash,
    T: TableFromTupleData + TableValues<Sel>,
    VP: ValueProvider<Sel>,
{ /* private fields */ }

Implementations

impl<Sel, T, VP> Db<Sel, T, VP>

where Sel: Clone + Eq + Hash, T: TableFromTupleData + TableValues<Sel>, VP: ValueProvider<Sel>,

pub async fn from_env(replication: bool) -> Result<Self, Error>

pub async fn from_database_url( database_url: &str, replication: bool, ) -> Result<Self, Error>

pub async fn from_pool(pool: &PgPool, replication: bool) -> Result<Self, Error>

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

pub async fn sync_changes(&mut self) -> Result<HashSet<Index>, Error>

pub fn get_value(&self, name: &'static str, selector: Sel, t: Time) -> f64

pub fn get_value_opt( &self, name: &'static str, selector: Sel, t: Time, ) -> Option<f64>

pub fn register_fn( &self, name: &'static str, selector: Sel, t: Time, value_fn: impl Fn(&Db<Sel, T, VP>) -> f64, ) -> f64

pub fn graph( &self, ) -> &Rc<RefCell<MatrixGraph<(&'static str, Sel, Time), (), Directed, Option<()>, usize>>>

pub fn subscribe( &mut self, name: &'static str, selector: &Sel, t: &Time, ) -> Index

TODO: The subscription should be a separate object that automatically unsubscribes when it is dropped.

pub fn unsubscribe(&mut self, _ref: Index)

pub fn update( &mut self, name: &'static str, selector: &Sel, t: &Time, new_value: f64, ) -> HashSet<Index>

TODO: When updating values in bulk (e.g., in a transaction), we can wait with the recursive part until the end of the transaction. This way, we can avoid updating the same values multiple times.