Method flush

graphlite/src/txn/wal.rs:639–651

ROADMAP v0.3.0 - Manual WAL flush for durability checkpoints and testing

(&self)

    /// Ensure all pending writes are flushed (for testing)
    #[allow(dead_code)] // ROADMAP v0.3.0 - Manual WAL flush for durability checkpoints and testing
    pub fn flush(&self) -> Result<(), WALError> {
        let mut writer_guard = self.current_writer.lock().unwrap();
        if let Some(writer) = writer_guard.as_mut() {
            writer
                .flush()
                .map_err(|e| WALError::IOError(format!("Failed to flush WAL: {}", e)))?;
            writer
                .get_mut()
                .sync_all()
                .map_err(|e| WALError::IOError(format!("Failed to sync WAL: {}", e)))?;
        }
        Ok(())
    }

    /// Read all entries from a specific WAL file
    pub fn read_wal_file(&self, file_number: u64) -> Result<Vec<WALEntry>, WALError> {