Struct Storage 

pub struct Storage { /* private fields */ }

Concrete storage implementation using PostgreSQL

Implementations

impl Storage

pub fn new(pool: PgPool) -> Self

Create a new storage instance

pub async fn store( &self, content: &str, context: String, summary: String, tags: Option<Vec<String>>, ) -> Result<Uuid>

Store text with context and summary (deduplication by hash)

pub async fn store_chunk( &self, content: &str, context: String, summary: String, tags: Option<Vec<String>>, chunk_index: i32, total_chunks: i32, parent_id: Uuid, ) -> Result<Uuid>

Store a chunk with parent reference

pub async fn get(&self, id: Uuid) -> Result<Option<Memory>>

Get memory by ID

pub async fn get_chunks(&self, parent_id: Uuid) -> Result<Vec<Memory>>

Get all chunks for a parent document, ordered by chunk index

pub async fn delete(&self, id: Uuid) -> Result<bool>

Delete memory by ID

pub async fn stats(&self) -> Result<StorageStats>

Get basic storage statistics

pub async fn list_recent(&self, limit: i64) -> Result<Vec<Memory>>

List recent memories (for basic browsing)

pub async fn find_similar_content( &self, content_hash: &str, limit: i64, ) -> Result<Vec<Memory>>

Find memories with similar content but different contexts Implements transfer appropriate processing - matching content with varying contexts

pub async fn exists_with_content(&self, content_hash: &str) -> Result<bool>

Check if a specific content already exists Simplified deduplication based on content hash only

pub async fn get_content_stats(&self) -> Result<Vec<(String, i64)>>

Get content statistics showing duplicate content Useful for understanding deduplication effectiveness

pub async fn search_memories( &self, params: SearchParams, ) -> Result<Vec<SearchResult>>

Semantic similarity search using existing embeddings from codex-dreams Implements progressive search strategy with automatic threshold relaxation

pub async fn search_memories_progressive_with_metadata( &self, params: SearchParams, ) -> Result<SearchResultWithMetadata>

Progressive search with metadata about which stage was used

Trait Implementations

impl StorageInterface for Storage

fn store<'life0, 'life1, 'async_trait>( &'life0 self, content: &'life1 str, context: String, summary: String, tags: Option<Vec<String>>, ) -> Pin<Box<dyn Future<Output = Result<Uuid>> + Send + 'async_trait>>

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

Store text content with context and summary

fn store_chunk<'life0, 'life1, 'async_trait>( &'life0 self, content: &'life1 str, context: String, summary: String, tags: Option<Vec<String>>, chunk_index: i32, total_chunks: i32, parent_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Uuid>> + Send + 'async_trait>>

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

Store a chunk with parent reference

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

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

Get memory by ID

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

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

Delete memory by ID

fn search<'life0, 'async_trait>( &'life0 self, params: SearchParams, ) -> Pin<Box<dyn Future<Output = Result<Vec<SearchResult>>> + Send + 'async_trait>>

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

Search memories with flexible parameters

fn stats<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<StorageStats>> + Send + 'async_trait>>

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

Get storage statistics

fn list_recent<'life0, 'async_trait>( &'life0 self, limit: i64, ) -> Pin<Box<dyn Future<Output = Result<Vec<Memory>>> + Send + 'async_trait>>

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

List recent memories

fn get_chunks<'life0, 'async_trait>( &'life0 self, parent_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Vec<Memory>>> + Send + 'async_trait>>

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

Get all chunks for a parent document