Struct R2ObjectStore 

pub struct R2ObjectStore { /* private fields */ }

R2-backed ObjectStore.

Construct with R2ObjectStore::new when keys are already in hand, or R2ObjectStore::from_vault to pull them from the yah keystore (with env-var fallback).

Implementations

impl R2ObjectStore

pub fn new( account_id: impl Into<String>, bucket: impl Into<String>, access_key: impl Into<String>, secret_key: impl Into<String>, ) -> Result<Self, Error>

Construct with explicit keys.

account_id is the Cloudflare account id (the subdomain in <account_id>.r2.cloudflarestorage.com).

pub fn with_endpoint(self, endpoint: impl Into<String>) -> Self

Point this store at an S3-compatible endpoint other than R2 — in practice, the pond tier’s local MinIO (http://127.0.0.1:9000).

Everything else about the store is already endpoint-agnostic: the bucket lives in the URL path (path-style addressing, which MinIO also speaks) and SigV4 is signed against whatever host the URL names.

This exists because without it the pond rehearsal could not exercise the read side of a publish at all. publish_to_pond uploads a directory tree and offers no way to read an object back, so the one part of a release that is a read-modify-write — the accumulating index.json that https://yah.dev/releases renders from — was the one part a green local rehearsal proved nothing about (R330-T32). A conditional-write loop that has never run is a conditional-write loop you do not have.

The region stays "auto"; MinIO accepts it.

pub fn from_vault( account_id: impl Into<String>, bucket: impl Into<String>, ) -> Result<Self, Error>

Construct from the yah keystore (vault), falling back to env vars.

Reads cloudflare-r2-access-key-id / cloudflare-r2-secret-key slots (env fallback CF_R2_ACCESS_KEY_ID / CF_R2_SECRET_KEY). Returns Error::Auth if either is missing.

impl R2ObjectStore

pub fn list_prefix_detailed( &self, prefix: &str, ) -> Result<Vec<ObjectMeta>, Error>

List objects under prefix returning key + size + last-modified.

Same paginated request as ObjectStore::list_prefix but parses the <Size> and <LastModified> siblings of each <Key> element. Used by the data-tab bucket viewer to render a directory-style listing.

Trait Implementations

impl Drop for R2ObjectStore

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl ObjectStore for R2ObjectStore

fn locate(&self, key: &str) -> String

Where key lives, in a form an operator can act on — a URL for a remote backend, an opaque descriptor otherwise (R746-F1).

fn put(&self, key: &str, data: Vec<u8>) -> Result<(), Error>

Write data at key. Overwrites any existing object unconditionally.

fn put_cached( &self, key: &str, data: Vec<u8>, cache_control: &str, ) -> Result<(), Error>

Write data at key with an explicit Cache-Control (R703-B8).

fn get(&self, key: &str) -> Result<Option<Vec<u8>>, Error>

Read bytes at key. Returns None when the key does not exist — NotFound is reserved for ambiguous cases (HEAD-then-GET race etc.).

fn head(&self, key: &str) -> Result<bool, Error>

Returns true when key exists. Cheaper than get for backends that support HEAD; the default impl falls back to get(...).is_some().

fn delete(&self, key: &str) -> Result<(), Error>

Remove key. Idempotent — succeeds whether or not the key existed.

fn list_prefix(&self, prefix: &str) -> Result<Vec<String>, Error>

List all keys with the given prefix (prefix-match, not glob).

fn put_if( &self, key: &str, data: Vec<u8>, cond: Precondition, ) -> Result<String, Error>

Conditionally write data at key, returning the resulting ETag.

fn etag(&self, key: &str) -> Result<Option<String>, Error>

Current ETag of key, or None if absent.