Struct LooseStore 

pub struct LooseStore { /* private fields */ }

On-disk loose object store for one objects/ directory.

Implementations

impl LooseStore

pub fn new( objects_dir: PathBuf, hash_algo: HashAlgo, compression: Compression, ) -> Self

Open a loose store at objects_dir using hash_algo and zlib compression.

pub fn objects_dir(&self) -> &Path

Path to the objects/ root.

pub fn object_path(&self, oid: &ObjectId) -> PathBuf

Filesystem path for a loose object file.

pub fn ensure_all_loose_prefix_dirs(&self) -> Result<()>

Create all 256 loose-object prefix directories (objects/xx/).

Errors

Returns Error::Io if a directory cannot be created.

pub fn zlib_compress_store_bytes(&self, store_bytes: &[u8]) -> Result<Vec<u8>>

Zlib-compress canonical store bytes at this store’s compression level.

Errors

Returns Error::Zlib when compression fails.

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

Write canonical store bytes for a precomputed oid (hashing skipped).

Errors

Same as WritableObjectStore::write.

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

Write zlib-compressed store bytes for a precomputed oid.

Errors

Same as WritableObjectStore::write.

pub fn read_verify_oid(path: &Path, expected_oid: &ObjectId) -> Result<Object>

Read a loose object at path, verifying the payload hashes to expected_oid.

Errors

• Error::Zlib — decompression failed.
• Error::CorruptObject — header is malformed.
• Error::LooseHashMismatch — payload OID does not match expected_oid.

Trait Implementations

impl Clone for LooseStore

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LooseStore

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

Formats the value using the given formatter.

impl ObjectStore for LooseStore

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 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 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 refresh(&self) -> Result<bool>

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

impl WritableObjectStore for LooseStore

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

Store canonical object bytes and return the object id.

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.

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

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