Struct InMemoryKv 

pub struct InMemoryKv { /* private fields */ }

In-memory KV for tests.

Implementations

impl InMemoryKv

pub fn new(local_id: NodeId) -> Self

Create a new in-memory KV identified as local_id.

pub fn seed(&self, peer: NodeId, key: &str, value: String)

Seed a remote peer’s state for tests.

Trait Implementations

impl ClusterKv for InMemoryKv

fn write<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, value: String, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Write value to this instance’s key slot (overwrites).

fn read_from<'life0, 'life1, 'async_trait>( &'life0 self, who: NodeId, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Option<String>> + Send + 'async_trait>>

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

Read key from who’s slot.

fn scan<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Vec<(NodeId, String)>> + Send + 'async_trait>>

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

Every visible instance’s value for key.

fn scan_prefix<'life0, 'life1, 'async_trait>( &'life0 self, prefix: &'life1 str, ) -> Pin<Box<dyn Future<Output = Vec<(NodeId, String, String)>> + Send + 'async_trait>>

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

Every visible instance’s key-value pairs where the key starts with the given prefix.

fn supports_subscription_routing(&self) -> bool

Whether the backend supports the subscription-interest scan the distributed SUBSCRIBE router needs (object stores return false).

impl Debug for InMemoryKv

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

Formats the value using the given formatter.