Struct B2Store 

pub struct B2Store { /* private fields */ }

A content-addressable store backed by Backblaze B2 via its S3-compatible endpoint. Thin wrapper over S3Store configured with the B2 endpoint.

Implementations

impl B2Store

pub fn connect( store_url: &str, endpoint_url: Option<&str>, region: Option<&str>, ) -> Result<Self, StoreError>

Connects to a b2://bucket/prefix store using Backblaze’s S3-compatible API.

endpoint_url overrides the endpoint outright (handy for emulators or an already-known regional host). When None, the endpoint is taken from SNAPDIR_B2_TEST_ENDPOINT, and failing that derived from region (or the SNAPDIR_B2_REGION / AWS_REGION env vars, else [DEFAULT_B2_REGION]) as https://s3.<region>.backblazeb2.com.

Credentials and signing are handled by the standard AWS chain; the B2 application key id/secret map to the AWS access-key/secret-key.

Errors

StoreError::Backend if the tokio runtime cannot be created or the AWS configuration cannot be loaded (propagated from S3Store::connect).

pub fn connect_with( store_url: &str, endpoint_url: Option<&str>, region: Option<&str>, config: TransferConfig, ) -> Result<Self, StoreError>

Like connect, but carries a TransferConfig for concurrency / bandwidth control. The config lives on the wrapped S3Store; connect delegates here with TransferConfig::default.

Errors

StoreError::Backend if the tokio runtime cannot be created or the AWS configuration cannot be loaded (propagated from S3Store::connect_with).

pub fn from_s3_store(inner: S3Store) -> Self

Builds a B2Store from an already-configured S3Store (intended for tests wiring a client at an emulator/B2 endpoint).

pub fn with_meter(self, meter: Option<Arc<Meter>>) -> Self

Attaches (or clears) an optional progress Meter. B2 has no transfer path of its own — it delegates entirely to the wrapped S3Store — so this forwards to S3Store::with_meter. None (the constructor default) means zero recording and byte-identical behavior.

pub fn location(&self) -> &S3Location

The parsed bucket/prefix this store targets (shared with S3Store).

pub fn transfer_config(&self) -> &TransferConfig

The TransferConfig (concurrency / bandwidth) this store was built with, carried on the wrapped S3Store. Consumed by the transfer loops in later gates.

Trait Implementations

impl Store for B2Store

fn get_manifest(&self, id: &str) -> Result<Manifest, StoreError>

Reads and parses the manifest stored under id’s sharded path, verifying that its bytes hash back to id before returning it.

fn fetch_files( &self, manifest: &Manifest, dest: &Path, ) -> Result<(), StoreError>

Materializes every entry of manifest under dest, pulling each referenced object from the store and reconstructing the directory tree (files, directories, permissions) rooted at dest.

fn push(&self, manifest: &Manifest, source: &Path) -> Result<(), StoreError>

Uploads the objects referenced by manifest (reading their bytes from the tree rooted at source) and then the manifest itself, filing each under its sharded address.

impl StreamStore for B2Store

fn has_object(&self, checksum: &str) -> Result<bool, StoreError>

Returns true if an object with this content-address already exists in the store.

fn get_object(&self, checksum: &str) -> Result<Vec<u8>, StoreError>

Reads the raw object blob filed under checksum, verifying its bytes hash (BLAKE3) back to checksum before returning them.

fn put_object(&self, checksum: &str, bytes: Vec<u8>) -> Result<(), StoreError>

Writes a raw object blob at its content-address, verifying bytes hash (BLAKE3) to checksum before storing anything.

fn put_manifest(&self, id: &str, manifest: &Manifest) -> Result<(), StoreError>

Writes the manifest object for id, verifying the manifest’s bytes hash back to id before storing it.

fn objects_needed( &self, checksums: &[String], ) -> Result<Vec<String>, StoreError>

Returns the subset of checksums NOT present in the store, PRESERVING INPUT ORDER.