Struct MemoryStore 

pub struct MemoryStore<const MCL: usize, const MCC: usize, const MPL: usize, N, S, PD, AT> { /* private fields */ }

A non-persistent, in-memory Willow store implementation.

Implementations

impl<const MCL: usize, const MCC: usize, const MPL: usize, N, S, PD, AT> MemoryStore<MCL, MCC, MPL, N, S, PD, AT>

pub fn new() -> Self

Creates a new, empty Willow store.

Trait Implementations

impl<const MCL: usize, const MCC: usize, const MPL: usize, N, S, PD, AT> Clone for MemoryStore<MCL, MCC, MPL, N, S, PD, AT>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<const MCL: usize, const MCC: usize, const MPL: usize, N: Debug, S: Debug, PD: Debug, AT: Debug> Debug for MemoryStore<MCL, MCC, MPL, N, S, PD, AT>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<const MCL: usize, const MCC: usize, const MPL: usize, N, S, PD, AT> Store<MCL, MCC, MPL, N, S, PD, AT> for MemoryStore<MCL, MCC, MPL, N, S, PD, AT>

where PD: Clone + Ord, N: Clone + Ord, S: Clone + Ord, AT: Clone,

async fn flush(&mut self) -> Result<(), Self::InternalError>

A no-op, because the store is not persistent.

type InternalError = Infallible

The type of errors the store implementation might yield on any operation.

async fn create_entry<Data, P, H>( &mut self, data: &Data, payload_producer: P, payload_length: u64, ingredients: &AT::Ingredients, ) -> Result<Option<AuthorisedEntry<MCL, MCC, MPL, N, S, PD, AT>>, CreateEntryError<Self::InternalError, P::Error, AT::CreationError>>

where Data: ?Sized + Namespaced<N> + Coordinatelike<MCL, MCC, MPL, S>, P: BulkProducer<Item = u8, Final = ()>, H: Default + Hasher<PD>, AT: AuthorisationToken<MCL, MCC, MPL, N, S, PD> + Debug, N: Debug, S: Debug, PD: Debug,

Creates an AuthorisedEntry with the given data and payload, and atomically inserts the payload and entry into the store.

async fn create_entry_nondestructive<Data, P, H>( &mut self, data: &Data, payload_producer: P, payload_length: u64, ingredients: &AT::Ingredients, ) -> Result<NondestructiveInsert<MCL, MCC, MPL, N, S, PD, AT>, CreateEntryError<Self::InternalError, P::Error, AT::CreationError>>

where Data: ?Sized + Namespaced<N> + Coordinatelike<MCL, MCC, MPL, S>, P: BulkProducer<Item = u8, Final = ()>, H: Default + Hasher<PD>, AT: AuthorisationToken<MCL, MCC, MPL, N, S, PD> + Debug, N: Debug, S: Debug, PD: Debug,

Creates an Entry with the given data and payload, and atomically inserts the payload and entry into the store, unless it would prune one or more older entries.

async fn insert_entry( &mut self, entry: AuthorisedEntry<MCL, MCC, MPL, N, S, PD, AT>, ) -> Result<bool, Self::InternalError>

Inserts a given AuthorisedEntry into the store.

async fn forget_entry<K>( &mut self, namespace_id: &N, key: &K, expected_digest: Option<PD>, ) -> Result<bool, Self::InternalError>

where K: Keylike<MCL, MCC, MPL, S>, PD: PartialEq,

Removes an entry and its payload from the store. Return Ok(true) if data was actually removed, and Ok(false) if there was no matching entry in the first place.

async fn forget_area( &mut self, namespace_id: &N, area: &Area<MCL, MCC, MPL, S>, ) -> Result<(), Self::InternalError>

Removes all entries and their payloads in some Area from the store.

async fn forget_namespace( &mut self, namespace_id: &N, ) -> Result<(), Self::InternalError>

Removes all entries and their payloads in some namespace from the store.

async fn get_entry<K, Slice>( &mut self, namespace_id: &N, key: &K, expected_digest: Option<PD>, payload_slice: &Slice, ) -> Result<Option<(AuthorisedEntry<MCL, MCC, MPL, N, S, PD, AT>, impl BulkProducer<Item = u8, Final = (), Error = PayloadProducerError<Self::InternalError>>)>, Self::InternalError>

where K: Keylike<MCL, MCC, MPL, S>, Slice: RangeBounds<u64>,

Gets an entry (or None if there is none) together with a producer its payload (more specifically, the indicated payload_slice).

async fn get_area( &mut self, namespace_id: N, area: Area<MCL, MCC, MPL, S>, ) -> impl Producer<Item = AuthorisedEntry<MCL, MCC, MPL, N, S, PD, AT>, Final = (), Error = Self::InternalError>

Returns a producer of all entries in some Area from the store.