Struct PeriodicMeasure 

pub struct PeriodicMeasure { /* private fields */ }

Pure-ledger runtime adapter with coalesced asynchronous snapshot persistence.

Network callbacks update only in-memory state and replace the pending full snapshot. A runtime task serializes storage writes. The algorithm, time projection, pruning, and snapshot schema remain in rings-measure.

Implementations

impl PeriodicMeasure

pub async fn new(storage: MeasureStorage) -> Result<Self, MeasureRuntimeError>

Load the complete ledger once and start the coalescing persistence task.

On native targets this captures the active Tokio runtime handle. The constructor returns MeasureRuntimeError::RuntimeUnavailable instead of panicking when called outside a live runtime.

pub async fn flush(&self) -> Result<(), MeasureRuntimeError>

Persist a snapshot containing every update visible when this method starts.

On native targets, the Tokio runtime captured by Self::new must remain alive until the returned future completes.

pub async fn flush_with_timeout( &self, timeout: Duration, ) -> Result<(), MeasureRuntimeError>

Persist all applied updates unless the supplied deadline expires first.

On native targets, the Tokio runtime captured by Self::new must remain alive until the returned future completes or reaches timeout.

Trait Implementations

impl BehaviourJudgement for PeriodicMeasure

fn quality<'life0, 'async_trait>( &'life0 self, did: Did, ) -> Pin<Box<dyn Future<Output = PeerQuality> + Send + 'async_trait>>

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

Classify local peer quality for DHT connection scheduling.

impl Measure for PeriodicMeasure

fn incr<'life0, 'async_trait>( &'life0 self, did: Did, counter: MeasureCounter, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Increment a legacy counter whose peer attribution was already established.

fn get_count<'life0, 'async_trait>( &'life0 self, did: Did, counter: MeasureCounter, ) -> Pin<Box<dyn Future<Output = u64> + Send + 'async_trait>>

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

get_count returns the counter of the given peer.

fn record<'life0, 'async_trait>( &'life0 self, did: Did, authentication: Authentication, event: MeasurementEvent, ) -> Pin<Box<dyn Future<Output = Result<ApplyOutcome, MeasureError>> + Send + 'async_trait>>

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

Record one logical transport event with its explicit identity proof state.

fn record_batch<'life0, 'async_trait>( &'life0 self, did: Did, authentication: Authentication, batch: MeasurementBatch, ) -> Pin<Box<dyn Future<Output = Result<ApplyOutcome, MeasureError>> + Send + 'async_trait>>

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

Record a homogeneous batch as one atomic logical transition.

fn peer_measurement<'life0, 'async_trait>( &'life0 self, did: Did, ) -> Pin<Box<dyn Future<Output = Result<Option<PeerMeasurement>, MeasureError>> + Send + 'async_trait>>

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

Return the projected local measurement for one peer.

fn peer_measurements<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<PeerMeasurement>, MeasureError>> + Send + 'async_trait>>

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

Return every retained local peer measurement.

fn peer_measurements_page<'life0, 'async_trait>( &'life0 self, after: Option<Did>, limit: NonZeroUsize, ) -> Pin<Box<dyn Future<Output = Result<PeerMeasurementPage, MeasureError>> + Send + 'async_trait>>

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

Return one bounded page after an exclusive DID cursor.