Struct SharedConsensus

pub struct SharedConsensus<L, M, H> { /* private fields */ }

Convenience wrapper for multithreaded handling of consensus packages Based on standard Arc<Mutex<_>> approach

Implementations

impl<L, M, H> SharedConsensus<L, M, H>

where L: Log, M: StateMachine, H: ConsensusHandler,

pub fn new(consensus: HandledConsensus<L, M, H>) -> Self

pub fn init(&self)

Calls initial actions which should be executed upon startup.

pub fn apply_peer_message( &self, from: ServerId, message: PeerMessage, ) -> Result<(), Error>

Applies a peer message to the consensus state machine.

pub fn apply_client_message( &self, from: ClientId, message: ClientRequest, ) -> Result<(), Error>

Applies a client message to the consensus state machine.

pub fn apply_timeout(&self, timeout: ConsensusTimeout) -> Result<(), Error>

Triggers a timeout for the peer.

pub fn heartbeat_timeout( &self, peer: ServerId, ) -> Result<AppendEntriesRequest, Error>

Triggers a heartbeat timeout for the peer.

pub fn election_timeout(&self) -> Result<(), Error>

Trait Implementations

impl<L: Clone, M: Clone, H: Clone> Clone for SharedConsensus<L, M, H>

fn clone(&self) -> SharedConsensus<L, M, H>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<L: Debug, M: Debug, H: Debug> Debug for SharedConsensus<L, M, H>

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

Formats the value using the given formatter.