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 disconnect_peer(
    &mut self,
    peer_id: PeerId
) -> Result<(), NetworkError>

Trait Implementations

impl ApplicationNetworkSender<HealthCheckerMsg> for HealthCheckerNetworkSender

fn send_rpc<'life0, 'async_trait>(
    &'life0 self,
    recipient: PeerId,
    req_msg: HealthCheckerMsg,
    timeout: Duration
) -> Pin<Box<dyn Future<Output = Result<HealthCheckerMsg, RpcError>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

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.

fn send_to(
    &self,
    _recipient: PeerId,
    _message: TMessage
) -> Result<(), NetworkError>

fn send_to_many(
    &self,
    _recipients: impl Iterator<Item = PeerId>,
    _message: TMessage
) -> Result<(), NetworkError>

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