Struct PartialGraphCommittedEpochs 

pub struct PartialGraphCommittedEpochs {
    inner: Mutex<HashMap<PartialGraphId, Sender<u64>>>,
}

Per-PartialGraphId monotonic committed-epoch cursor, backed by one watch channel per tracked partial graph.

Fields

inner: Mutex<HashMap<PartialGraphId, Sender<u64>>>

Implementations

impl PartialGraphCommittedEpochs

pub fn ensure(&self, partial_graph_id: PartialGraphId)

Start tracking partial_graph_id (initialized to 0) if not already tracked.

pub fn advance_all( &self, epochs: impl IntoIterator<Item = (PartialGraphId, u64)>, )

Advance each (partial_graph_id, epoch)’s committed epoch to max(current, epoch)

pub fn wait( &self, partial_graph_id: PartialGraphId, target: u64, ) -> impl Future<Output = ()> + 'static

Resolve once partial_graph_id’s committed epoch is >= target. If the partial graph is not tracked (never registered, or unregistered while this call raced), resolve immediately — the caller then observes the coordinator is gone and errors out, instead of blocking forever on an entry that nothing would advance.

Returns an owned ('static) future rather than an async fn borrowing &self, so callers can tokio::spawn the wait without holding a borrow of PartialGraphCommittedEpochs for the lifetime of the wait. The subscription is taken eagerly (before returning); the wait holds no lock.

pub fn remove(&self, partial_graph_id: PartialGraphId)

Stop tracking one partial graph (unregister of its last sink).

pub fn clear(&self)

Stop tracking every partial graph (global recovery reset).

Trait Implementations

impl Default for PartialGraphCommittedEpochs

fn default() -> PartialGraphCommittedEpochs

Returns the “default value” for a type.