Struct NetworkRemoteStore 

pub struct NetworkRemoteStore { /* private fields */ }

Bridges an async BlockTransport to the sync RemoteStore trait.

The pipeline code is synchronous. The daemon is async. This adapter holds a tokio runtime handle and calls block_on to bridge the gap.

Safety

Must NOT be called from within a tokio async context — that would deadlock. The CLI’s main thread (which runs the pipeline) is not inside tokio, so this is safe.

Implementations

impl NetworkRemoteStore

pub fn new(transport: Arc<dyn BlockTransport>, runtime: Handle) -> Self

Create a new adapter wrapping a BlockTransport.

Trait Implementations

impl RemoteStore for NetworkRemoteStore

fn fetch_raw(&self, cid_obj: &VoidCid) -> Result<Vec<u8>>

Fetch raw bytes by CID.

fn push_raw(&self, data: &[u8]) -> Result<VoidCid>

Push raw bytes, returning the content CID.

fn exists(&self, cid_obj: &VoidCid) -> Result<bool>

Check if a blob exists on the remote.

fn pin(&self, _cid: &VoidCid) -> Result<()>

Pin a blob to prevent remote garbage collection.