asteroid_mq/protocol/node/raft/
raft_node.rs

1use serde::{Deserialize, Serialize};
2
3use crate::DEFAULT_TCP_SOCKET_ADDR;
4
5#[derive(Clone, Serialize, Deserialize, PartialEq, Eq)]
6pub struct TcpNode {
7    pub addr: String,
8}
9
10impl std::fmt::Debug for TcpNode {
11    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
12        f.debug_tuple("TcpNode").field(&self.addr).finish()
13    }
14}
15
16impl TcpNode {
17    pub fn new(addr: String) -> Self {
18        Self { addr }
19    }
20}
21
22impl Default for TcpNode {
23    fn default() -> Self {
24        Self::new(DEFAULT_TCP_SOCKET_ADDR.to_string())
25    }
26}

asteroid_mq/protocol/node/raft/raft_node.rs

asteroid_mq/protocol/node/raft/
raft_node.rs