Struct InMemorySessionStore 

pub struct InMemorySessionStore { /* private fields */ }

In-memory session storage implementation

This implementation stores sessions in a HashMap protected by an async RwLock, making it thread-safe for concurrent access. It’s suitable for development, testing, and single-instance deployments.

Examples

use talk::{InMemorySessionStore, Session};
use talk::storage::SessionStore;
use talk::types::AgentId;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let store = InMemorySessionStore::new();
    let session = Session::new(AgentId::new());
    let session_id = store.create(session).await?;

    let retrieved = store.get(&session_id).await?;
    assert!(retrieved.is_some());

    Ok(())
}

Implementations

impl InMemorySessionStore

pub fn new() -> Self

Create a new in-memory session store

pub async fn len(&self) -> usize

Get the number of sessions currently stored

This is useful for monitoring and testing purposes.

pub async fn is_empty(&self) -> bool

Check if the store is empty

pub async fn clear(&self)

Clear all sessions from the store

This is primarily useful for testing purposes.

Trait Implementations

impl Clone for InMemorySessionStore

fn clone(&self) -> InMemorySessionStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InMemorySessionStore

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

Formats the value using the given formatter.

impl Default for InMemorySessionStore

fn default() -> Self

Returns the “default value” for a type.

impl SessionStore for InMemorySessionStore

fn create<'life0, 'async_trait>( &'life0 self, session: Session, ) -> Pin<Box<dyn Future<Output = Result<SessionId, StorageError>> + Send + 'async_trait>>

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

Create a new session in the store

fn get<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = Result<Option<Session>, StorageError>> + Send + 'async_trait>>

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

Get a session by ID

fn update<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 SessionId, session: Session, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

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

Update an existing session

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

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

Delete a session by ID

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

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

List all session IDs in the store

fn exists<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = Result<bool, StorageError>> + Send + 'async_trait>>

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

Check if a session exists