Enum SnapshotEvent 

pub enum SnapshotEvent {
    ManifestLoaded {
        snapshot_id: String,
        chunks: usize,
    },
    ChunkStarted {
        chunk_id: String,
        size_bytes: u64,
    },
    ChunkProgress {
        chunk_id: String,
        bytes_downloaded: u64,
        bytes_total: u64,
    },
    ChunkCompleted {
        chunk_id: String,
        articles_count: u64,
        elapsed: Duration,
    },
    ArticleProcessed {
        article_id: u64,
        title: String,
    },
    CheckpointSaved {
        path: PathBuf,
    },
    Error {
        error: StreamError,
        recoverable: bool,
    },
    Completed {
        total_articles: u64,
        total_bytes: u64,
    },
}

Progress event for snapshot processing.

These events allow you to monitor the progress of snapshot downloads and processing. Use them to update progress bars or log activity.

Example

use wme_stream::SnapshotEvent;

fn handle_event(event: SnapshotEvent) {
    match event {
        SnapshotEvent::ChunkStarted { chunk_id, size_bytes } => {
            println!("Starting download of {} ({} bytes)", chunk_id, size_bytes);
        }
        SnapshotEvent::ChunkProgress { chunk_id, bytes_downloaded, bytes_total } => {
            let pct = (bytes_downloaded as f64 / bytes_total as f64) * 100.0;
            println!("{}: {:.1}%", chunk_id, pct);
        }
        SnapshotEvent::ArticleProcessed { article_id, title } => {
            println!("Processed: {}", title);
        }
        _ => {}
    }
}

Variants

ManifestLoaded

Manifest loaded successfully.

Fields

snapshot_id: String

Snapshot identifier

chunks: usize

Number of chunks

ChunkStarted

Chunk download started.

Fields

chunk_id: String

Chunk identifier

size_bytes: u64

Size in bytes

ChunkProgress

Chunk download progress.

Fields

chunk_id: String

Chunk identifier

bytes_downloaded: u64

Bytes downloaded so far

bytes_total: u64

Total bytes

ChunkCompleted

Chunk processing completed.

Fields

chunk_id: String

Chunk identifier

articles_count: u64

Number of articles processed

elapsed: Duration

Elapsed time

ArticleProcessed

Individual article processed.

Fields

article_id: u64

Article ID

title: String

Article title

CheckpointSaved

Checkpoint saved.

Fields

path: PathBuf

Path to checkpoint file

Error

Error occurred.

Fields

error: StreamError

Error details

recoverable: bool

Whether the error is recoverable

Completed

Processing completed.

Fields

total_articles: u64

Total articles processed

total_bytes: u64

Total bytes processed

Trait Implementations

impl Clone for SnapshotEvent

fn clone(&self) -> SnapshotEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SnapshotEvent

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

Formats the value using the given formatter.