Skip to main content

ConcurrentBloom

Struct ConcurrentBloom 

Source
pub struct ConcurrentBloom<T> { /* private fields */ }
👎Deprecated since 3.1.0:

This crate has been marked for formal inclusion in the Agave Unstable API. From v4.0.0 onward, the agave-unstable-api crate feature must be specified to acknowledge use of an interface that may break without warning.

Expand description

Bloom filter that can be used concurrently. Concurrent reads/writes are safe, but are not atomic at the struct level, this means that reads may see partial writes.

Implementations§

Source§

impl<T: BloomHashIndex> ConcurrentBloom<T>

Source

pub fn add(&self, key: &T) -> bool

👎Deprecated since 3.1.0:

This crate has been marked for formal inclusion in the Agave Unstable API. From v4.0.0 onward, the agave-unstable-api crate feature must be specified to acknowledge use of an interface that may break without warning.

Adds an item to the bloom filter and returns true if the item was not in the filter before.

Source

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

👎Deprecated since 3.1.0:

This crate has been marked for formal inclusion in the Agave Unstable API. From v4.0.0 onward, the agave-unstable-api crate feature must be specified to acknowledge use of an interface that may break without warning.

Source

pub fn clear(&self)

👎Deprecated since 3.1.0:

This crate has been marked for formal inclusion in the Agave Unstable API. From v4.0.0 onward, the agave-unstable-api crate feature must be specified to acknowledge use of an interface that may break without warning.

Trait Implementations§

Source§

impl<T: BloomHashIndex> From<Bloom<T>> for ConcurrentBloom<T>

Source§

fn from(bloom: Bloom<T>) -> Self

Converts to this type from the input type.
Source§

impl<T: BloomHashIndex> From<ConcurrentBloom<T>> for Bloom<T>

Source§

fn from(atomic_bloom: ConcurrentBloom<T>) -> Self

Converts to this type from the input type.

Auto Trait Implementations§

§

impl<T> Freeze for ConcurrentBloom<T>

§

impl<T> RefUnwindSafe for ConcurrentBloom<T>
where T: RefUnwindSafe,

§

impl<T> Send for ConcurrentBloom<T>
where T: Send,

§

impl<T> Sync for ConcurrentBloom<T>
where T: Sync,

§

impl<T> Unpin for ConcurrentBloom<T>
where T: Unpin,

§

impl<T> UnsafeUnpin for ConcurrentBloom<T>

§

impl<T> UnwindSafe for ConcurrentBloom<T>
where T: UnwindSafe,

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V