pub struct CausalNetworkSimulator<D> { /* private fields */ }Expand description
Network simulator for causal anti-entropy
Implementations§
Source§impl<D: Clone> CausalNetworkSimulator<D>
impl<D: Clone> CausalNetworkSimulator<D>
pub fn new(loss_rate: f64) -> Self
Sourcepub fn send(&mut self, msg: CausalMessage<D>)
pub fn send(&mut self, msg: CausalMessage<D>)
Send a message
Sourcepub fn receive(&mut self) -> Option<CausalMessage<D>>
pub fn receive(&mut self) -> Option<CausalMessage<D>>
Receive the next message
Sourcepub fn retransmit_lost(&mut self)
pub fn retransmit_lost(&mut self)
Retransmit lost messages
Sourcepub fn in_flight_count(&self) -> usize
pub fn in_flight_count(&self) -> usize
Messages in flight
Sourcepub fn lost_count(&self) -> usize
pub fn lost_count(&self) -> usize
Lost messages
Trait Implementations§
Auto Trait Implementations§
impl<D> Freeze for CausalNetworkSimulator<D>
impl<D> RefUnwindSafe for CausalNetworkSimulator<D>where
D: RefUnwindSafe,
impl<D> Send for CausalNetworkSimulator<D>where
D: Send,
impl<D> Sync for CausalNetworkSimulator<D>where
D: Sync,
impl<D> Unpin for CausalNetworkSimulator<D>where
D: Unpin,
impl<D> UnwindSafe for CausalNetworkSimulator<D>where
D: UnwindSafe,
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more