Struct Append 

pub struct Append<B: Blob> { /* private fields */ }

A Blob wrapper that supports appending new data that is both read and write cached, and provides buffer-pool managed read caching of older data.

Implementations

impl<B: Blob> Append<B>

pub async fn new( blob: B, size: u64, buffer_size: NonZeroUsize, pool_ref: PoolRef, ) -> Result<Self, Error>

Create a new Append of provided size using the provided pool for read caching, and a write buffer with capacity buffer_size.

pub async fn append( &self, buf: impl Into<StableBuf> + Send, ) -> Result<(), Error>

Append all bytes in buf to the tip of the blob.

pub async fn size(&self) -> u64

Returns the current logical size of the blob including any buffered data.

This represents the total size of data that would be present after flushing.

pub fn clone_blob(&self) -> B

Clones and returns the underlying blob.

Trait Implementations

impl<B: Blob> Blob for Append<B>

async fn write_at( &self, _buf: impl Into<StableBuf> + Send, _offset: u64, ) -> Result<(), Error>

This Blob trait method is unimplemented by Append and unconditionally panics.

async fn resize(&self, size: u64) -> Result<(), Error>

Resize the blob to the provided size.

async fn read_at( &self, buf: impl Into<StableBuf> + Send, offset: u64, ) -> Result<StableBuf, Error>

Read from the blob at the given offset.

async fn sync(&self) -> Result<(), Error>

Ensure all pending data is durably persisted.

impl<B: Clone + Blob> Clone for Append<B>

fn clone(&self) -> Append<B>

Returns a duplicate of the value.

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

Performs copy-assignment from source.