Struct Ping 

pub struct Ping { /* private fields */ }

Ping is our protocol struct.

We’ll implement ProtocolHandler on this struct so we can use it with an iroh::protocol::Router. It’s also fine to keep state in this struct for use across many incoming connections, in this case we’ll keep metrics about the amount of pings we sent or received.

Implementations

impl Ping

pub fn new() -> Self

Creates new ping state.

pub fn metrics(&self) -> &Arc<Metrics>

Returns a handle to ping metrics.

pub async fn ping( &self, endpoint: &Endpoint, addr: EndpointAddr, ) -> Result<Duration>

Sends a ping on the provided endpoint to a given node address.

Trait Implementations

impl Clone for Ping

fn clone(&self) -> Ping

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Ping

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

Formats the value using the given formatter.

impl Default for Ping

fn default() -> Self

Returns the “default value” for a type.

impl ProtocolHandler for Ping

async fn accept(&self, connection: Connection) -> Result<(), AcceptError>

The accept method is called for each incoming connection for our ALPN.

The returned future runs on a newly spawned tokio task, so it can run as long as the connection lasts.

fn on_accepting( &self, accepting: Accepting, ) -> impl Future<Output = Result<Connection, AcceptError>> + Send

Optional interception point to handle the Accepting state.

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

Called when the router shuts down.