Struct InMemoryStore 

pub struct InMemoryStore<Id, State> { /* private fields */ }

In-process StateStore backed by a RwLock<HashMap>.

Thread-safe for concurrent reads and writes. Suitable for single-process deployments and testing; for distributed setups, use a shared backend like Redis (see loadwise-store-redis).

Implementations

impl<Id, State> InMemoryStore<Id, State>

pub fn new() -> Self

Trait Implementations

impl<Id, State> Default for InMemoryStore<Id, State>

fn default() -> Self

Returns the “default value” for a type.

impl<Id, State> StateStore for InMemoryStore<Id, State>

where Id: Eq + Hash + Clone + Send + Sync, State: Clone + Send + Sync,

type NodeId = Id

type State = State

type Error = Infallible

fn get(&self, id: &Id) -> Result<Option<State>, Self::Error>

Fetch the state for a single node, or None if absent.

fn put(&self, id: &Id, state: State) -> Result<(), Self::Error>

Insert or overwrite the state for a node.

fn remove(&self, id: &Id) -> Result<(), Self::Error>

Remove the state entry for a node.

fn list(&self) -> Result<Vec<(Id, State)>, Self::Error>

Return all stored (id, state) pairs.