Struct StatisticsHandle 

pub struct StatisticsHandle { /* private fields */ }

A cheaply cloned handle for recording and reading crawl statistics.

Implementations

impl StatisticsHandle

pub fn new() -> Self

Creates an empty statistics handle with a 60-second rate window.

pub fn record_finished( &self, duration: Duration, status_code: Option<u16>, retry_count: u32, )

Records a successful terminal request.

duration is the cumulative per-request processing time across all attempts.

pub fn record_failed( &self, duration: Duration, error_key: &str, retry_count: u32, )

Records a terminally failed request.

duration is the cumulative per-request processing time across all attempts.

pub fn record_retry(&self, error_key: &str)

Records an error that caused a request retry.

pub fn mark_run_started(&self)

Starts runtime measurement if it is not already running.

pub fn mark_run_stopped(&self)

Stops runtime measurement if it is running and accumulates the elapsed time.

pub fn snapshot(&self) -> StatisticsSnapshot

Returns a point-in-time copy of the current statistics.

pub fn subscribe(&self) -> Receiver<StatisticsSnapshot>

Subscribes to live snapshots emitted after statistics are recorded.

Updates are best effort: a slow receiver may skip intermediate snapshots, while a later record operation will still deliver the newest state once capacity is available. When called from within a Tokio runtime, snapshots are also emitted periodically. Outside a runtime, the receiver remains usable for snapshots triggered by record operations.

pub fn finalize(&self) -> FinalStatistics

Returns the current statistics in their final run-result form.

pub async fn persist(&self, kvs: &dyn KeyValueStore) -> StorageResult<()>

Persists lossless accumulator state to a key-value store.

pub async fn restore(&self, kvs: &dyn KeyValueStore) -> StorageResult<bool>

Restores persisted accumulator state, returning whether the key existed.

Sliding-window events are intentionally not restored, and runtime resumes stopped.

Trait Implementations

impl Clone for StatisticsHandle

fn clone(&self) -> StatisticsHandle

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for StatisticsHandle

fn default() -> Self

Returns the “default value” for a type.