Struct FilesSource 

pub struct FilesSource { /* private fields */ }

Read/write object storage backed by one objects/ directory tree.

Implementations

impl FilesSource

pub fn open( pack_store: Arc<PackStore>, loose: LooseStore, use_midx: bool, midx_tip_listing_for_exists: bool, diagnostics: DiagnosticsHandle, ) -> Result<Self>

Open a files source for pack_store’s directory.

use_midx enables multi-pack-index reads when a chain is present. midx_tip_listing_for_exists matches Git’s MIDX membership probe for ObjectStore::contains.

Errors

Propagates MidxObjects::new failures other than a missing index.

pub fn objects_dir(&self) -> &Path

objects/ root for this source.

pub fn loose_store(&self) -> &LooseStore

Loose-object backend (writes target this store).

pub fn packed_objects(&self) -> &PackedObjects

Shared pack read backend.

pub fn midx_objects(&self) -> &MidxObjects

MIDX layer for this directory.

pub fn exists_local_materialized(&self, oid: &ObjectId) -> bool

Whether oid is materialized under this objects/ tree (local loose or non-promisor pack).

pub fn try_finish_duplicate_write( &self, oid: &ObjectId, options: WriteOptions, ) -> Result<Option<ObjectId>>

Resolve duplicate-write short-circuit for this directory before creating a loose file.

Returns Some(oid) when the object is already present locally and was freshened when appropriate. When options.trust_new_loose is set, only an existing loose file stops the write (callers may still consult alternates).

pub fn write_zlib_prehashed( &self, oid: &ObjectId, zlib_store: &[u8], options: WriteOptions, ) -> Result<ObjectId>

Write zlib-compressed store bytes for a precomputed oid into this source’s loose store.

Errors

Same as WritableObjectStore::write.

pub fn local_loose_exists_but_unreadable( &self, oid: &ObjectId, err: &Error, ) -> bool

Whether a loose object file exists but could not be parsed (caller may consult alternates).

Trait Implementations

impl Debug for FilesSource

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

Formats the value using the given formatter.

impl ObjectStore for FilesSource

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 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).

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.

impl WritableObjectStore for FilesSource

fn write( &self, kind: ObjectKind, data: &[u8], options: WriteOptions, ) -> Result<ObjectId>

Store canonical object bytes and return the object id.

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

Mark oid as recently used so retention policies keep it (Git freshen).

fn write_stream( &self, kind: ObjectKind, size: u64, reader: &mut dyn Read, options: WriteOptions, ) -> Result<ObjectId>

Store an object from a byte stream of known uncompressed size.