Struct InMemoryStateStore 

pub struct InMemoryStateStore { /* private fields */ }

A simple in-memory implementation of StateStore for testing.

Implementations

impl InMemoryStateStore

pub fn new() -> Self

Create a new in-memory state store

Trait Implementations

impl Default for InMemoryStateStore

fn default() -> Self

Returns the “default value” for a type.

impl StateStore for InMemoryStateStore

fn save_state<'life0, 'life1, 'async_trait, T>( &'life0 self, node_id: NodeId, state: &'life1 T, ) -> Pin<Box<dyn Future<Output = Result<(), FloxideError>> + Send + 'async_trait>>

where T: 'async_trait + Serialize + Send + Sync + 'static, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Save a node’s state

fn get_state<'life0, 'async_trait, T>( &'life0 self, node_id: NodeId, ) -> Pin<Box<dyn Future<Output = Result<Option<T>, FloxideError>> + Send + 'async_trait>>

where T: 'async_trait + for<'de> Deserialize<'de> + Send + Sync + 'static, Self: 'async_trait, 'life0: 'async_trait,

Get a node’s state if it exists

fn has_state<'life0, 'async_trait>( &'life0 self, node_id: NodeId, ) -> Pin<Box<dyn Future<Output = Result<bool, FloxideError>> + Send + 'async_trait>>

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

Check if a node has saved state

fn remove_state<'life0, 'async_trait>( &'life0 self, node_id: NodeId, ) -> Pin<Box<dyn Future<Output = Result<(), FloxideError>> + Send + 'async_trait>>

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

Remove a node’s state

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

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

Get all node IDs with saved states