Struct BlobsStore 

pub struct BlobsStore {
    pub inner: Arc<BlobsProtocol>,
}

Client over a local iroh-blob store. Exposes an iroh-blobs peer over the endpoint. Router must handle the iroh-blobs APLN Also acts as our main BlockStore implemenetation for bucket, node, and data storage and retrieval

Fields

inner: Arc<BlobsProtocol>

Implementations

impl BlobsStore

pub async fn legacy_fs(path: &Path) -> Result<Self, BlobsStoreError>

Legacy: load from filesystem using iroh’s FsStore directly.

pub async fn legacy_memory() -> Result<Self, BlobsStoreError>

Legacy: in-memory using iroh’s MemStore directly.

pub async fn fs(data_dir: &Path) -> Result<Self, BlobsStoreError>

Local filesystem via ObjectStore (SQLite + local object storage).

pub async fn memory() -> Result<Self, BlobsStoreError>

In-memory via ObjectStore.

pub async fn s3( db_path: &Path, endpoint: &str, access_key: &str, secret_key: &str, bucket: &str, region: Option<&str>, ) -> Result<Self, BlobsStoreError>

S3-backed via ObjectStore.

pub fn from_store(store: Store) -> Self

Wrap an existing iroh-blobs Store (kept for flexibility).

pub fn blobs(&self) -> &Blobs

Get a handle to the underlying blobs client against the store

pub async fn get(&self, hash: &Hash) -> Result<Bytes, BlobsStoreError>

Get a blob as bytes

pub async fn get_cbor<T: BlockEncoded<DagCborCodec>>( &self, hash: &Hash, ) -> Result<T, BlobsStoreError>

Get a blob as a block encoded

pub async fn get_reader(&self, hash: Hash) -> Result<Reader, BlobsStoreError>

Get a blob from the store as a reader

pub async fn put_stream( &self, stream: impl Stream<Item = Result<Bytes>> + Send + Unpin + 'static + Sync, ) -> Result<Hash, BlobsStoreError>

Store a stream of bytes as a blob

pub async fn put(&self, data: Vec<u8>) -> Result<Hash, BlobsStoreError>

Store a vec of bytes as a blob

pub async fn stat(&self, hash: &Hash) -> Result<bool, BlobsStoreError>

Get the stat of a blob

pub async fn download_hash( &self, hash: Hash, peer_ids: Vec<PublicKey>, endpoint: &Endpoint, ) -> Result<(), BlobsStoreError>

Download a single hash from peers

This checks if the hash exists locally first, then downloads if needed. Uses the Downloader API with Shuffled content discovery.

pub async fn download_hash_list( &self, hash_list_hash: Hash, peer_ids: Vec<PublicKey>, endpoint: &Endpoint, ) -> Result<(), BlobsStoreError>

Download a hash list (pinset) and all referenced hashes

This first downloads the hash list blob, reads the list of hashes, then downloads each referenced hash.

pub async fn create_hash_list<I>( &self, hashes: I, ) -> Result<Hash, BlobsStoreError>

where I: IntoIterator<Item = Hash>,

Create a simple blob containing a sequence of hashes Each hash is 32 bytes, stored consecutively Returns the hash of the blob containing all the hashes

pub async fn read_hash_list( &self, list_hash: Hash, ) -> Result<Vec<Hash>, BlobsStoreError>

Read all hashes from a hash list blob Returns a Vec of all hashes in the list

Trait Implementations

impl Clone for BlobsStore

fn clone(&self) -> BlobsStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for BlobsStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Deref for BlobsStore

type Target = Arc<BlobsProtocol>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.