pub struct WatermarkSet<T> {
pub watermark: T,
pub recently_added: VecDeque<u64>,
}
Expand description
A watermarking set
Allows insert and contains operations.
Fields§
§watermark: T
§recently_added: VecDeque<u64>
Implementations§
Source§impl<T> WatermarkSet<T>
impl<T> WatermarkSet<T>
Sourcepub fn new(watermark: T) -> WatermarkSet<T>
pub fn new(watermark: T) -> WatermarkSet<T>
Create a new benchmarking set containing all elements less than the first parameter.
let wm = watermark::WatermarkSet::new(1385);
assert!(wm.contains(1384));
assert_eq!(wm.contains(1385), false);
assert_eq!(wm.contains(1386), false);
Source§impl<T: Integer + CheckedSub + CheckedAdd + FromPrimitive + ToPrimitive> WatermarkSet<T>
impl<T: Integer + CheckedSub + CheckedAdd + FromPrimitive + ToPrimitive> WatermarkSet<T>
Source§impl<T: Integer + ToPrimitive> WatermarkSet<T>
impl<T: Integer + ToPrimitive> WatermarkSet<T>
Source§impl<T: Integer + CheckedSub + ToPrimitive> WatermarkSet<T>
impl<T: Integer + CheckedSub + ToPrimitive> WatermarkSet<T>
Trait Implementations§
Source§impl<T: Default> Default for WatermarkSet<T>
impl<T: Default> Default for WatermarkSet<T>
Source§fn default() -> WatermarkSet<T>
fn default() -> WatermarkSet<T>
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl<T> Freeze for WatermarkSet<T>where
T: Freeze,
impl<T> RefUnwindSafe for WatermarkSet<T>where
T: RefUnwindSafe,
impl<T> Send for WatermarkSet<T>where
T: Send,
impl<T> Sync for WatermarkSet<T>where
T: Sync,
impl<T> Unpin for WatermarkSet<T>where
T: Unpin,
impl<T> UnwindSafe for WatermarkSet<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