Struct Storage 

pub struct Storage { /* private fields */ }

Simple storage repository for text data

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