Struct AtomicBatch 

pub struct AtomicBatch { /* private fields */ }

Manages a two-phase atomic commit of multiple file writes.

Implementations

impl AtomicBatch

pub fn new( targets: &[PathBuf], backup_enabled: bool, interrupted: Arc<AtomicBool>, ) -> Result<Self>

Create a new atomic batch. Acquires the lock file immediately. targets is used to determine the journal directory. backup_enabled controls whether hard-link backups are created. interrupted is an AtomicBool set by signal handlers.

pub fn stage( &mut self, target_path: &Path, content: &[u8], _encoding: &str, ) -> Result<()>

Stage a single file write: write content to a temp file in the same directory as the target, fsync it, then release the fd.

pub fn warn_if_large_batch(&self)

Emit a warning if the batch size exceeds the threshold.

pub fn commit(self) -> Result<()>

Execute the two-phase commit: create backups, write journal, rename all. Returns Ok(()) if all renames succeed. On failure, attempts rollback if backups are enabled.

Trait Implementations

impl Drop for AtomicBatch

fn drop(&mut self)

Executes the destructor for this type.