Struct FdbTimestampOracle 

pub struct FdbTimestampOracle<N> {
    timeline: String,
    next: N,
    db: Arc<Database>,
    read_only: bool,
    read_ts_key: Vec<u8>,
    write_ts_key: Vec<u8>,
}

A TimestampOracle backed by FoundationDB.

Fields

timeline: String

next: N

db: Arc<Database>

read_only: bool

A read-only timestamp oracle is NOT allowed to do operations that change the backing FoundationDB state.

read_ts_key: Vec<u8>

read_ts key for this timeline

write_ts_key: Vec<u8>

write_ts key for this timeline

Implementations

impl<N: Sync> FdbTimestampOracle<N>

async fn open_inner( timeline: String, next: N, read_only: bool, db: Arc<Database>, prefix: Vec<String>, directory: DirectoryLayer, ) -> Result<FdbTimestampOracle<N>, Error>

async fn max_ts(&self) -> Result<Option<PackableTimestamp>, Error>

async fn max_rs_trx( &self, trx: &Transaction, ) -> Result<Option<PackableTimestamp>, FdbTransactError>

impl<N> FdbTimestampOracle<N>

where N: GenericNowFn<Timestamp> + Debug + 'static,

pub async fn open( config: FdbTimestampOracleConfig, timeline: String, initially: Timestamp, next: N, read_only: bool, ) -> Result<Self, Error>

Open a FoundationDB TimestampOracle instance with config, for the timeline named timeline. next generates new timestamps when invoked. Timestamps that are returned are made durable and will never retract.

async fn initialize(&self, initially: Timestamp) -> Result<(), FdbBindingError>

Initialize the timestamps for this timeline if they don’t exist.

Both read_ts and write_ts are set to initially if they do not already exist.

pub async fn get_all_timelines( config: FdbTimestampOracleConfig, ) -> Result<Vec<(String, Timestamp)>, Error>

Returns a Vec of all known timelines along with their current greatest timestamp (max of read_ts and write_ts).

For use when initializing another TimestampOracle implementation from another oracle’s state.

async fn write_ts_trx( &self, trx: &Transaction, proposed_next_ts: Timestamp, ) -> Result<Timestamp, FdbTransactError>

async fn peek_write_ts_trx( &self, trx: &Transaction, ) -> Result<Option<PackableTimestamp>, FdbTransactError>

async fn read_ts_trx( &self, trx: &Transaction, ) -> Result<Option<PackableTimestamp>, FdbTransactError>

async fn apply_write_trx( &self, trx: &Transaction, write_ts: Timestamp, ) -> Result<(), FdbTransactError>

Trait Implementations

impl<N> Debug for FdbTimestampOracle<N>

where N: GenericNowFn<Timestamp> + Debug,

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

Formats the value using the given formatter.

impl<N> TimestampOracle<Timestamp> for FdbTimestampOracle<N>

where N: GenericNowFn<Timestamp> + Debug + 'static,

fn write_ts<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = WriteTimestamp<Timestamp>> + Send + 'async_trait>>

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

Acquire a new timestamp for writing.

fn peek_write_ts<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Timestamp> + Send + 'async_trait>>

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

Peek the current write timestamp.

fn read_ts<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Timestamp> + Send + 'async_trait>>

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

Acquire a new timestamp for reading.

fn apply_write<'life0, 'async_trait>( &'life0 self, write_ts: Timestamp, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Mark a write at write_ts completed.