Struct mz_persist::sqlite::SqliteConsensus

pub struct SqliteConsensus { /* private fields */ }

Implementation of Consensus over a sqlite database.

Implementations

impl SqliteConsensus

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

Open a sqlite-backed Consensus instance at path.

Trait Implementations

impl Consensus for SqliteConsensus

fn head<'life0, 'life1, 'async_trait>(
    &'life0 self,
    _deadline: Instant,
    key: &'life1 str
) -> Pin<Box<dyn Future<Output = Result<Option<VersionedData>, ExternalError>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Returns a recent version of data, and the corresponding sequence number, if one exists at this location.

fn compare_and_set<'life0, 'life1, 'async_trait>(
    &'life0 self,
    deadline: Instant,
    key: &'life1 str,
    expected: Option<SeqNo>,
    new: VersionedData
) -> Pin<Box<dyn Future<Output = Result<Result<(), Option<VersionedData>>, ExternalError>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Update the VersionedData stored at this location to new, iff the current sequence number is exactly expected and new’s sequence number > the current sequence number.

fn scan<'life0, 'life1, 'async_trait>(
    &'life0 self,
    _deadline: Instant,
    key: &'life1 str,
    from: SeqNo
) -> Pin<Box<dyn Future<Output = Result<Vec<VersionedData>, ExternalError>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Return all versions of data stored for this key at sequence numbers >= from, in ascending order of sequence number.

fn truncate<'life0, 'life1, 'async_trait>(
    &'life0 self,
    deadline: Instant,
    key: &'life1 str,
    seqno: SeqNo
) -> Pin<Box<dyn Future<Output = Result<(), ExternalError>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Deletes all historical versions of the data stored at key that are < seqno, iff seqno <= the current sequence number.

impl Debug for SqliteConsensus

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.