Struct watermark::WatermarkSet

pub struct WatermarkSet<T> {
    pub watermark: T,
    pub recently_added: VecDeque<u64>,
}

A watermarking set

Allows insert and contains operations.

Fields

watermark: T

recently_added: VecDeque<u64>

Methods

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

impl<T: Integer + CheckedSub + CheckedAdd + FromPrimitive + ToPrimitive> WatermarkSet<T>

pub fn insert(&mut self, elem: T)

Insert an element to the collection

Example

let mut wm = watermark::WatermarkSet::default();
wm.insert(123);

Panics

If the collection gets completely full, watermark may overflow the bounds of T, resulting in an unwrap panic on a checked_add.

impl<T: Integer + CheckedSub + ToPrimitive> WatermarkSet<T>

pub fn contains(&self, elem: T) -> bool

Check if an element has been added to the collection

Example

let mut wm = watermark::WatermarkSet::default();
wm.insert(1);
assert!(wm.contains(1));
assert_eq!(wm.contains(2), false);

Trait Implementations

impl<T: Default> Default for WatermarkSet<T>

fn default() -> WatermarkSet<T>

Returns the "default value" for a type.