Struct MemoryBlobStore 

pub struct MemoryBlobStore { /* private fields */ }

An in-memory BlobStore for one keyspace. Clones share the blobs.

Implementations

impl MemoryBlobStore

pub fn new(keyspace: impl Into<String>) -> Self

An empty store for keyspace (packs for pack uploads).

pub fn keyspace(&self) -> &str

The keyspace this store serves.

pub fn with_single_put_limit(self, limit: u64) -> Self

Cap what one begin upload may carry, as a bounded backend does, so larger objects take the multipart path. For tests.

pub fn with_fault(self, fault: MemoryFault) -> Self

Arm a one-shot MemoryFault (BlobWrite or BlobCommit).

Trait Implementations

impl BlobStore for MemoryBlobStore

type Sink = MemoryPackSink

The upload handle Self::begin returns.

async fn begin( &self, key: BlobKey, len: u64, ) -> Result<MemoryPackSink, StoreError>

Start writing blob key of len bytes.

async fn get( &self, key: &BlobKey, range: Option<ByteRange>, ) -> Result<Option<BlobBody>, StoreError>

The blob’s bytes, or range of them. A body longer than MAX_BLOB_PIECE_BYTES MUST be a BlobBody::Stream whose pieces are each at most MAX_BLOB_PIECE_BYTES (an adapter re-chunks its backend’s stream); a backend never buffers a whole pack. A range starting at or past the end is StoreError::RangeNotSatisfiable.

async fn head(&self, key: &BlobKey) -> Result<Option<BlobMeta>, StoreError>

The blob’s metadata, if present.

async fn probe(&self) -> Result<(), StoreError>

A cheap health check.

async fn delete(&self, key: &BlobKey) -> Result<bool, StoreError>

Remove a blob; returns whether it existed. Never called by the M0 pipeline: reserved for GC and takedown (WP-5.3b, WP-5.6).

impl Clone for MemoryBlobStore

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 MemoryBlobStore

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

Formats the value using the given formatter.

impl Default for MemoryBlobStore

The packs keyspace.

fn default() -> Self

Returns the “default value” for a type.

impl MultipartBlobStore for MemoryBlobStore

const MAX_PARTS: u32 = u32::MAX

Maximum part count accepted by this backend.

type PartSink = MemoryPartSink

The upload handle returned by Self::begin_part.

fn supports_multipart(&self) -> bool

Whether this backend can start a multipart upload now.

async fn begin_multipart( &self, key: BlobKey, len: u64, part_size: u64, ) -> Result<Vec<u8>, StoreError>

Open a new storage session for a pack.

async fn begin_part( &self, key: BlobKey, session: &[u8], plan: &PartPlan, index: u32, expected_cv: [u8; 32], ) -> Result<MemoryPartSink, StoreError>

Start one part in an existing storage session.

async fn complete( &self, key: BlobKey, session: &[u8], plan: &PartPlan, parts: &[PartRef], ) -> Result<CommitOutcome, StoreError>

Atomically make the verified pack visible.

async fn complete_with_root( &self, key: BlobKey, session: &[u8], plan: &PartPlan, parts: &[PartRef], content_root: Hash, ) -> Result<CommitOutcome, StoreError>

Atomically make a verified object visible: the parts’ merged BLAKE3 root must equal content_root (the object key is an object id, not a content hash). Plain Self::complete refuses object keys, as PackSink::commit does. WP-4.10.

fn single_put_limit(&self) -> Option<u64>

The most bytes one BlobStore::begin upload can carry, or None when unbounded. Objects longer than this are extracted in parts.

async fn abort(&self, key: BlobKey, session: &[u8]) -> Result<(), StoreError>

Reclaim an incomplete session. Repeated aborts succeed.

fn begin_multipart_for_ticket( &self, key: BlobKey, len: u64, part_size: u64, _ticket_id: [u8; 32], ) -> impl Future<Output = Result<Vec<u8>, StoreError>> + MaybeSend

Open a session for a known ticket. Backends that do not use the ticket id as their storage session keep their existing session format.