Struct BrainMemoryBackend 

pub struct BrainMemoryBackend { /* private fields */ }

Brain memory backend. The Arc<Mutex<Option<…>>> wrapper yields interior mutability on the optional client while keeping the MemoryBackend trait object signature (Arc<…>, no &mut).

Implementations

impl BrainMemoryBackend

pub fn new(socket_path: impl Into<PathBuf>) -> Self

Build a backend pointing at the given socket path. The client is not eagerly connected; the first call attempts to attach.

pub fn with_scope(self, scope: impl Into<String>) -> Self

Set the default scope. Tools that do not pass one explicitly use this value.

pub fn health(&self) -> BrainHealth

Current health. Read by the TUI health banner.

pub async fn ping(&self) -> Result<(), ToolError>

Probe daemon liveness with a ping. Cheaper than a full tool call; used by the TUI health prober. Updates the cached health.

pub async fn stats(&self) -> Result<Value, ToolError>

Space statistics from the daemon’s stats tool (episodes, entities, statements, contradictions). Returned as the raw parsed JSON so callers render without a typed mirror of daemon fields.

pub fn stats_sync(&self) -> Result<Value, ToolError>

Synchronous stats on a small current-thread runtime — same pattern as Self::put_sync. Used by the TUI /memory command.

pub fn search_sync( &self, query: &str, k: usize, ) -> Result<Vec<MemoryItem>, ToolError>

Synchronous search wrapper for callers outside a tokio executor.

pub async fn connected(&self) -> bool

Number of times the connection is currently held. Always 0 or 1 in production; useful for tests that assert reconnect logic.

pub fn put_sync( &self, content: &str, kind: &str, subject: &str, ) -> Result<String, ToolError>

Synchronous helper that drives the MemoryBackend::put trait method on a small current-thread runtime. Used by the migrate flow and by callers that don’t already run inside a tokio executor.

pub fn ping_sync(&self) -> Result<(), ToolError>

Synchronous ping — used by flows that need a live health probe without an executor of their own.

Trait Implementations

impl Debug for BrainMemoryBackend

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl MemoryBackend for BrainMemoryBackend

fn put<'a>( &'a self, content: &'a str, kind: &'a str, subject: &'a str, ) -> Pin<Box<dyn Future<Output = Result<String, ToolError>> + Send + 'a>>

Store a memory item, returning its new ID.

fn search<'a>( &'a self, query: &'a str, k: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<MemoryItem>, ToolError>> + Send + 'a>>

Semantic-search stored memories, returning up to k matches.

fn list<'a>( &'a self, subject: &'a str, ) -> Pin<Box<dyn Future<Output = Result<Vec<MemoryItem>, ToolError>> + Send + 'a>>

List memory items for the given subject.

fn delete<'a>( &'a self, id: &'a str, ) -> Pin<Box<dyn Future<Output = Result<(), ToolError>> + Send + 'a>>

Delete the memory item with the given ID.

fn memory_info(&self) -> Option<String>

Human-readable memory status (None if not supported by this backend).

fn trigger_consolidation(&self) -> Option<String>

Trigger sleep consolidation, returning a status message.

fn trigger_harmonize(&self) -> Option<String>

Trigger SHMR harmonization, returning a status message.

fn clear_all<'a>( &'a self, ) -> Pin<Box<dyn Future<Output = Result<usize, String>> + Send + 'a>>

Delete every memory item in the backend. Returns the number of items removed.

fn enqueue_consolidation<'a>( &'a self, ) -> Pin<Box<dyn Future<Output = Result<String, String>> + Send + 'a>>

Force a consolidation (rebuild) job. Returns a status message describing what was dispatched, or Err when the backend has no in-process capability to enqueue work.