Struct networking::Peer

pub struct Peer { /* fields omitted */ }

A tower::Service representing an individual peer.

Relies on a backing NodeDataStore Service to obtain block and transaction information. If the NodeDataStore polls unready, this information will be propagated to the ConnectionManager struct, which may drop the the corresponding peer to relieve backpressure.

Implementations

impl Peer

pub async fn at_address(
    id: usize,
    address: SocketAddr,
    config: Arc<Config>
) -> Result<Peer, PeerError>

pub async fn from_connection(
    id: usize,
    connection: TcpStream,
    config: Arc<Config>
) -> Peer

pub async fn send<'_>(&'_ mut self, msg: Message) -> Result<(), PeerError>

pub fn get_ip_address(&self) -> SocketAddr

pub fn get_daemon_address(&self) -> SocketAddr

pub fn get_best_block(&self) -> u32

pub async fn receive<'_>(
    &'_ mut self,
    _timeout_duration: Option<Duration>
) -> Result<Message, PeerError>

pub async fn receive_expected<'_>(
    &'_ mut self,
    expected: Command,
    timeout_duration: Option<Duration>
) -> Result<Message, PeerError>

pub async fn perform_handshake<'_>(
    &'_ mut self,
    best_block: Option<u32>
) -> Result<(), PeerError>

pub async fn accept_handshake<'_>(
    &'_ mut self,
    best_block: Option<u32>
) -> Result<(), PeerError>

pub fn create_version_msg(&self, best_block: Option<u32>) -> Message

Trait Implementations

impl Debug for Peer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.