Struct ObjectStoreChunkStore 

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

Stores Chunks in any backend supported by the object_store crate.

Each Chunk is stored as a zstd-compressed object at {base_path}/chunks/b3/{HEXLOWER(digest[0..2])}/{HEXLOWER(digest)}.

Fields

instance_name: String

object_store: Arc<dyn ObjectStore>

base_path: Path

Implementations

impl ObjectStoreChunkStore

pub fn from_parts( instance_name: String, object_store: Arc<dyn ObjectStore>, base_path: Path, ) -> Self

Constructs a new ObjectStoreChunkStore from already existing instance_name, object_store and base_name.

Trait Implementations

impl ChunkStore for ObjectStoreChunkStore

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,

Check if a Chunk with this B3Digest exists.

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

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

Retrieves a Chunk by its B3Digest, if it exists.

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

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

Upload a Chunk, returns its B3Digest.