Struct ObjectStoreBlobStore 

pub struct ObjectStoreBlobStore {
    instance_name: String,
    object_store: Arc<dyn ObjectStore>,
    base_path: Path,
}

Stores BlobMeta in any backend supported by the object_store crate.

Each BlobMeta is stored as a proto::BlobMeta at {base_path}/blob/b3/{HEXLOWER(digest[0..2])}/{HEXLOWER(digest)}.

If old BlobMeta are present, it might also access {base_path}/chunk/b3/{HEXLOWER(digest[0..2])}/{HEXLOWER(digest)}.

Fields

instance_name: String

object_store: Arc<dyn ObjectStore>

base_path: Path

Implementations

impl ObjectStoreBlobStore

async fn gen_single_chunk_blob_meta( &self, digest: &B3Digest, ) -> Result<BlobMeta, Error>

Create BlobMeta for a single chunk.

In an earlier format, when BlobMeta described a single chunk, the version serialized to disk was an empty file. As we cannot immediately return a BlobMeta from that, as we don’t know its size.

This fetches the chunk, assuming an ObjectStoreChunkStore at the same backend and base path, and returns a BlobMeta.

If the chunk cannot be fetched from the chunk store, it returns None.

Trait Implementations

impl BlobStore for ObjectStoreBlobStore

fn get<'life0, 'life1, 'async_trait>( &'life0 self, digest: &'life1 B3Digest, ) -> Pin<Box<dyn Future<Output = Result<Option<BlobMeta>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Retrieves a BlobMeta for a given blob digest.

fn has<'life0, 'life1, 'async_trait>( &'life0 self, digest: &'life1 B3Digest, ) -> Pin<Box<dyn Future<Output = Result<bool, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Checks if a BlobMeta for a given blob exists.

fn put<'life0, 'life1, 'async_trait>( &'life0 self, digest: &'life1 B3Digest, blob_meta: BlobMeta, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Persists a BlobMeta for the given blob digest.