Struct Sqlite 

pub struct Sqlite { /* private fields */ }

Implementations

impl Sqlite

pub fn new( conn_gen: impl FnMut() -> Result<(Connection, Box<dyn RngCore + Send>), JsErrorBox>, notifier: SqliteNotifier, config: SqliteConfig, ) -> Result<Sqlite, SqliteCreateError>

impl Sqlite

pub async fn snapshot_read( &self, requests: Vec<ReadRange>, options: SnapshotReadOptions, ) -> Result<Vec<ReadRangeOutput>, SqliteBackendError>

pub async fn atomic_write( &self, write: AtomicWrite, ) -> Result<Option<CommitResult>, SqliteBackendError>

pub async fn dequeue_next_message( &self, ) -> Result<Option<SqliteMessageHandle>, SqliteBackendError>

pub fn watch( &self, keys: Vec<Vec<u8>>, ) -> Pin<Box<dyn Stream<Item = Result<Vec<WatchKeyOutput>, JsErrorBox>> + Send>>

pub fn close(&self)

Trait Implementations

impl Clone for Sqlite

fn clone(&self) -> Sqlite

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Database for Sqlite

type QMH = SqliteMessageHandle

fn snapshot_read<'life0, 'async_trait>( &'life0 self, requests: Vec<ReadRange>, options: SnapshotReadOptions, ) -> Pin<Box<dyn Future<Output = Result<Vec<ReadRangeOutput>, JsErrorBox>> + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn atomic_write<'life0, 'async_trait>( &'life0 self, write: AtomicWrite, ) -> Pin<Box<dyn Future<Output = Result<Option<CommitResult>, JsErrorBox>> + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn dequeue_next_message<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<Self::QMH>, JsErrorBox>> + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn watch( &self, keys: Vec<Vec<u8>>, ) -> Pin<Box<dyn Stream<Item = Result<Vec<WatchKeyOutput>, JsErrorBox>>>>

fn close(&self)