Struct PersistenceProbe 

pub struct PersistenceProbe { /* private fields */ }

Implementations

impl PersistenceProbe

pub fn new(bus: TelemetryBus) -> Self

pub fn register_journal(&self, admin: Arc<dyn JournalAdmin>)

pub fn record_write( &self, journal: &str, persistence_id: &str, sequence_nr: u64, )

pub fn total_events(&self) -> u64

pub fn snapshot(&self) -> PersistenceSnapshot

pub async fn snapshot_async(&self) -> PersistenceSnapshot

Same as Self::snapshot but populates per-journal persistence ids + sequence numbers by calling into every registered JournalAdmin. Awaits each admin sequentially.