Struct MmapWriter

pub struct MmapWriter { /* private fields */ }

Memory-mapped file writer for metrics

Implementations

impl MmapWriter

pub fn new( path: impl AsRef<Path>, file_size: usize, enable_compression: bool, ) -> Result<Self>

Create a new memory-mapped file writer

pub fn write_snapshot(&self, snapshot: &MetricsSnapshot) -> Result<usize>

Write a metrics snapshot to the memory-mapped file

pub fn write_metrics( &self, metrics: &[Metric], timestamp_ns: u64, ) -> Result<usize>

Write raw metrics (will aggregate them first)

pub fn write_position(&self) -> usize

Get the current write position

pub fn reset(&self) -> Result<()>

Reset the writer (clear the file)

pub fn read_snapshots(&self) -> Result<Vec<MetricsSnapshot>>

Read snapshots from the memory-mapped file