Struct McpServer 

pub struct McpServer {
    pub name: String,
    pub version: String,
    /* private fields */
}

MCP server that reads JSON-RPC from stdin, writes responses to stdout. Holds Storage, HnswIndex, and GraphEngine for real tool dispatch.

Fields

name: String

version: String

Implementations

impl McpServer

pub fn new( storage: Box<dyn StorageBackend>, vector: HnswIndex, graph: GraphEngine, embeddings: Option<Box<dyn EmbeddingProvider>>, ) -> Self

Create a server with storage, vector, graph, and optional embeddings backends.

pub fn from_db_path(db_path: &Path) -> Result<Self, CodememError>

Create a server from a database path, loading all backends.

pub fn for_testing() -> Self

Create a minimal server for testing (no backends wired).

pub fn lock_graph(&self) -> Result<MutexGuard<'_, GraphEngine>, CodememError>

pub fn storage(&self) -> &dyn StorageBackend

Access the underlying storage backend.

pub fn graph(&self) -> &Mutex<GraphEngine>

Access the graph engine (mutex-protected).

pub fn vector(&self) -> &Mutex<HnswIndex>

Access the vector index (mutex-protected).

pub fn embeddings(&self) -> Option<&Mutex<Box<dyn EmbeddingProvider>>>

Access the embedding provider (mutex-protected, optional).

pub fn bm25(&self) -> &Mutex<Bm25Index>

Access the BM25 index (mutex-protected).

pub fn reload_graph(&self) -> Result<(), CodememError>

Reload the in-memory graph from the database.

This is needed when the graph was modified by a separate process (e.g., MCP stdio indexing while the API server is running).

pub fn db_path(&self) -> Option<&Path>

Access the database path.

pub fn config(&self) -> &CodememConfig

Access the loaded configuration.

pub fn metrics_collector(&self) -> &Arc<InMemoryMetrics>

Access the operational metrics collector.

pub fn save_index(&self)

Save the HNSW index to disk. The index file path is derived from the database path with an .idx extension. No-op if db_path is None (e.g., in-memory / testing mode).

pub fn run(&self) -> Result<()>

Run the MCP server over stdio. Convenience method that creates a StdioTransport and runs it. Blocks until stdin is closed.

pub fn handle_notification(&self, method: &str)

pub fn handle_request( &self, method: &str, params: Option<&Value>, id: Value, ) -> JsonRpcResponse