Struct RankedRegister 

pub struct RankedRegister { /* private fields */ }

A ranked register backed by FoundationDB

Provides a mutable register with conflict detection via ranks. No initialization is needed — an absent key represents the bottom state (zero ranks, no value).

Thread Safety

RankedRegister is Clone, Send, and Sync. It holds only a Subspace and can be safely shared across tasks.

Implementations

impl RankedRegister

pub fn new(subspace: Subspace) -> Self

Create a new ranked register instance

The subspace isolates this register from other data in the database. No initialization step is required — the register starts in the bottom state (zero ranks, no value) until the first write.

pub fn subspace(&self) -> &Subspace

Returns a reference to the underlying subspace

pub async fn read<T>(&self, txn: &T, rank: Rank) -> Result<ReadResult>

where T: Deref<Target = Transaction>,

Perform a ranked read

Updates max_read_rank if the given rank is higher, installing a fence that prevents lower-ranked writes. Returns the current write rank and value.

Used by the leader before writing to ensure consistency.

pub async fn write<T>( &self, txn: &T, rank: Rank, value: &[u8], ) -> Result<WriteResult>

where T: Deref<Target = Transaction>,

Perform a ranked write

Commits the value only if:

• rank >= max_read_rank (no higher fence)
• rank > max_write_rank (no equal-or-higher write)

Returns WriteResult::Committed or WriteResult::Aborted.

pub async fn value<T>(&self, txn: &T) -> Result<Option<Vec<u8>>>

where T: Deref<Target = Transaction>,

Read the current value without updating ranks

Safe for followers and observers — does not install a fence, so it won’t interfere with the leader’s writes.

Trait Implementations

impl Clone for RankedRegister

fn clone(&self) -> RankedRegister

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RankedRegister

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

Formats the value using the given formatter.