Struct Node

pub struct Node {
    pub connections: Arc<Mutex<NodeMap>>,
    pub node_addr: SocketAddr,
    pub duration: u32,
    pub network: Arc<Mutex<Network>>,
    pub event_queue: EventQueue<NetEvent>,
    pub peer: Option<String>,
}

Structure of a node

Fields

connections: Arc<Mutex<NodeMap>>

List of peers of the current node

node_addr: SocketAddr

Public address of the node

duration: u32

Sets the duration (in seconds) of emitting messages to other peers

network: Arc<Mutex<Network>>

Network of nodes

event_queue: EventQueue<NetEvent>

Network events queue

peer: Option<String>

Sets the optional peer address to connect to

Implementations

impl Node

pub fn new(port: u32, duration: u32, peer: Option<String>) -> Result<Self>

Creates a new Node

pub fn execute(self) -> Result<()>

Executes the peer-to-peer process.