Trait paxos::Reactor

pub trait Reactor: Debug + Clone {
    type Peer: ToSocketAddrs;
    type Message: Serialize + DeserializeOwned;
    fn receive(
        &mut self, 
        at: SystemTime, 
        from: Self::Peer, 
        msg: Self::Message
    ) -> Vec<(Self::Peer, Self::Message)>;

    fn tick(&mut self, _at: SystemTime) -> Vec<(Self::Peer, Self::Message)> { ... }
}

Associated Types

type Peer: ToSocketAddrs

type Message: Serialize + DeserializeOwned

Required Methods

fn receive(
    &mut self,
    at: SystemTime,
    from: Self::Peer,
    msg: Self::Message
) -> Vec<(Self::Peer, Self::Message)>

Provided Methods

fn tick(&mut self, _at: SystemTime) -> Vec<(Self::Peer, Self::Message)>

Implementors

• impl Reactor for Acceptor type Peer = String; type Message = Rpc;
• impl Reactor for Proposer type Peer = String; type Message = Rpc;
• impl Reactor for Client type Peer = String; type Message = Rpc;