[−][src]Trait paxos::Reactor
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)>
&mut self,
at: SystemTime,
from: Self::Peer,
msg: Self::Message
) -> Vec<(Self::Peer, Self::Message)>
Provided methods
Loading content...Implementors
impl Reactor for Client
[src]
type Peer = String
type Message = Rpc
fn receive(
&mut self,
_at: SystemTime,
_from: Self::Peer,
_msg: Self::Message
) -> Vec<(Self::Peer, Self::Message)>
[src]
&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)>
[src]
impl Reactor for Proposer
[src]
type Peer = String
type Message = Rpc
fn receive(
&mut self,
at: SystemTime,
from: Self::Peer,
msg: Self::Message
) -> Vec<(Self::Peer, Self::Message)>
[src]
&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)>
[src]
impl<S> Reactor for Acceptor<S> where
S: Storage + Clone + Sized,
[src]
S: Storage + Clone + Sized,