Struct network::protocols::health_checker::HealthCheckerNetworkSender

pub struct HealthCheckerNetworkSender { /* private fields */ }

The interface from HealthChecker to Networking layer.

This is a thin wrapper around a NetworkSender<HealthCheckerMsg>, so it is easy to clone and send off to a separate task. For example, the rpc requests return Futures that encapsulate the whole flow, from sending the request to remote, to finally receiving the response and deserializing. It therefore makes the most sense to make the rpc call on a separate async task, which requires the HealthCheckerNetworkSender to be Clone and Send.

Implementations

impl HealthCheckerNetworkSender

pub async fn send_rpc( &mut self, recipient: PeerId, req_msg: HealthCheckerMsg, timeout: Duration ) -> Result<HealthCheckerMsg, RpcError>

Send a HealthChecker Ping RPC request to remote peer recipient. Returns the remote peer’s future Pong reply.

The rpc request can be canceled at any point by dropping the returned future.

pub async fn disconnect_peer( &mut self, peer_id: PeerId ) -> Result<(), NetworkError>

Trait Implementations

impl Clone for HealthCheckerNetworkSender

fn clone(&self) -> HealthCheckerNetworkSender

Returns a copy of the value.

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

Performs copy-assignment from source.

impl NewNetworkSender for HealthCheckerNetworkSender

fn new( peer_mgr_reqs_tx: PeerManagerRequestSender, connection_reqs_tx: ConnectionRequestSender ) -> Self