echo_agent 0.1.4

Production-grade AI Agent framework for Rust — ReAct engine, multi-agent, memory, streaming, MCP, IM channels, workflows
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

//! Memory and persistence subsystem
//!
//! Centralized management of context window, long-term memory store, state snapshots,
//! Checkpoint, and conversation history projection.

use crate::compression::ContextManager;
use crate::memory::{Checkpointer, SnapshotManager, Store};
use std::sync::Arc;

/// Memory and persistence subsystem
///
/// Aggregates conversation context, long-term memory Store, state snapshots,
/// thread Checkpoint, and conversation history projection Store.
pub(crate) struct MemorySubsystem {
    pub(crate) context: Arc<tokio::sync::Mutex<ContextManager>>,
    pub(crate) store: Option<Arc<dyn Store>>,
    pub(crate) checkpointer: Option<Arc<dyn Checkpointer>>,
    pub(crate) snapshot_manager: Arc<std::sync::RwLock<Option<SnapshotManager>>>,
    pub(crate) conversation_store: Option<Arc<dyn crate::memory::ConversationStore>>,
}