Struct MemoryStore 

pub struct MemoryStore { /* private fields */ }

In-process KvStore (sharded Mutex maps + TTL).

Implementations

impl MemoryStore

pub fn new() -> Self

Default shard count: max(1, available_parallelism * 2).

pub fn with_shards(n: usize) -> Self

Explicit shard count (minimum 1).

Trait Implementations

impl Clone for MemoryStore

fn clone(&self) -> MemoryStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for MemoryStore

fn default() -> Self

Returns the “default value” for a type.

impl KvStore for MemoryStore

fn get<'a>(&'a self, key: &'a str) -> BoxFuture<'a, Option<Bytes>>

fn set<'a>( &'a self, key: &'a str, val: Bytes, ttl: Option<Duration>, ) -> BoxFuture<'a, ()>

fn remove<'a>(&'a self, key: &'a str) -> BoxFuture<'a, ()>

fn incr<'a>( &'a self, key: &'a str, by: i64, ttl: Option<Duration>, ) -> BoxFuture<'a, u64>

Atomic increment; creates the key at by when missing. Returns new value.

fn clear_prefix<'a>(&'a self, prefix: &'a str) -> BoxFuture<'a, u64>

Remove keys starting with prefix. Returns how many were removed.