Struct ReplayCheckpoint 

pub struct ReplayCheckpoint {
    pub events_processed: u64,
    pub total_events: u64,
    pub seed: u64,
    pub metadata_hash: u64,
    pub created_at: u64,
}

A checkpoint for resuming long replays.

Checkpoints capture the current position in the trace, allowing replay to be suspended and resumed later without re-processing all events.

Safety

Checkpoints are only valid for the specific trace file they were created from. Attempting to resume with a checkpoint from a different trace will result in an error.

Fields

events_processed: u64

Number of events that have been processed.

total_events: u64

Total number of events in the trace this checkpoint came from.

seed: u64

The seed from the trace metadata (for validation).

metadata_hash: u64

Hash of the trace metadata (for validation).

created_at: u64

Deterministic checkpoint timestamp derived from trace metadata and position.

Implementations

impl ReplayCheckpoint

pub fn to_bytes(&self) -> StreamingReplayResult<Vec<u8>>

Serializes the checkpoint to bytes.

Errors

Returns an error if serialization fails.

pub fn from_bytes(bytes: &[u8]) -> StreamingReplayResult<Self>

Deserializes a checkpoint from bytes.

Security

This method validates input size and performs basic bounds checking before deserialization to prevent DoS attacks from malformed data.

Errors

Returns an error if deserialization fails or if the data fails validation.

Trait Implementations

impl Clone for ReplayCheckpoint

fn clone(&self) -> ReplayCheckpoint

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for ReplayCheckpoint

impl Debug for ReplayCheckpoint

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ReplayCheckpoint

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ReplayCheckpoint

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

where __S: Serializer,

Serialize this value into the given Serde serializer.