Struct BrainClient 

pub struct BrainClient { /* private fields */ }

Central orchestrator for all Open Brain storage operations.

Implementations

impl BrainClient

pub async fn new() -> Result<Self>

Create a new BrainClient with default paths.

• LanceDB: ~/.brainwires/brain/
• PKS: ~/.brainwires/pks.db
• BKS: ~/.brainwires/bks.db

pub async fn with_paths( lance_path: &str, pks_path: &str, bks_path: &str, ) -> Result<Self>

Create with explicit paths (useful for testing).

Creates a LanceDatabase internally as the default backend.

pub async fn with_backend( backend: Arc<dyn StorageBackend>, embeddings: Arc<EmbeddingProvider>, pks_path: &str, bks_path: &str, ) -> Result<Self>

Create with an externally-provided storage backend.

This is the primary constructor for dependency injection — any StorageBackend implementation can be used (LanceDB, Postgres, etc.).

pub async fn with_bank_config(config: MemoryBankConfig) -> Result<Self>

Create with default paths and a custom MemoryBankConfig.

pub fn set_config(&mut self, config: MemoryBankConfig)

Set or replace the MemoryBankConfig on an existing client.

pub fn config(&self) -> &MemoryBankConfig

Return a reference to the active MemoryBankConfig.

pub async fn capture_thought( &mut self, req: CaptureThoughtRequest, ) -> Result<CaptureThoughtResponse>

Capture a new thought, embed it, detect category, extract PKS facts.

pub async fn capture_thoughts_batch( &mut self, requests: Vec<CaptureThoughtRequest>, ) -> Result<usize>

Batch-capture multiple thoughts in a single embed + insert pass.

Skips per-message evidence checks for speed. PKS extraction still runs per message. Returns the number of thoughts stored.

pub async fn search_memory( &self, req: SearchMemoryRequest, ) -> Result<SearchMemoryResponse>

Semantic search across thoughts and optionally PKS facts.

pub async fn list_recent( &self, req: ListRecentRequest, ) -> Result<ListRecentResponse>

List recent thoughts, optionally filtered by category and time range.

pub async fn query_thought_contents( &self, filter: &Filter, limit: usize, ) -> Result<Vec<String>>

Query thought content strings matching a filter. Used for deduplication.

pub async fn get_thought(&self, id: &str) -> Result<Option<GetThoughtResponse>>

Get a single thought by ID.

pub fn search_knowledge( &self, req: SearchKnowledgeRequest, ) -> Result<SearchKnowledgeResponse>

Search PKS and/or BKS knowledge stores.

pub async fn memory_stats(&self) -> Result<MemoryStatsResponse>

Get aggregate statistics across all memory stores.

pub async fn delete_thought(&self, id: &str) -> Result<DeleteThoughtResponse>

Soft-delete a thought by ID.

pub fn add_behavioral_truth(&mut self, truth: BehavioralTruth) -> Result<()>

Add a behavioral truth to the BKS.

pub async fn delete_by_filter(&self, filter: &Filter) -> Result<usize>

Delete all thoughts matching a filter. Returns count deleted.