Struct Node

pub struct Node<T>
where
    T: Serialize + DeserializeOwned + 'static,
{
    pub id: u32,
    pub election_timeout_ms: u32,
    pub heartbeat_timeout_ms: u32,
    /* private fields */
}

Fields

id: u32

election_timeout_ms: u32

heartbeat_timeout_ms: u32

Implementations

impl<T> Node<T>

where T: Serialize + DeserializeOwned + 'static,

pub fn peer(&self) -> Peer

pub fn is(&self, peer: &Peer) -> bool

impl<T> Node<T>

where T: Serialize + DeserializeOwned + 'static,

pub fn builder() -> NodeBuilder<T>

pub fn stop(&self)

pub fn role(&self) -> Role

pub fn peers(&self) -> HashSet<Peer>

pub fn issue(&self, payload: T)

Issue a message to all nodes (only sends if this node is the leader)

Trait Implementations

impl<T> Drop for Node<T>

where T: Serialize + DeserializeOwned + 'static,

fn drop(&mut self)

Executes the destructor for this type.