Struct RecordLogWriter 

pub struct RecordLogWriter { /* private fields */ }

Append-only record log writer.

Implementations

impl RecordLogWriter

pub fn new(dir: impl Into<Arc<dyn Directory>>, path: impl Into<String>) -> Self

Create a record log writer that appends to path.

pub fn new_conservative( dir: impl Into<Arc<dyn Directory>>, path: impl Into<String>, ) -> Self

Conservative default: no buffering + flush after each append.

pub fn with_flush_policy( dir: impl Into<Arc<dyn Directory>>, path: impl Into<String>, flush_policy: FlushPolicy, ) -> Self

Create a record log writer with an explicit flush policy.

pub fn with_options( dir: impl Into<Arc<dyn Directory>>, path: impl Into<String>, flush_policy: FlushPolicy, write_buffer_limit_bytes: usize, ) -> Self

Create a record log writer with explicit flush policy and write buffer size.

write_buffer_limit_bytes == 0 disables buffering (writes are issued on each append).

pub fn flush(&mut self) -> PersistenceResult<()>

Flush the underlying writer (if one is open).

pub fn flush_and_sync(&mut self) -> PersistenceResult<()>

Flush buffered bytes and attempt to make the record log durable on stable storage.

This is an opt-in stronger guarantee than flush():

• flush() is a visibility boundary (userspace → OS / underlying writer).
• flush_and_sync() additionally calls sync_all on the underlying file.

Returns NotSupported if the underlying Directory does not provide file_path().

pub fn append_bytes(&mut self, payload: &[u8]) -> PersistenceResult<()>

Append one record containing payload.

pub fn append_postcard<T: Serialize>( &mut self, value: &T, ) -> PersistenceResult<()>

Append one postcard-encoded value as a record payload.