Struct libp2p_rs::kad::record::store::MemoryStore

pub struct MemoryStore { /* fields omitted */ }

In-memory implementation of a RecordStore.

Implementations

impl MemoryStore

pub fn new(local_id: PeerId) -> MemoryStore

Creates a new MemoryRecordStore with a default configuration.

pub fn with_config(local_id: PeerId, config: MemoryStoreConfig) -> MemoryStore

Creates a new MemoryRecordStore with the given configuration.

pub fn retain<F>(&mut self, f: F) where
    F: FnMut(&Key, &mut Record) -> bool, 

Retains the records satisfying a predicate.

Trait Implementations

impl<'a> RecordStore<'a> for MemoryStore

type RecordsIter = Map<Values<'a, Key, Record>, fn(&'a Record) -> Cow<'a, Record>>

type ProviderIter = Map<Flatten<Values<'a, Key, SmallVec<[ProviderRecord; 20]>>>, fn(&'a ProviderRecord) -> Cow<'a, ProviderRecord>>

pub fn get(&'a self, k: &Key) -> Option<Cow<'a, Record>>

Gets a record from the store, given its key.

pub fn put(&'a mut self, r: Record) -> Result<(), KadError>

Puts a record into the store.

pub fn remove(&'a mut self, k: &Key)

Removes the record with the given key from the store.

pub fn all_records(&'a self) -> <MemoryStore as RecordStore<'a>>::RecordsIter

Gets an iterator over all (value-) records currently stored.

pub fn gc_records(&'a mut self, ttl: Duration)

Runs GC for all stored records. As a result, all outdated items will be removed from storage.

pub fn add_provider(
    &'a mut self,
    record: ProviderRecord
) -> Result<(), KadError>

Adds a provider record to the store.

pub fn providers(&'a self, key: &Key) -> Vec<ProviderRecord, Global>

Gets a copy of the stored provider records for the given key.

pub fn all_providers(&'a self) -> <MemoryStore as RecordStore<'a>>::ProviderIter

Gets an iterator over all stored provider records.

pub fn remove_provider(&'a mut self, key: &Key, provider: &PeerId)

Removes a provider record from the store.

pub fn gc_providers(&'a mut self, ttl: Duration)

Runs GC for all stored providers. As a result, all outdated items will be removed from storage.