Struct S3Store 

pub struct S3Store { /* private fields */ }

A content-addressable store backed by an S3 (or S3-compatible) bucket.

Construct one with S3Store::connect (resolves the standard AWS credential chain) or S3Store::from_client (an already-built SDK client, e.g. for tests against an emulator).

Implementations

impl S3Store

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

Connects to the s3://bucket/prefix store, resolving credentials and region via the standard AWS chain (aws_config::load_defaults).

The HTTP client is pinned to the ring rustls provider (see the module docs). An optional endpoint_url selects an S3-compatible backend (path-style addressing is enabled when an endpoint is given, as emulators rarely support virtual-host addressing).

Errors

StoreError::Backend if the tokio runtime cannot be created or the AWS configuration cannot be loaded.

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

Like connect, but carries a TransferConfig for concurrency / bandwidth control. The existing connect delegates here with TransferConfig::default.

Errors

StoreError::Backend if the tokio runtime cannot be created or the AWS configuration cannot be loaded.

pub fn from_client( client: Client, location: S3Location, ) -> Result<Self, StoreError>

Builds a store from an already-configured SDK Client and a parsed location, owning a fresh tokio runtime for the sync bridge. Intended for tests (e.g. wiring a client at an emulator endpoint).

Errors

StoreError::Backend if the tokio runtime cannot be created.

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

Attaches (or clears) an optional progress Meter, rides alongside config. The transfer paths record bytes-in / bytes-out + per-object progress into it; None (the constructor default) means zero recording and byte-identical behavior. The CLI sets this after construction.

pub fn location(&self) -> &S3Location

The parsed bucket/prefix this store targets.

pub fn transfer_config(&self) -> &TransferConfig

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

Trait Implementations

impl Store for S3Store

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 S3Store

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.