Struct Atomic 

pub struct Atomic<R: ResourceExt> { /* private fields */ }

Decorator for crash-safe whole-file writes.

For file-backed resources: write-rename pattern ensures that the target file is either the old version or the new version — never a partial write.

For in-memory resources: direct delegation (crash-safety is not applicable).

Implementations

impl<R: ResourceExt> Atomic<R>

pub fn new(inner: R) -> Self

Wrap a resource for crash-safe writes.

impl<R: ResourceExt> Atomic<R>

pub fn write_all_durable(&self, data: &[u8]) -> StorageResult<()>

Write the whole payload atomically AND durably: like ResourceExt::write_all but also sync_datas the temp file before the atomic rename. Returns only after the bytes are physically on disk.

Use this on explicit checkpoint paths where the caller wants post-return durability. Per-mutation flushes should keep using the cheaper ResourceExt::write_all (best-effort, atomic rename only).

For memory-backed inners (no filesystem path) durability is meaningless; the call falls back to the same passthrough as write_all.

Errors

Propagates filesystem errors from temp creation, write, sync_data, rename, or the inner’s post-rename commit.

Trait Implementations

impl<R: Clone + ResourceExt> Clone for Atomic<R>

fn clone(&self) -> Atomic<R>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<R: Debug + ResourceExt> Debug for Atomic<R>

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

Formats the value using the given formatter.

impl<R: ResourceExt> ResourceExt for Atomic<R>

fn write_all(&self, data: &[u8]) -> StorageResult<()>

Write entire contents and commit atomically.

fn commit(&self, final_len: Option<u64>) -> StorageResult<()>

Mark the resource as fully written.

fn fail(&self, reason: String)

Mark the resource as failed.

fn len(&self) -> Option<u64>

Get the committed length, if known.

fn path(&self) -> Option<&Path>

Get the file path, if backed by a file.

fn reactivate(&self) -> StorageResult<()>

Reactivate a committed resource for continued writing.

fn read_at(&self, offset: u64, buf: &mut [u8]) -> StorageResult<usize>

Read data at the given offset into buf.

fn status(&self) -> ResourceStatus

Get resource status.

fn wait_range(&self, range: Range<u64>) -> StorageResult<WaitOutcome>

Wait until the given byte range is available.

fn write_at(&self, offset: u64, data: &[u8]) -> StorageResult<()>

Write data at the given offset.

fn contains_range(&self, _range: Range<u64>) -> bool

Check if the given byte range is fully covered by available data (non-blocking).

fn is_empty(&self) -> bool

Returns true if the resource has been committed with zero length.

fn next_gap(&self, _from: u64, _limit: u64) -> Option<Range<u64>>

Find the first gap in available data starting from from, up to limit.

fn read_into(&self, buf: &mut Vec<u8>) -> StorageResult<usize>

Read the entire resource contents into a caller-provided buffer.