Struct buffett_core::crdt::Crdt

pub struct Crdt {
    pub table: HashMap<Pubkey, NodeInfo>,
    pub remote: HashMap<Pubkey, u64>,
    pub alive: HashMap<Pubkey, u64>,
    pub update_index: u64,
    pub id: Pubkey,
    pub scheduled_leaders: HashMap<u64, Pubkey>,
    pub leader_rotation_interval: u64,
    // some fields omitted
}

Fields

table: HashMap<Pubkey, NodeInfo>

remote: HashMap<Pubkey, u64>

alive: HashMap<Pubkey, u64>

update_index: u64

id: Pubkey

scheduled_leaders: HashMap<u64, Pubkey>

leader_rotation_interval: u64

Methods

impl Crdt

pub fn new(node_info: NodeInfo) -> Result<Crdt>

pub fn my_data(&self) -> &NodeInfo

pub fn leader_data(&self) -> Option<&NodeInfo>

pub fn node_info_trace(&self) -> String

pub fn set_leader(&mut self, key: Pubkey)

pub fn get_scheduled_leader(&self, entry_height: u64) -> Option<Pubkey>

pub fn set_leader_rotation_interval(&mut self, leader_rotation_interval: u64)

pub fn get_leader_rotation_interval(&self) -> u64

pub fn set_scheduled_leader(&mut self, entry_height: u64, new_leader_id: Pubkey)

pub fn get_valid_peers(&self) -> Vec<NodeInfo>

pub fn get_external_liveness_entry(
    &self,
    key: &Pubkey
) -> Option<&HashMap<Pubkey, u64>>

pub fn insert_vote(&mut self, pubkey: &Pubkey, v: &Vote, last_id: Hash)

pub fn insert_votes(&mut self, votes: &[(Pubkey, Vote, Hash)])

pub fn insert(&mut self, v: &NodeInfo) -> usize

pub fn purge(&mut self, now: u64)

pub fn compute_broadcast_table(&self) -> Vec<NodeInfo>

pub fn broadcast(
    crdt: &Arc<RwLock<Crdt>>,
    leader_rotation_interval: u64,
    me: &NodeInfo,
    broadcast_table: &[NodeInfo],
    window: &SharedWindow,
    s: &UdpSocket,
    transmit_index: &mut WindowIndex,
    received_index: u64
) -> Result<()>

pub fn retransmit(
    obj: &Arc<RwLock<Self>>,
    blob: &SharedBlob,
    s: &UdpSocket
) -> Result<()>

pub fn convergence(&self) -> u64

pub fn valid_last_ids(&self) -> Vec<Hash>

pub fn window_index_request(&self, ix: u64) -> Result<(SocketAddr, Vec<u8>)>

pub fn new_vote(&mut self, last_id: Hash) -> Result<(Vote, SocketAddr)>

pub fn gossip(
    obj: Arc<RwLock<Self>>,
    blob_sender: BlobSender,
    exit: Arc<AtomicBool>
) -> JoinHandle<()>

pub fn listen(
    me: Arc<RwLock<Self>>,
    window: SharedWindow,
    ledger_path: Option<&str>,
    requests_receiver: BlobReceiver,
    response_sender: BlobSender,
    exit: Arc<AtomicBool>
) -> JoinHandle<()>

pub fn is_valid_address(addr: &SocketAddr) -> bool

pub fn spy_node() -> (NodeInfo, UdpSocket)