Struct R2Storage 

pub struct R2Storage { /* private fields */ }

R2 storage client

Implementations

impl R2Storage

pub fn new(config: R2Config) -> Result<Self>

Create new R2 storage client

pub async fn upload_blob(&self, blob: &Blob) -> Result<String>

Upload blob to R2

pub async fn download_blob(&self, hash: &str) -> Result<Blob>

Download blob from R2

pub async fn blob_exists(&self, hash: &str) -> Result<bool>

Check if blob exists in R2

pub async fn delete_blob(&self, hash: &str) -> Result<()>

Delete blob from R2

pub async fn download_component( &self, tool: &str, component: &str, version: Option<&str>, ) -> Result<String>

Download component from R2

pub async fn upload_component( &self, tool: &str, component: &str, version: &str, content: &str, ) -> Result<String>

Upload component to R2

pub async fn component_exists( &self, tool: &str, component: &str, version: Option<&str>, ) -> Result<bool>

Check if component exists in R2

pub async fn list_components(&self, tool: &str) -> Result<Vec<String>>

List all components in R2

pub async fn sync_components( &self, tool: &str, local_components: &[String], on_download: impl Fn(&str), on_upload: impl Fn(&str), ) -> Result<()>

Sync components (bidirectional)

pub async fn sync_up( &self, local_blobs: Vec<Blob>, progress_callback: Option<impl Fn(usize, usize) + Send + Sync>, ) -> Result<SyncResult>

Sync local blobs up to R2 (upload missing blobs)

pub async fn sync_down( &self, remote_hashes: Vec<String>, progress_callback: Option<impl Fn(usize, usize) + Send + Sync>, ) -> Result<Vec<Blob>>

Sync remote blobs down from R2 (download missing blobs)

pub async fn list_blobs(&self, _prefix: Option<&str>) -> Result<Vec<String>>

List all blob hashes in R2 bucket (simplified - in production use pagination)