Struct FdbConsensus 

pub struct FdbConsensus {
    keys: DirectorySubspace,
    data: DirectorySubspace,
    db: Database,
}

Implementation of Consensus over a Foundation database.

Fields

keys: DirectorySubspace

Subspace for data.

data: DirectorySubspace

Subspace for data.

db: Database

The FoundationDB database handle.

Implementations

impl FdbConsensus

pub async fn open(config: FdbConsensusConfig) -> Result<Self, ExternalError>

Open a FoundationDB Consensus instance with config.

async fn open_directory( db: &Database, directory: &DirectoryLayer, path: &[String], ) -> Result<DirectorySubspace, ExternalError>

Opens (or creates) a directory at the specified path. Errors if the directory is a partition, or cannot be opened for another reason..

async fn head_trx( &self, trx: &Transaction, data_key: &Subspace, ) -> Result<Option<VersionedData>, FdbTransactError>

async fn compare_and_set_trx( &self, trx: &Transaction, data_key: &Subspace, expected: &Option<SeqNo>, new: &VersionedData, key: &str, ) -> Result<CaSResult, FdbTransactError>

async fn scan_trx( &self, trx: &Transaction, data_key: &Subspace, from: &SeqNo, limit: &usize, entries: &mut Vec<VersionedData>, ) -> Result<(), FdbTransactError>

async fn truncate_trx( &self, trx: &Transaction, data_key: &Subspace, until: &SeqNo, ) -> Result<(), FdbTransactError>

Trait Implementations

impl Consensus for FdbConsensus

fn list_keys(&self) -> ResultStream<'_, String>

Returns all the keys ever created in the consensus store.

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

where Self: 'async_trait, 'life0: 'async_trait, 'life1: '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, key: &'life1 str, expected: Option<SeqNo>, new: VersionedData, ) -> Pin<Box<dyn Future<Output = Result<CaSResult, ExternalError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: '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, key: &'life1 str, from: SeqNo, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<VersionedData>, ExternalError>> + Send + 'async_trait>>

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

Return limit 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, key: &'life1 str, seqno: SeqNo, ) -> Pin<Box<dyn Future<Output = Result<Option<usize>, ExternalError>> + Send + 'async_trait>>

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

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

impl Debug for FdbConsensus

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

Formats the value using the given formatter.