Trait MessageHandler 

pub trait MessageHandler {
    // Required method
    fn handle(
        &self,
        message: DistributedMessage,
    ) -> NetworkResult<Option<DistributedMessage>>;
}

Trait for handling incoming messages

Required Methods

fn handle( &self, message: DistributedMessage, ) -> NetworkResult<Option<DistributedMessage>>

Implementors

impl MessageHandler for RaftHeartbeatHandler

impl MessageHandler for RaftVoteHandler

impl MessageHandler for ReplicationHandler

impl MessageHandler for QuorumHandler

impl MessageHandler for HeartbeatHandler

impl MessageHandler for VoteHandler