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.

When an encryption key is set, writes: [nonce: 12B][len: 4B][ciphertext]. Otherwise writes the v2 format: [tag+payload][crc32: 4B].

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.

Uses write-to-temp-then-rename for crash safety: the old AOF remains intact until the new file (with only a header) is fully synced and atomically renamed into place.