Struct BlobsProtocol

pub struct BlobsProtocol { /* private fields */ }

A protocol handler for the blobs protocol.

Implementations

impl BlobsProtocol

pub fn new( store: &Store, endpoint: Endpoint, events: Option<Sender<Event>>, ) -> Self

pub fn store(&self) -> &Store

pub fn endpoint(&self) -> &Endpoint

pub async fn ticket( &self, content: impl Into<HashAndFormat>, ) -> Result<BlobTicket>

Create a ticket for content on this node.

Note that this does not check whether the content is partially or fully available. It is just a convenience method to create a ticket from content and the address of this node.

Trait Implementations

impl Clone for BlobsProtocol

fn clone(&self) -> BlobsProtocol

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for BlobsProtocol

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

Formats the value using the given formatter.

impl ProtocolHandler for BlobsProtocol

fn accept( &self, conn: Connection, ) -> impl Future<Output = Result<(), AcceptError>> + Send

Handle an incoming connection.

fn shutdown(&self) -> impl Future<Output = ()> + Send

Called when the router shuts down.

fn on_connecting( &self, connecting: Connecting, ) -> impl Future<Output = Result<Connection, AcceptError>> + Send

Optional interception point to handle the Connecting state.