Struct WalWriter 

pub struct WalWriter { /* private fields */ }

Write-ahead log writer.

Thread-safe WAL writer with durable append operations.

Durability

When sync_on_write is enabled, each write is followed by an fsync to ensure the data is persisted to disk before returning.

Example

use rag_plusplus_core::wal::{WalWriter, WalConfig};

let config = WalConfig::new("./wal");
let mut writer = WalWriter::new(config)?;

writer.log_insert(&record)?;
writer.log_update_stats(&id, 0.9)?;

Implementations

impl WalWriter

pub fn new(config: WalConfig) -> Result<Self>

Create a new WAL writer.

Creates the WAL directory if it doesn’t exist.

Errors

Returns error if directory creation or file opening fails.

pub fn log_insert(&self, record: &MemoryRecord) -> Result<u64>

Log an insert operation.

Errors

Returns error if write fails.

pub fn log_update_stats( &self, record_id: &RecordId, outcome: f64, ) -> Result<u64>

Log a stats update operation.

pub fn log_delete(&self, record_id: &RecordId) -> Result<u64>

Log a delete operation.

pub fn log_checkpoint(&self) -> Result<u64>

Log a checkpoint marker.

pub fn sequence(&self) -> u64

Get current sequence number.

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

Flush pending writes.

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

Close the WAL writer.

pub fn directory(&self) -> &Path

Get WAL directory.

pub fn list_files(&self) -> Result<Vec<PathBuf>>

Get list of WAL files.

pub fn truncate_before(&self, checkpoint_seq: u64) -> Result<()>

Truncate WAL files up to (but not including) a checkpoint.

This removes entries that have been successfully checkpointed.

Trait Implementations

impl Debug for WalWriter

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

Formats the value using the given formatter.