Struct Peer 

pub struct Peer {
    pub address: SocketAddr,
    pub is_client: bool,
    /* private fields */
}

A struct representing one peer (peer connection. Can be both a client peer or a connected peer)

Fields

address: SocketAddr

is_client: bool

Implementations

impl Peer

pub fn new(address: SocketAddr, is_client: bool) -> Self

Create a new peer

pub async fn connect( peer: Arc<RwLock<Peer>>, node: Arc<RwLock<Node>>, stream: TcpStream, ) -> JoinHandle<Result<(), PeerError>>

Main connection handler

pub async fn request( peer: Arc<RwLock<Peer>>, message: Message, ) -> Result<Message, PeerError>

Send a request and wait for the response

pub async fn send(peer: Arc<RwLock<Peer>>, message: Message)

Send a message to this peer, without expecting a response

pub async fn send_to_peers(node: Arc<RwLock<Node>>, message: Message)

Send this message to all peers but this one