Struct AsyncWalManager 

pub struct AsyncWalManager { /* private fields */ }

Async Write-Ahead Log manager with non-blocking I/O.

This manager provides the same durability guarantees as the sync version but uses tokio’s async I/O for better throughput in async contexts.

Implementations

impl AsyncWalManager

pub async fn open(dir: impl AsRef<Path>) -> Result<Self>

Opens or creates an async WAL in the given directory.

Errors

Returns an error if the directory cannot be created or accessed.

pub async fn with_config( dir: impl AsRef<Path>, config: WalConfig, ) -> Result<Self>

Opens or creates an async WAL with custom configuration.

Errors

Returns an error if the directory cannot be created or accessed.

pub async fn log(&self, record: &WalRecord) -> Result<()>

Logs a record to the WAL asynchronously.

Errors

Returns an error if the record cannot be written.

pub async fn checkpoint(&self, current_tx: TxId, epoch: EpochId) -> Result<()>

Writes a checkpoint marker and returns the checkpoint info.

Errors

Returns an error if the checkpoint cannot be written.

pub async fn rotate(&self) -> Result<()>

Rotates to a new log file.

Errors

Returns an error if rotation fails.

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

Flushes the WAL buffer to disk.

Errors

Returns an error if the flush fails.

pub async fn sync(&self) -> Result<()>

Syncs the WAL to disk (fsync).

Errors

Returns an error if the sync fails.

pub async fn start_background_sync(&self) -> bool

Starts a background sync task for batch durability mode.

The task will periodically sync the WAL based on the batch configuration. This is useful when you want automatic syncing without waiting for individual log calls to trigger it.

Returns

Returns true if a new background task was started, false if batch mode is not configured or a task is already running.

pub async fn stop_background_sync(&self)

Stops the background sync task if running.

pub fn record_count(&self) -> u64

Returns the total number of records written.

pub fn dir(&self) -> &Path

Returns the WAL directory path.

pub fn durability_mode(&self) -> DurabilityMode

Returns the current durability mode.

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

Returns all WAL log file paths in sequence order.

pub async fn checkpoint_epoch(&self) -> Option<EpochId>

Returns the latest checkpoint epoch, if any.

Trait Implementations

impl Drop for AsyncWalManager

fn drop(&mut self)

Executes the destructor for this type.