Struct McpServer 

pub struct McpServer { /* private fields */ }

MCP server wrapping a MemoryService.

Implementations

impl McpServer

pub fn compile_context_tool_attr() -> Tool

Generated tool metadata function for compile_context

pub fn compile_transcript_tool_attr() -> Tool

Generated tool metadata function for compile_transcript

pub fn context_savings_tool_attr() -> Tool

Generated tool metadata function for context_savings

pub fn explain_compilation_tool_attr() -> Tool

Generated tool metadata function for explain_compilation

pub fn retrieve_context_source_tool_attr() -> Tool

Generated tool metadata function for retrieve_context_source

pub fn save_working_context_tool_attr() -> Tool

Generated tool metadata function for save_working_context

pub fn load_working_context_tool_attr() -> Tool

Generated tool metadata function for load_working_context

pub fn list_working_contexts_tool_attr() -> Tool

Generated tool metadata function for list_working_contexts

pub fn suggest_budget_tool_attr() -> Tool

Generated tool metadata function for suggest_budget

impl McpServer

pub fn recall_fused_tool_attr() -> Tool

Generated tool metadata function for recall_fused

pub fn why_tool_attr() -> Tool

Generated tool metadata function for why

pub fn remember_extracted_tool_attr() -> Tool

Generated tool metadata function for remember_extracted

pub fn extraction_status_tool_attr() -> Tool

Generated tool metadata function for extraction_status

pub fn list_memories_tool_attr() -> Tool

Generated tool metadata function for list_memories

impl McpServer

pub fn migration_start_tool_attr() -> Tool

Generated tool metadata function for migration_start

pub fn migration_status_tool_attr() -> Tool

Generated tool metadata function for migration_status

pub fn migration_cancel_tool_attr() -> Tool

Generated tool metadata function for migration_cancel

pub fn migration_recover_tool_attr() -> Tool

Generated tool metadata function for migration_recover

impl McpServer

pub fn memory_status_tool_attr() -> Tool

Generated tool metadata function for memory_status

impl McpServer

pub fn new(service: MemoryService<DynEmbedder>) -> Self

Wrap a memory service as an MCP server.

pub fn with_embedder_identity( self, model: impl Into<String>, _dimension: usize, ) -> Self

Declare the running embedder’s identity (model name + vector width) so memory_status can name it — and say whether recall is semantic. Undeclared, the status reports the embedder as unreported rather than guessing from the service, which only ever sees &[f32].

pub fn with_store_dir(self, dir: impl Into<PathBuf>) -> Self

Point memory_status at the store directory so it can relay the embedding-provenance record (#1751). Without it the provenance block reports recorded: false.

pub fn with_online_migration<F>( self, source: impl Into<PathBuf>, factory: F, ) -> Result<Self, MemoryError>

where F: Fn(&str) -> Result<(DynEmbedder, String), MemoryError> + Send + Sync + 'static,

Attach the daemon-owned online migration control plane.

Errors

Returns an error when its durable control directory cannot be created safely.

pub fn with_extractor(self, extractor: DynExtractor) -> Self

Attach an extraction backend, enabling the remember_extracted tool. Without it the tool reports that extraction is not configured.

pub fn with_named_extractor( self, backend: impl Into<String>, extractor: DynExtractor, ) -> Result<Self, String>

Attach the named daemon-level default used when remember_extracted omits its per-call extractor choice.

Errors

Returns an error when backend is unknown or disables extraction.

pub fn with_extraction_jobs( self, store_root: impl AsRef<Path>, ) -> Result<Self, String>

Enable the durable extraction-job worker under the native store root.

Call this after opening the store and before serving requests. Accepted and in-flight records are recovered immediately; corrupt durable state fails startup instead of silently losing a receipt.

Errors

Returns a descriptive error if the job directory cannot be created, validated, read, or if the recovery worker cannot start.

pub fn with_default_ttl(self, ttl_seconds: u64) -> Self

Apply a default TTL (seconds) to rememberd facts that don’t carry their own ttl_seconds. 0 is treated as “no default” (permanent).

pub fn with_ingest_roots(self, roots: IngestRoots) -> Self

Enable path ingestion (V2b-1): compile_context and explain_compilation fragments carrying path are resolved against this allowlist before compilation. Without this (the default), every path fragment fails with an explicit “ingestion disabled” error — same pattern as Self::with_extractor.

pub fn remember_tool_attr() -> Tool

Generated tool metadata function for remember

pub fn recall_tool_attr() -> Tool

Generated tool metadata function for recall

pub fn recall_where_tool_attr() -> Tool

Generated tool metadata function for recall_where

pub fn feedback_tool_attr() -> Tool

Generated tool metadata function for feedback

pub fn relate_tool_attr() -> Tool

Generated tool metadata function for relate

pub fn unrelate_tool_attr() -> Tool

Generated tool metadata function for unrelate

pub fn forget_tool_attr() -> Tool

Generated tool metadata function for forget

pub fn entity_tool_attr() -> Tool

Generated tool metadata function for entity

Trait Implementations

impl Clone for McpServer

fn clone(&self) -> McpServer

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl ServerHandler for McpServer

async fn call_tool( &self, request: CallToolRequestParams, context: RequestContext<RoleServer>, ) -> Result<CallToolResponse, ErrorData>

One trace event per tool call (#1780): tool name, session id, verdict, duration — never an argument or fact content (tests/daemon_logging.rs holds a canary against that). Written by hand so the event wraps the dispatch — #[tool_handler] sees the method already exists and only generates list_tools; the dispatch below is exactly what the macro would have generated.

fn get_info(&self) -> ServerInfo

async fn list_tools( &self, _request: Option<PaginatedRequestParams>, context: RequestContext<RoleServer>, ) -> Result<ListToolsResult, ErrorData>

fn get_tool(&self, name: &str) -> Option<Tool>

Get a tool definition by name.

fn ping( &self, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture

fn initialize( &self, request: InitializeRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<InitializeResult, ErrorData>> + MaybeSendFuture

fn supported_protocol_versions(&self) -> Cow<'static, [ProtocolVersion]>

Return the protocol versions supported by this server.

fn discover( &self, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<DiscoverResult, ErrorData>> + MaybeSendFuture

Return this server’s discovery information.

fn complete( &self, request: CompleteRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<CompleteResult, ErrorData>> + MaybeSendFuture

fn set_level( &self, request: SetLevelRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture

fn get_prompt( &self, request: GetPromptRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<GetPromptResponse, ErrorData>> + MaybeSendFuture

fn list_prompts( &self, request: Option<PaginatedRequestParams>, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ListPromptsResult, ErrorData>> + MaybeSendFuture

fn list_resources( &self, request: Option<PaginatedRequestParams>, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ListResourcesResult, ErrorData>> + MaybeSendFuture

fn list_resource_templates( &self, request: Option<PaginatedRequestParams>, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ListResourceTemplatesResult, ErrorData>> + MaybeSendFuture

fn read_resource( &self, request: ReadResourceRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ReadResourceResponse, ErrorData>> + MaybeSendFuture

fn accepted_subscription_filter( &self, requested: &SubscriptionFilter, ) -> Option<SubscriptionFilter>

Return the subset of a requested notification filter this server accepts.

fn listen( &self, context: SubscriptionContext, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture

Run one established subscription until it is cancelled or closed gracefully.

fn subscribe( &self, request: SubscribeRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture

👎Deprecated:

resources/subscribe is legacy-only; implement accepted_subscription_filter and listen for protocol version 2026-07-28

fn unsubscribe( &self, request: UnsubscribeRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture

👎Deprecated:

resources/unsubscribe is legacy-only; subscriptions/listen is cancelled through its request lifecycle

fn on_custom_request( &self, request: CustomRequest, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<CustomResult, ErrorData>> + MaybeSendFuture

fn on_cancelled( &self, notification: CancelledNotificationParam, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + MaybeSendFuture

fn on_progress( &self, notification: ProgressNotificationParam, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + MaybeSendFuture

fn on_initialized( &self, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + MaybeSendFuture

fn on_roots_list_changed( &self, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + MaybeSendFuture

fn on_custom_notification( &self, notification: CustomNotification, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + MaybeSendFuture

fn get_task( &self, request: GetTaskParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<GetTaskResult, ErrorData>> + MaybeSendFuture

SEP-2663 tasks/get: return the current DetailedTask state.

fn update_task( &self, request: UpdateTaskParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture

SEP-2663 tasks/update: accept responses to outstanding in-task input requests. Returns an empty acknowledgement on success.

fn cancel_task( &self, request: CancelTaskParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture

SEP-2663 tasks/cancel: cooperative cancellation. Returns an empty acknowledgement; the task’s observable status may lag.