Struct MemoryServiceImpl 

pub struct MemoryServiceImpl { /* private fields */ }

Canonical PostCortexService implementation backed by ConversationMemorySystem.

Construct with Self::new passing an Arc<ConversationMemorySystem> (typically the singleton owned by the daemon).

Implementations

impl MemoryServiceImpl

pub fn new(system: Arc<ConversationMemorySystem>) -> Self

Wrap an existing memory system in the canonical service trait, starting the non-blocking write pipeline with default capacities. Must be called from inside a Tokio runtime.

pub fn with_pipeline_config( system: Arc<ConversationMemorySystem>, config: PipelineConfig, ) -> Self

Wrap an existing memory system in the service trait with an explicit pipeline configuration.

pub fn pipeline(&self) -> &Arc<Pipeline>

Borrow the non-blocking pipeline. Exposed so transport adapters can submit derived-work items directly (e.g. enqueue an embedding compute after a manual storage write).

pub fn inner(&self) -> &Arc<ConversationMemorySystem>

Borrow the underlying memory system. Provided so the daemon’s gRPC handlers can fall back to direct calls for methods that have not been migrated to the trait yet.

Trait Implementations

impl PostCortexService for MemoryServiceImpl

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

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

Returns a snapshot of system health. Cheap — the only operation that does not flow through the storage actor and is safe to call from a heartbeat probe.

fn update_context<'life0, 'async_trait>( &'life0 self, req: UpdateContextRequest, ) -> Pin<Box<dyn Future<Output = Result<UpdateContextResponse, SystemError>> + Send + 'async_trait>>

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

Persist a single context update for a session and enqueue derived work (embedding, HNSW upsert, graph update, summary refresh) onto background pipelines. Returns once the entry is durably persisted; embeddings / vector index land asynchronously per TODO.md:136-145.

fn bulk_update_context<'life0, 'async_trait>( &'life0 self, req: BulkUpdateContextRequest, ) -> Pin<Box<dyn Future<Output = Result<BulkUpdateContextResponse, SystemError>> + Send + 'async_trait>>

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

Batch variant of Self::update_context. Backends use storage write batches when available (RocksDB transaction).

fn semantic_search<'life0, 'async_trait>( &'life0 self, _req: SemanticSearchRequest, ) -> Pin<Box<dyn Future<Output = Result<SemanticSearchResponse, SystemError>> + Send + 'async_trait>>

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

Run a semantic similarity search against persisted content. Scope determines whether the query runs against a single session, a workspace, or the global index.

fn query_context<'life0, 'async_trait>( &'life0 self, _req: QueryContextRequest, ) -> Pin<Box<dyn Future<Output = Result<QueryContextResponse, SystemError>> + Send + 'async_trait>>

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

Run a structured/keyword query against the session’s context updates. Faster than semantic search; no embedding required.

fn assemble_context<'life0, 'async_trait>( &'life0 self, _req: AssembleContextRequest, ) -> Pin<Box<dyn Future<Output = Result<AssembleContextResponse, SystemError>> + Send + 'async_trait>>

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

Graph-aware retrieval: semantic search + entity neighbourhood traversal + impact analysis, all merged into one assembled context payload.

fn manage_session<'life0, 'async_trait>( &'life0 self, _req: ManageSessionRequest, ) -> Pin<Box<dyn Future<Output = Result<ManageSessionResponse, SystemError>> + Send + 'async_trait>>

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

Manage session lifecycle (create / list / load / search / update / delete). The variant carried in the request determines which operation runs — letting callers (especially MCP) treat sessions as a single tool surface.

fn manage_workspace<'life0, 'async_trait>( &'life0 self, _req: ManageWorkspaceRequest, ) -> Pin<Box<dyn Future<Output = Result<ManageWorkspaceResponse, SystemError>> + Send + 'async_trait>>

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

Manage workspace lifecycle (create / list / get / delete / add-session / remove-session). Same shape as Self::manage_session.

fn manage_entity<'life0, 'async_trait>( &'life0 self, _req: ManageEntityRequest, ) -> Pin<Box<dyn Future<Output = Result<ManageEntityResponse, SystemError>> + Send + 'async_trait>>

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

Manage entity lifecycle (delete / delete-update). Cascades through the entity graph; storage-layer side effects (vector index purge, summary invalidation) run on background pipelines.

fn get_structured_summary<'life0, 'async_trait>( &'life0 self, _req: StructuredSummaryRequest, ) -> Pin<Box<dyn Future<Output = Result<StructuredSummaryResponse, SystemError>> + Send + 'async_trait>>

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

Compose the structured summary view for a session — a hierarchical projection over context updates, decisions, problems, and entity importance.

fn admin<'life0, 'async_trait>( &'life0 self, _req: AdminRequest, ) -> Pin<Box<dyn Future<Output = Result<AdminResponse, SystemError>> + Send + 'async_trait>>

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

Run an admin operation (vectorize session, create checkpoint, fetch vectorization stats, etc.). Variant-dispatched like session/workspace/entity for symmetry.