Struct CompositeStore 

pub struct CompositeStore { /* private fields */ }

Read-only store that consults an ordered list of backends.

Errors

Reads (ObjectStore::read, read_into, read_info, open_stream) skip past a backend whose copy is damaged (Error::Zlib or Error::CorruptObject) and return a later backend’s good copy. When no backend returns the object, the first such corruption error is returned instead of Ok(None). Any other backend error is returned immediately.

Implementations

impl CompositeStore

pub fn new(stores: Vec<Arc<dyn ObjectStore>>, hash_algo: HashAlgo) -> Self

Build a composite from stores in lookup order (first match wins).

hash_algo is used when every child is empty; otherwise the first store’s algorithm applies.

pub fn stores(&self) -> &[Arc<dyn ObjectStore>]

Backends in lookup order (read-only).

Trait Implementations

impl Debug for CompositeStore

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

Formats the value using the given formatter.

impl ObjectStore for CompositeStore

fn hash_algo(&self) -> HashAlgo

Hash algorithm for objects written through this store.

fn read(&self, oid: &ObjectId) -> Result<Option<Object>>

Load the full object, if present.

fn read_into( &self, oid: &ObjectId, buf: &mut Vec<u8>, ) -> Result<Option<ObjectKind>>

Load object payload into buf, reusing its capacity when possible.

fn read_info(&self, oid: &ObjectId) -> Result<Option<ObjectInfo>>

Object kind and size without loading the full payload.

fn contains(&self, oid: &ObjectId) -> Result<bool>

Whether oid is stored in this backend (without reading the payload).

fn contains_many(&self, oids: &[ObjectId]) -> Result<Vec<bool>>

For each id in oids, whether it is stored in this backend; the result has one entry per input id, in input order.

fn open_stream(&self, oid: &ObjectId) -> Result<Option<ObjectStream<'_>>>

Open a stream over the object’s uncompressed payload.

fn for_each_object( &self, f: &mut dyn FnMut(&ObjectId) -> ControlFlow<()>, ) -> Result<()>

Invoke f for every object id in this store until f returns ControlFlow::Break.

fn lookup_prefix( &self, prefix: &str, limit: usize, out: &mut Vec<ObjectId>, ) -> Result<()>

Fill out with object ids whose hex form starts with prefix (case-insensitive).

fn refresh(&self) -> Result<bool>

Reload indexes or caches after on-disk changes (packs, alternates, MIDX).