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

Loading content...

Required methods

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

Loading content...

Provided methods

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

Loading content...

Implementors

impl Reactor for Client

type Peer = String

type Message = Rpc

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)>

impl Reactor for Proposer

type Peer = String

type Message = Rpc

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)>

impl<S> Reactor for Acceptor<S> where
    S: Storage + Clone + Sized, 

type Peer = String

type Message = Rpc

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

Loading content...