Struct Glob 

pub struct Glob<E: Storage + Metrics, V: Codec> { /* private fields */ }

Simple section-based blob storage for values.

Uses buffer::Write for batching writes. Reads go directly to blobs without any caching (ideal for large values that shouldn’t pollute a buffer pool cache).

Implementations

impl<E: Storage + Metrics, V: CodecShared> Glob<E, V>

pub async fn init(context: E, cfg: Config<V::Cfg>) -> Result<Self, Error>

Initialize blob storage, opening existing section blobs.

pub async fn append( &mut self, section: u64, value: &V, ) -> Result<(u64, u32), Error>

Append value to section, returns (offset, size).

The returned offset is the byte offset where the entry was written. The returned size is the total bytes written (compressed_data + crc32). Both should be stored in the index entry for later retrieval.

pub async fn get( &self, section: u64, offset: u64, size: u32, ) -> Result<V, Error>

Read value at offset with known size (from index entry).

The offset should be the byte offset returned by append(). Reads directly from blob without any caching.

pub async fn sync(&self, section: u64) -> Result<(), Error>

Sync section to disk (flushes write buffer).

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

Sync all sections to disk.

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

Get the current size of a section (including buffered data).

pub async fn rewind(&mut self, section: u64, size: u64) -> Result<(), Error>

Rewind to a specific section and size.

Truncates the section to the given size and removes all sections after it.

pub async fn rewind_section( &mut self, section: u64, size: u64, ) -> Result<(), Error>

Rewind only the given section to a specific size.

Unlike rewind, this does not affect other sections.

pub async fn prune(&mut self, min: u64) -> Result<bool, Error>

Prune sections before min.

pub fn oldest_section(&self) -> Option<u64>

Returns the number of the oldest section.

pub fn newest_section(&self) -> Option<u64>

Returns the number of the newest section.

pub fn sections(&self) -> impl Iterator<Item = u64> + '_

Returns an iterator over all section numbers.

pub async fn remove_section(&mut self, section: u64) -> Result<bool, Error>

Remove a specific section. Returns true if the section existed and was removed.

pub async fn close(&mut self) -> Result<(), Error>

Close all blobs (syncs first).

pub async fn destroy(self) -> Result<(), Error>

Destroy all blobs.