Struct CollectHandler

pub struct CollectHandler {
    pub peer_messages: HashMap<ServerId, Vec<PeerMessage>>,
    pub client_messages: HashMap<ClientId, Vec<ClientResponse>>,
    pub timeouts: Vec<ConsensusTimeout>,
    pub clear_timeouts: Vec<ConsensusTimeout>,
    pub state: ConsensusState,
}

A handler that collects all messages leaving processing of them untouched. Note that timeouts vectors may intersect, that means both - clearing and setting a new timeout was requested.

Fields

peer_messages: HashMap<ServerId, Vec<PeerMessage>>

client_messages: HashMap<ClientId, Vec<ClientResponse>>

timeouts: Vec<ConsensusTimeout>

clear_timeouts: Vec<ConsensusTimeout>

state: ConsensusState

Implementations

impl CollectHandler

pub fn new() -> Self

pub fn clear(&mut self)

Delete all events

Trait Implementations

impl ConsensusHandler for CollectHandler

fn send_peer_message(&mut self, id: ServerId, message: PeerMessage)

Saves peer message to a vector

fn send_client_response(&mut self, id: ClientId, message: ClientResponse)

Saves client message to a vector

fn set_timeout(&mut self, timeout: ConsensusTimeout)

Collects timeouts uniquely

fn clear_timeout(&mut self, timeout: ConsensusTimeout)

fn state_changed(&mut self, _old: ConsensusState, new: ConsensusState)

Called when consensus goes to new state. Initializing new consensus does not call this function.

fn done(&mut self)

Called when the particular event has been fully processed. Useful for doing actions in batches.

impl Debug for CollectHandler

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for CollectHandler

fn default() -> Self

Returns the “default value” for a type.