pub struct Fenced<T> { /* private fields */ }Expand description
A value tagged with the epoch in which it was produced.
Use this to stamp messages or state snapshots with an epoch so that recipients can reject stale data.
Implementations§
Source§impl<T> Fenced<T>
impl<T> Fenced<T>
Sourcepub fn new(epoch: FenceEpoch, value: T) -> Self
pub fn new(epoch: FenceEpoch, value: T) -> Self
Wrap a value with the given epoch.
Sourcepub fn epoch(&self) -> FenceEpoch
pub fn epoch(&self) -> FenceEpoch
The epoch this value was produced in.
Sourcepub fn into_value(self) -> T
pub fn into_value(self) -> T
Consume the wrapper and return the inner value.
Sourcepub fn is_stale(&self, current_epoch: &FenceEpoch) -> bool
pub fn is_stale(&self, current_epoch: &FenceEpoch) -> bool
Returns true if this value’s epoch is behind current_epoch.
Trait Implementations§
Source§impl<'de, T> Deserialize<'de> for Fenced<T>where
T: Deserialize<'de>,
impl<'de, T> Deserialize<'de> for Fenced<T>where
T: Deserialize<'de>,
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
impl<T: Copy> Copy for Fenced<T>
impl<T: Eq> Eq for Fenced<T>
impl<T> StructuralPartialEq for Fenced<T>
Auto Trait Implementations§
impl<T> Freeze for Fenced<T>where
T: Freeze,
impl<T> RefUnwindSafe for Fenced<T>where
T: RefUnwindSafe,
impl<T> Send for Fenced<T>where
T: Send,
impl<T> Sync for Fenced<T>where
T: Sync,
impl<T> Unpin for Fenced<T>where
T: Unpin,
impl<T> UnwindSafe for Fenced<T>where
T: 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