pub struct HealthCheckerNetworkSender { /* private fields */ }
Expand description
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§
source§impl HealthCheckerNetworkSender
impl HealthCheckerNetworkSender
sourcepub async fn send_rpc(
&mut self,
recipient: PeerId,
req_msg: HealthCheckerMsg,
timeout: Duration
) -> Result<HealthCheckerMsg, RpcError>
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§
source§impl Clone for HealthCheckerNetworkSender
impl Clone for HealthCheckerNetworkSender
source§fn clone(&self) -> HealthCheckerNetworkSender
fn clone(&self) -> HealthCheckerNetworkSender
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read more