Struct iroh_blobs::net_protocol::Blobs

pub struct Blobs<S> { /* private fields */ }

Available on crate feature downloader only.

Implementations

impl<S: Store> Blobs<S>

pub fn new_with_events( store: S, rt: LocalPoolHandle, events: EventSender, downloader: Downloader, endpoint: Endpoint ) -> Self

pub fn store(&self) -> &S

pub async fn batches(&self) -> MutexGuard<'_, BlobBatches>

pub async fn download( &self, endpoint: Endpoint, req: BlobDownloadRequest, progress: AsyncChannelProgressSender<DownloadProgress> ) -> Result<()>

impl<D: Store> Blobs<D>

pub async fn handle_rpc_request<C>( self: Arc<Self>, msg: Request, chan: RpcChannel<RpcService, C> ) -> Result<(), RpcServerError<C>>

where C: ChannelTypes<RpcService>,

Available on crate feature rpc only.

Handle an RPC request

pub async fn handle_tags_request<C>( self: Arc<Self>, msg: Request, chan: RpcChannel<RpcService, C> ) -> Result<(), RpcServerError<C>>

where C: ChannelTypes<RpcService>,

Available on crate feature rpc only.

Handle a tags request

pub async fn handle_blobs_request<C>( self: Arc<Self>, msg: Request, chan: RpcChannel<RpcService, C> ) -> Result<(), RpcServerError<C>>

where C: ChannelTypes<RpcService>,

Available on crate feature rpc only.

Handle a blobs request

Trait Implementations

impl<S: Debug> Debug for Blobs<S>

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

Formats the value using the given formatter.

impl<S: Store> ProtocolHandler for Blobs<S>

fn accept(self: Arc<Self>, conn: Connecting) -> BoxedFuture<Result<()>>

Handle an incoming connection.

fn shutdown(self: Arc<Self>) -> BoxedFuture<()>

Called when the node shuts down.