Struct AofWriter 

pub struct AofWriter { /* private fields */ }

Buffered writer for appending AOF records to a file.

Implementations

impl AofWriter

pub fn open(path: impl Into<PathBuf>) -> Result<Self, FormatError>

Opens (or creates) an AOF file. If the file is new, writes the header. If the file already exists, appends to it.

pub fn write_record(&mut self, record: &AofRecord) -> Result<(), FormatError>

Appends a record to the AOF. Writes tag+payload+crc32.

pub fn flush(&mut self) -> Result<(), FormatError>

Flushes the internal buffer to the OS.

pub fn sync(&mut self) -> Result<(), FormatError>

Flushes and fsyncs the file to disk.

pub fn path(&self) -> &Path

Returns the file path.

pub fn truncate(&mut self) -> Result<(), FormatError>

Truncates the AOF file back to just the header. Used after a successful snapshot to reset the log.