Struct MimirServer 

pub struct MimirServer { /* private fields */ }

Mimir MCP server. Holds workspace context (computed at server startup, not per-call), an optional opened Store (required for read tools), and the rmcp ToolRouter that dispatches incoming tool calls to the #[tool]-annotated methods below.

Construct with MimirServer::new and serve over any tokio::io::AsyncRead + AsyncWrite transport via rmcp::ServiceExt::serve. The bin/mimir-mcp target wires this to stdio; integration tests in tests/ use tokio::io::duplex for in-memory framing.

Implementations

impl MimirServer

pub fn new( workspace_id: Option<WorkspaceId>, log_path: Option<PathBuf>, store: Option<Store>, ) -> Self

Build a server with explicit workspace context and (optionally) an already-opened Store. When store is None, the read tools error with no_workspace_open; only mimir_status (and mimir_open_workspace) remain useful.

The default lease TTL is taken from the MIMIR_MCP_LEASE_TTL_SECONDS env var when present and parseable as a non-zero u64, otherwise DEFAULT_LEASE_TTL_SECONDS. The chosen value is stamped into the server at construction; clients can override per- call via OpenWorkspaceArgs::ttl_seconds.

pub fn with_clock( workspace_id: Option<WorkspaceId>, log_path: Option<PathBuf>, store: Option<Store>, clock: Arc<dyn Clock>, ) -> Self

Like MimirServer::new but with an injected Clock implementation. Tests use this with a virtual clock so the lease-expiry state machine can be driven deterministically without tokio::time::sleep against wall-clock SystemTime. Production callers should use MimirServer::new (which wires up SystemClock by default).

pub fn mimir_status_tool_attr() -> Tool

Generated tool metadata function for mimir_status

pub fn mimir_read_tool_attr() -> Tool

Generated tool metadata function for mimir_read

pub fn mimir_verify_tool_attr() -> Tool

Generated tool metadata function for mimir_verify

pub fn mimir_list_episodes_tool_attr() -> Tool

Generated tool metadata function for mimir_list_episodes

pub fn mimir_render_memory_tool_attr() -> Tool

Generated tool metadata function for mimir_render_memory

pub fn mimir_open_workspace_tool_attr() -> Tool

Generated tool metadata function for mimir_open_workspace

pub fn mimir_write_tool_attr() -> Tool

Generated tool metadata function for mimir_write

pub fn mimir_close_episode_tool_attr() -> Tool

Generated tool metadata function for mimir_close_episode

pub fn mimir_release_workspace_tool_attr() -> Tool

Generated tool metadata function for mimir_release_workspace

Trait Implementations

impl Clone for MimirServer

fn clone(&self) -> MimirServer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ServerHandler for MimirServer

fn get_info(&self) -> ServerInfo

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

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 enqueue_task( &self, _request: CallToolRequestParams, _context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<CreateTaskResult, ErrorData>> + MaybeSendFuture

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 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<GetPromptResult, 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<ReadResourceResult, ErrorData>> + MaybeSendFuture

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

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

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 list_tasks( &self, request: Option<PaginatedRequestParams>, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ListTasksResult, ErrorData>> + MaybeSendFuture

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

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

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