Struct GcsStore 

pub struct GcsStore { /* private fields */ }

A content-addressable store backed by a Google Cloud Storage bucket.

Construct one with GcsStore::connect (resolves Application Default Credentials via the SDK).

Implementations

impl GcsStore

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

Connects to the gs://bucket/prefix store, resolving credentials via the SDK’s Application Default Credentials chain.

The ring rustls crypto provider is installed as the process default (idempotent) before the clients are built, keeping aws-lc-rs out of the graph (see the module docs).

Errors

StoreError::Backend if the tokio runtime cannot be created or the SDK clients cannot be built (e.g. credentials cannot be resolved).

pub fn connect_with( store_url: &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 SDK clients cannot be built (e.g. credentials cannot be resolved).

pub fn from_clients( storage: Storage, control: StorageControl, location: GcsLocation, ) -> Result<Self, StoreError>

Builds a store from already-configured SDK clients and a parsed location, owning a fresh tokio runtime for the sync bridge. Intended for tests.

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) -> &GcsLocation

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 GcsStore

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 GcsStore

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.