Struct AckTable 

pub struct AckTable { /* private fields */ }

The fold-frontier / ack bookkeeping B3’s relay ack(frontier) reports against: per-device max folded HLC, monotone-only advance, persisted alongside the checkpoint (temp + atomic rename, like everything durable here). This is the proposal’s acked[device] table, device-local.

MUST, binding on B3: an ack asserts durably-folded state. A device may report ack(frontier) only after the ops at/below that frontier are durably persisted on it (journal-durable, fold applied) — an ack sent from memory ahead of the fsync lets compaction drop ops the acking device then loses in a crash, which is exactly the data loss the stable frontier exists to prevent. The mirror of B1’s journal-durable-before-transmit rule.

Implementations

impl AckTable

pub fn new() -> Self

pub fn ack(&mut self, device_id: impl Into<String>, frontier: Hlc) -> bool

Advance a device’s acked frontier. Monotone-only: an ack at or below the current frontier is ignored (returns false) — a delayed or replayed ack can never move GC eligibility backwards.

pub fn get(&self, device_id: &str) -> Option<&Hlc>

pub fn devices(&self) -> impl Iterator<Item = &str>

pub fn stable_frontier(&self) -> Option<&Hlc>

The stable frontier — min(acked[d]) over every known device (proposal §“Snapshots”). Ops at or below it are folded by everyone and are the only truncation candidates. None when no device has acked (nothing is ever droppable then).

pub fn save(&self, path: &Path) -> Result<()>

Durably persist (temp + atomic rename); pairs with AckTable::load. Kept alongside the checkpoint directory by convention.

pub fn load(path: &Path) -> Result<Self>

Load a persisted table; a missing file is an empty table (a fresh device knows of no acks — and an empty table makes compaction refuse, the safe default).

Trait Implementations

impl Clone for AckTable

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AckTable

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

Formats the value using the given formatter.

impl Default for AckTable

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for AckTable

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for AckTable

impl PartialEq for AckTable

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for AckTable

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for AckTable