Struct Data 

pub struct Data {
    global: Arc<Map>,
    retires: Sender<u64>,
    counter: Arc<Counter<Box<dyn Fn(u64) -> Result + Send + Sync>>>,
    pub(super) db: Arc<Database>,
}

Owns persistent global state and the two-phase sequence counter.

Dispatched counter values are recorded before use. A watch channel publishes the retirement frontier as outstanding permits are dropped.

Fields

global: Arc<Map>

retires: Sender<u64>

counter: Arc<Counter<Box<dyn Fn(u64) -> Result + Send + Sync>>>

db: Arc<Database>

Database handle used to report process-wide read-only state.

Implementations

impl Data

pub(super) fn new(args: &Args<'_>) -> Self

Restores the global counter and initializes retirement notifications.

A fresh database starts at zero, making one the first dispatched sequence number.

Panics

Panics when a successfully read stored counter cannot be decoded.

pub(super) async fn wait_pending(&self) -> Result<u64>

Waits for all sequence numbers dispatched at call time to retire.

The dispatched frontier is sampled before subscribing. The returned frontier is guaranteed to be at least that sample.

pub(super) async fn wait_count(&self, count: &u64) -> Result<u64>

Waits until the retirement frontier reaches count.

The returned frontier may exceed count when additional permits retire before the waiter is notified.

pub(super) fn next_count( &self, ) -> Permit<Box<dyn Fn(u64) -> Result + Send + Sync>>

Dispatches the next sequence number and returns its retirement permit.

Dispatch records the new number before exposing it to the caller.

Panics

Panics when the counter is exhausted or the dispatched value cannot be recorded.

pub(super) fn current_count(&self) -> u64

Returns the highest fully retired sequence number.

All writes through this frontier are safe for readers to observe.

pub(super) fn pending_count(&self) -> Range<u64>

Returns the retired-to-dispatched counter range.

The start is the reader-visible frontier and the end is the latest dispatched value.

fn handle_retire(sender: &Sender<u64>, count: u64) -> Result

fn store_count(db: &Arc<Database>, global: &Arc<Map>, count: u64) -> Result

fn stored_count(global: &Arc<Map>) -> Result<u64>

impl Data

pub fn bump_database_version(&self, new_version: u64)

Stores a new database schema version.

The value replaces the existing version in the global metadata map.

pub async fn database_version(&self) -> u64

Loads the current database schema version.

Missing or undecodable values are treated as version zero.