Struct CompressedReplayLog 

pub struct CompressedReplayLog {
    pub frequency_sketch: CountMinSketch,
    pub entry_sample: ReservoirSampler<String>,
    pub error_sample: ReservoirSampler<String>,
    pub schema_version: String,
}

Compressed replay log combining count-min sketch and reservoir sampling.

Tracks both frequency estimates (via CMS) and representative samples (via reservoir) for efficient log analysis.

Fields

frequency_sketch: CountMinSketch

Frequency sketch for operation counts.

entry_sample: ReservoirSampler<String>

Sample of recent log entries.

error_sample: ReservoirSampler<String>

Sample of error messages.

schema_version: String

Schema version for serialization compatibility.

Implementations

impl CompressedReplayLog

pub fn new() -> Self

Create a new compressed replay log with default parameters.

pub fn with_params( sketch_width: usize, sketch_depth: usize, entry_sample_size: usize, error_sample_size: usize, ) -> Self

Create with custom parameters.

• sketch_width: Width of frequency sketch
• sketch_depth: Depth of frequency sketch
• entry_sample_size: Number of log entries to retain
• error_sample_size: Number of error messages to retain

pub fn record_operation(&mut self, operation: &str)

Record an operation.

pub fn record_entry(&mut self, entry: String)

Record a log entry.

pub fn record_error(&mut self, error: String)

Record an error.

pub fn estimate_frequency(&self, operation: &str) -> u64

Estimate the frequency of an operation.

pub fn sampled_entries(&self) -> &[String]

Get sampled log entries.

pub fn sampled_errors(&self) -> &[String]

Get sampled errors.

pub fn total_operations(&self) -> u64

Get total operation count.

pub fn merge(&mut self, other: &Self) -> Result<(), &'static str>

Merge another log into this one.

Trait Implementations

impl Clone for CompressedReplayLog

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CompressedReplayLog

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

Formats the value using the given formatter.

impl Default for CompressedReplayLog

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for CompressedReplayLog

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for CompressedReplayLog

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

where __S: Serializer,

Serialize this value into the given Serde serializer.