Struct ProcessingStats 

pub struct ProcessingStats {
    pub articles_processed: u64,
    pub bytes_downloaded: u64,
    pub bytes_decompressed: u64,
    pub errors: u64,
    pub duplicates: u64,
    pub started_at: Option<DateTime<Utc>>,
    pub completed_at: Option<DateTime<Utc>>,
}

Processing statistics.

Tracks metrics during snapshot/realtime processing including articles processed, bytes transferred, errors, and duplicates.

Example

use wme_stream::ProcessingStats;
use chrono::Utc;

let mut stats = ProcessingStats::new();
stats.articles_processed = 1000;
stats.bytes_downloaded = 1024 * 1024 * 100; // 100 MB

let rate = stats.rate();
println!("Processing rate: {} articles/sec", rate);

Fields

articles_processed: u64

Total articles processed

bytes_downloaded: u64

Total bytes downloaded

bytes_decompressed: u64

Total bytes decompressed

errors: u64

Errors encountered

duplicates: u64

Duplicates removed

started_at: Option<DateTime<Utc>>

Start time

completed_at: Option<DateTime<Utc>>

End time

Implementations

impl ProcessingStats

pub fn new() -> Self

Create new empty stats with current timestamp.

Sets started_at to the current time.

pub fn merge(&mut self, other: &ProcessingStats)

Merge another stats into this one.

Combines counts from another stats instance. Useful when aggregating stats from multiple chunks or workers.

pub fn rate(&self) -> f64

Calculate processing rate (articles per second).

Returns 0.0 if started_at is not set. Uses completed_at if set, otherwise uses current time.

pub fn complete(&mut self)

Mark processing as completed.

Sets completed_at to the current time.

Trait Implementations

impl Clone for ProcessingStats

fn clone(&self) -> ProcessingStats

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProcessingStats

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ProcessingStats

fn default() -> ProcessingStats

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ProcessingStats

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ProcessingStats

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.