Struct Db

pub struct Db { /* private fields */ }

Implementations

impl Db

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

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

check db version, return Error::VersionMismatch when db schema changed

pub fn open<P: AsRef<Path>>(path: P) -> Result<Self, Error>

pub fn writer(&self) -> Result<Writer<'_>, Error>

pub fn reader(&self) -> Result<Reader<'_>, Error>

pub fn commit<T: Transaction>(&self, txn: T) -> Result<(), Error>

pub fn put<E: AsRef<Event>>( &self, writer: &mut Writer<'_>, event: E, ) -> Result<CheckEventResult, Error>

pub fn get<R: FromEventData, K: AsRef<[u8]>, T: Transaction>( &self, txn: &T, event_id: K, ) -> Result<Option<R>, Error>

pub fn del<K: AsRef<[u8]>>( &self, writer: &mut Writer<'_>, event_id: K, ) -> Result<bool, Error>

pub fn batch_put<II, N>(&self, events: II) -> Result<usize, Error>

where II: IntoIterator<Item = N>, N: AsRef<Event>,

pub fn batch_get<R: FromEventData, II, N>( &self, event_ids: II, ) -> Result<Vec<R>, Error>

where II: IntoIterator<Item = N>, N: AsRef<[u8]>,

pub fn batch_del<II, N>(&self, event_ids: II) -> Result<(), Error>

where II: IntoIterator<Item = N>, N: AsRef<[u8]>,

pub fn iter<'txn, J: FromEventData, T: Transaction>( &self, txn: &'txn T, filter: &Filter, ) -> Result<Iter<'txn, T, J>, Error>

iter events by filter

pub fn iter_expiration<'txn, J: FromEventData, T: Transaction>( &self, txn: &'txn T, until: Option<u64>, ) -> Result<Iter<'txn, T, J>, Error>

iter expired events

pub fn iter_ephemeral<'txn, J: FromEventData, T: Transaction>( &self, txn: &'txn T, until: Option<u64>, ) -> Result<Iter<'txn, T, J>, Error>

iter ephemeral events

Trait Implementations

impl Clone for Db

fn clone(&self) -> Db

Returns a duplicate of the value.

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

Performs copy-assignment from source.