Struct StoreReads 

pub struct StoreReads { /* private fields */ }

Application reads over owned read-only connections, with a separate bounded executor for processing owned results after their transaction ends.

Implementations

impl StoreReads

pub fn open(path: &Path) -> Result<Self, DbError>

Open application readers after the store’s schema has been validated. All connections open before any worker or read capability is exposed.

pub async fn read<F, R, E>(&self, read: F) -> Result<Result<R, E>, DbError>

where F: for<'connection> FnOnce(SqlReadContext<'connection>) -> Result<R, E> + Send + 'static, R: Send + 'static, E: Send + 'static,

pub async fn read_tracked<F, R, E>( &self, read: F, ) -> Result<(Result<R, E>, QueryDependencies), DbError>

where F: for<'connection> FnOnce(SqlReadContext<'connection>) -> Result<R, E> + Send + 'static, R: Send + 'static, E: Send + 'static,

pub async fn process<F, R>(&self, process: F) -> R

where F: FnOnce() -> R + Send + 'static, R: Send + 'static,

Run owned result processing without occupying a read connection.

Trait Implementations

impl Clone for StoreReads

fn clone(&self) -> StoreReads

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.