Struct VersionedRefTable 

pub struct VersionedRefTable<T: ?Sized> { /* private fields */ }

The refs write counter — the liveness source’s in-process invalidation half (crate::liveness “the arbitration window”): bumped on every CAS call through the composition’s refs impl, read by the source’s arbitration consult. See VersionedRefTable.

The wave-6 refs rows carry no version counter; the wrapper is the counter’s home (the POC-O table-embedded counter’s shape, moved into the composition wiring — the tables stay row-homes).

Implementations

impl<T: ?Sized> VersionedRefTable<T>

pub fn new(inner: Arc<T>, version: Arc<AtomicU64>) -> Self

The wrapper over the table and the shared write counter.

pub fn inner(&self) -> &Arc<T>

The wrapped table (the rows’ home — the liveness snapshot forwards through it).

pub fn version(&self) -> u64

The write counter’s current value (the liveness source’s arbitration epoch signal — the GitRefs impl’s verbatim delegation adds only the bump).

Trait Implementations

impl<T> GitRefs for VersionedRefTable<T>

where T: GitRefs + ?Sized,

fn list_refs<'life0, 'life1, 'async_trait>( &'life0 self, repo: &'life1 RepoRecord, ) -> Pin<Box<dyn Future<Output = Result<Vec<RefLine>, StorageError>> + Send + 'async_trait>>

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

Ref listing — advertisement + ls-refs response data (the full set; ref-prefix filtering is wire-side, client-driven).

fn apply_updates<'life0, 'life1, 'async_trait>( &'life0 self, repo: &'life1 RepoRecord, updates: Vec<RefUpdate>, atomic: bool, ) -> Pin<Box<dyn Future<Output = Result<Vec<RefOutcome>, StorageError>> + Send + 'async_trait>>

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

One CAS transaction per call — the atomic-correctness home (ADR-013 §7; the substrate row transaction — ADR-019 §2). Runs the per-ref CAS; per-ref denials are outcomes (RefOutcome), not errors (a stale ref is a business result of receive-pack — ADR-013 §7–8).

impl<T> RefRows for VersionedRefTable<T>

where T: RefRows + ?Sized,

fn snapshot<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<RefRowsSnapshot, StorageError>> + Send + 'async_trait>>

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

The full canonical snapshot: all repos’ rows, name-sorted, with the fingerprint over the canonical form.