Struct InMemoryCheckpointer 

pub struct InMemoryCheckpointer { /* private fields */ }

In-process memory Checkpointer, state is lost on restart, suitable for tests

Implementations

impl InMemoryCheckpointer

pub fn new() -> InMemoryCheckpointer

pub async fn list_with_limit( &self, session_id: &str, offset: usize, limit: usize, ) -> Vec<Checkpoint>

List checkpoints with pagination (offset + limit).

pub async fn cleanup_old(&self, days: u64) -> usize

Clean up snapshots older than days days.

Trait Implementations

impl Checkpointer for InMemoryCheckpointer

fn put<'a>( &'a self, session_id: &'a str, messages: Vec<Message>, ) -> Pin<Box<dyn Future<Output = Result<String, ReactError>> + Send + 'a>>

Save the current session’s message history, returning the new snapshot ID

fn get<'a>( &'a self, session_id: &'a str, ) -> Pin<Box<dyn Future<Output = Result<Option<Checkpoint>, ReactError>> + Send + 'a>>

Get the latest snapshot for the given session (returns None if not found)

fn list<'a>( &'a self, session_id: &'a str, ) -> Pin<Box<dyn Future<Output = Result<Vec<Checkpoint>, ReactError>> + Send + 'a>>

Get all historical snapshots for the given session (reverse chronological order)

fn delete_session<'a>( &'a self, session_id: &'a str, ) -> Pin<Box<dyn Future<Output = Result<(), ReactError>> + Send + 'a>>

Delete all snapshots for the given session

fn list_sessions( &self, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, ReactError>> + Send + '_>>

List all existing session IDs

fn put_state<'a>( &'a self, session_id: &'a str, state: ThreadState, ) -> Pin<Box<dyn Future<Output = Result<String, ReactError>> + Send + 'a>>

Save complete thread state, defaulting to saving only the message list.

fn get_state<'a>( &'a self, session_id: &'a str, ) -> Pin<Box<dyn Future<Output = Result<Option<ThreadState>, ReactError>> + Send + 'a>>

Get the latest thread state, defaulting to recovering from the latest checkpoint.

impl Default for InMemoryCheckpointer

fn default() -> InMemoryCheckpointer

Returns the “default value” for a type.