Struct MemorySystem 

pub struct MemorySystem { /* private fields */ }

Unified memory system interface

Implementations

impl MemorySystem

pub async fn new(config: MemoryConfig) -> Result<Self>

Create new memory system

pub async fn get(&self, namespace: &str, key: &str) -> Result<Option<Vec<u8>>>

Get from memory (tries L1 -> L2 -> L3)

pub async fn put( &self, namespace: &str, key: &str, value: Vec<u8>, ) -> Result<()>

Store in memory (writes to all tiers)

pub async fn search_similar( &self, namespace: &str, query_embedding: Vec<f32>, top_k: usize, ) -> Result<Vec<(String, f32)>>

Semantic search using L2 vector store

pub async fn track_trajectory(&self, trajectory: Trajectory) -> Result<()>

Track agent trajectory

pub async fn subscribe(&self, topic: &str) -> Result<Receiver<Vec<u8>>>

Subscribe to agent messages

pub async fn publish(&self, topic: &str, message: Vec<u8>) -> Result<()>

Publish message to agents

pub async fn acquire_lock( &self, resource: &str, timeout: Duration, ) -> Result<String>

Acquire distributed lock

pub async fn release_lock(&self, token: &str) -> Result<()>

Release distributed lock

pub fn stats(&self) -> MemoryStats

Get memory statistics