fedimint_core/net/
peers.rs

1use std::sync::Arc;
2
3use async_trait::async_trait;
4use fedimint_core::PeerId;
5
6#[cfg(not(target_family = "wasm"))]
7pub mod fake;
8
9pub type DynP2PConnections<M> = Arc<dyn IP2PConnections<M>>;
10
11/// Connection manager that tries to keep connections open to all peers
12#[async_trait]
13pub trait IP2PConnections<M>: Send + Sync + 'static {
14    /// Send message to recipient; drop message if channel is full.
15    fn send(&self, recipient: Recipient, msg: M);
16
17    /// Await the next message; return None if we are shutting down.
18    async fn receive(&self) -> Option<(PeerId, M)>;
19
20    /// Await the next message from peer; return None if we are shutting down.
21    async fn receive_from_peer(&self, peer: PeerId) -> Option<M>;
22
23    /// Convert the struct to trait object.
24    fn into_dyn(self) -> DynP2PConnections<M>
25    where
26        Self: Sized,
27    {
28        Arc::new(self)
29    }
30}
31
32/// This enum defines the intended recipient of a p2p message.
33#[derive(Clone, Copy, Debug, PartialEq, Eq)]
34pub enum Recipient {
35    Everyone,
36    Peer(PeerId),
37}
fedimint_core/net/peers.rs

fedimint_core/net/
peers.rs
