Struct Node 

pub struct Node {
    pub id: u32,
    pub pool: Arc<PacketBufferPool>,
    pub schedule: Arc<Schedule>,
    /* private fields */
}

Fields

id: u32

pool: Arc<PacketBufferPool>

schedule: Arc<Schedule>

Implementations

impl Node

pub fn new(id: u32, address: &str, verbose: bool) -> Self

pub fn recv_once(&mut self, callback: fn(PacketView<'_>))

Receive a single packet and call the callback with the packet

pub fn recv(&mut self, callback: fn(PacketView<'_>))

Receive packets and call the callback with each packet

pub fn send(&mut self, packet: PacketBuffer<'static>, addr: SocketAddr)

Send a packet without waiting for reply

pub fn send_await( &mut self, packet: PacketBuffer<'static>, addr: SocketAddr, callback: fn(PacketView<'_>), )

Send a packet and wait for reply