Struct MemoryStorage 

pub struct MemoryStorage<T: Chunk = String> { /* private fields */ }

A simple in-memory storage implementation.

Great for experimentation and testing.

The storage will use a zero indexed, incremental counter as the key for each node if the node id is not set.

Implementations

impl<T: Chunk> MemoryStorage<T>

pub async fn get(&self, key: impl AsRef<str>) -> Option<Node<T>>

Retrieve a node by its key

pub async fn get_all_values(&self) -> Vec<Node<T>>

Retrieve all nodes in the storage

pub async fn get_all(&self) -> Vec<(String, Node<T>)>

Retrieve all nodes in the storage with their keys

Trait Implementations

impl<T: Clone + Chunk> Clone for MemoryStorage<T>

fn clone(&self) -> MemoryStorage<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug + Chunk> Debug for MemoryStorage<T>

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

Formats the value using the given formatter.

impl<T: Default + Chunk> Default for MemoryStorage<T>

fn default() -> MemoryStorage<T>

Returns the “default value” for a type.

impl<T: Chunk> Persist for MemoryStorage<T>

fn store<'life0, 'async_trait>( &'life0 self, node: Node<T>, ) -> Pin<Box<dyn Future<Output = Result<Node<T>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Store a node by its id

If the node does not have an id, a simple counter is used as the key.

fn batch_store<'life0, 'async_trait>( &'life0 self, nodes: Vec<Node<T>>, ) -> Pin<Box<dyn Future<Output = IndexingStream<T>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Store multiple nodes at once

If a node does not have an id, a simple counter is used as the key.

type Input = T

type Output = T

fn setup<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn batch_size(&self) -> Option<usize>

fn name(&self) -> &'static str