Trait pearl::filter::traits::BloomProvider

pub trait BloomProvider<Key: Send + Sync>: Sync + Send {
    type Filter: FilterTrait<Key>;

    fn check_filter<'life0, 'life1, 'async_trait>(
        &'life0 self,
        item: &'life1 Key
    ) -> Pin<Box<dyn Future<Output = FilterResult> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        'life1: 'async_trait,
        Self: 'async_trait;
    fn check_filter_fast(&self, item: &Key) -> FilterResult;
    fn offload_buffer<'life0, 'async_trait>(
        &'life0 mut self,
        needed_memory: usize,
        level: usize
    ) -> Pin<Box<dyn Future<Output = usize> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;
    fn get_filter<'life0, 'async_trait>(
        &'life0 self
    ) -> Pin<Box<dyn Future<Output = Option<Self::Filter>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;
    fn get_filter_fast(&self) -> Option<&Self::Filter>;
    fn filter_memory_allocated<'life0, 'async_trait>(
        &'life0 self
    ) -> Pin<Box<dyn Future<Output = usize> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;
}

Trait for scructs which contains bloom filters

Required Associated Types

type Filter: FilterTrait<Key>

Inner filter type

Required Methods

fn check_filter<'life0, 'life1, 'async_trait>(
    &'life0 self,
    item: &'life1 Key
) -> Pin<Box<dyn Future<Output = FilterResult> + Send + 'async_trait>>where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait,

Check if element in filter

fn check_filter_fast(&self, item: &Key) -> FilterResult

Check if element in filter

fn offload_buffer<'life0, 'async_trait>(
    &'life0 mut self,
    needed_memory: usize,
    level: usize
) -> Pin<Box<dyn Future<Output = usize> + Send + 'async_trait>>where
    'life0: 'async_trait,
    Self: 'async_trait,

Returns freed memory

fn get_filter<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = Option<Self::Filter>> + Send + 'async_trait>>where
    'life0: 'async_trait,
    Self: 'async_trait,

Returns overall filter

fn get_filter_fast(&self) -> Option<&Self::Filter>

Returns overall filter

fn filter_memory_allocated<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = usize> + Send + 'async_trait>>where
    'life0: 'async_trait,
    Self: 'async_trait,

Returns allocated memory

Implementors

impl<K: Key + 'static> BloomProvider<K> for Storage<K>

type Filter = <Blob<K> as BloomProvider<K>>::Filter

impl<Key, Filter, Child> BloomProvider<Key> for HierarchicalFilters<Key, Filter, Child>where
    Key: Sync + Send,
    Child: BloomProvider<Key>,
    Filter: FilterTrait<Key>,

type Filter = Filter