Module streaming 

Streaming replay for large traces.

This module provides streaming support for processing traces that are too large to fit in memory. The key types are:

• StreamingReplayer: Replays traces directly from file with O(1) memory
• ReplayCheckpoint: Saves replay state for resumption
• ReplayProgress: Progress tracking during replay

Memory Guarantees

• StreamingReplayer: O(1) memory - only buffers current event
• Reading: Uses TraceReader with streaming reads
• Writing: Uses TraceWriter with streaming writes

Example

use asupersync::trace::streaming::{StreamingReplayer, ReplayProgress};
use std::path::Path;

// Open a large trace file for streaming replay
let mut replayer = StreamingReplayer::open("large_trace.bin")?;

// Process events one at a time
while let Some(event) = replayer.next_event()? {
    println!("Event: {:?}", event);

    // Check progress
    if replayer.progress().percent() > 50.0 {
        println!("Halfway done!");
    }
}

// For very long replays, checkpoint and resume later
let checkpoint = replayer.checkpoint()?;
std::fs::write("checkpoint.bin", checkpoint.to_bytes()?)?;

// Later: resume from checkpoint
let checkpoint = ReplayCheckpoint::from_bytes(&std::fs::read("checkpoint.bin")?)?;
let mut resumed = StreamingReplayer::resume("large_trace.bin", checkpoint)?;

Structs

ReplayCheckpoint

A checkpoint for resuming long replays.

ReplayProgress

Progress information during streaming replay.

StreamingReplayer

A streaming replayer that processes traces with O(1) memory.

Enums

StreamingReplayError

Errors specific to streaming replay operations.

Type Aliases

StreamingReplayResult

Result type for streaming replay operations.