Struct SegmentSource 

pub struct SegmentSource<S> { /* private fields */ }

Read-through segment source over a blob/root store.

Implementations

impl<S: BlobStore + RootStore> SegmentSource<S>

pub fn new(store: Arc<S>) -> Self

Wraps a store with an empty cache.

pub async fn index_root(&self, db: &str) -> Result<Option<DbRoot>, StoreError>

Reads the current published index root for db.

Errors

Returns an error when the root store cannot be read.

pub async fn lease_holder_endpoint( &self, db: &str, ) -> Result<Option<String>, StoreError>

Rediscovers the current lease holder’s advertised client endpoint from the root record — peers with storage credentials can rebuild their endpoint preference after an HA takeover without any static configuration.

Errors

Returns an error when the root store cannot be read.

pub async fn segment( &self, root: &DbRoot, order: IndexOrder, ) -> Result<Option<Arc<[u8]>>, StoreError>

Loads the full key stream for one index order of a published root, through the cache: a format-3 manifest’s chunks concatenated in order, or a pre-format-3 flat segment as stored.

Errors

Returns an error when a blob cannot be loaded or is missing.

pub fn segment_keys(bytes: &[u8]) -> Result<Vec<Vec<u8>>, StoreError>

Decodes a segment’s length-prefixed key entries.

Errors

Returns StoreError::CorruptBlob-free decode failures as None entries never occur; malformed framing yields an error.