Struct McpServer 

pub struct McpServer { /* private fields */ }

Implementations

impl McpServer

pub fn new() -> Self

Create a new MCP server.

pub fn enable_layered_pipeline(&mut self, pipeline: SessionPipeline)

Enable the Paper 2 layered pipeline (L0 cross-turn dedup) for the lifetime of this server. Once set, every tools/call response is passed through SessionPipeline::process before being returned.

pub fn on_compaction_boundary(&self)

Drop the layered-pipeline cache partition on host compaction.

pub fn set_routing_engine(&mut self, engine: Arc<RoutingEngine>)

Install a transparent-routing engine. Must be built by the caller after upstream tools have been fetched and the local tool catalogue has been enumerated.

pub fn set_telemetry(&mut self, buffer: TelemetryBuffer)

Install a telemetry buffer. Every tool invocation emits one event into it.

pub fn set_builtin_tools_config( &mut self, config: BuiltinToolsConfig, ) -> Result<()>

Set the built-in tools filtering configuration.

Returns an error if both disabled and enabled are set (mutually exclusive).

pub fn set_proxy_manager(&mut self, proxy_manager: ProxyManager)

Set the proxy manager for upstream MCP server connections.

pub fn set_deferred_init(&mut self, receiver: Receiver<DeferredInit>)

Set deferred initialization that will be resolved on first tools/list or tools/call.

This allows the MCP server to start reading stdin immediately while remote config fetch, proxy connections, and tool loading run in the background.

pub fn add_meeting_provider(&mut self, provider: Arc<dyn MeetingNotesProvider>)

pub fn add_knowledge_base_provider( &mut self, provider: Arc<dyn KnowledgeBaseProvider>, )

pub fn add_knowledge_base_provider_to_context( &mut self, context: &str, provider: Arc<dyn KnowledgeBaseProvider>, )

pub fn add_messenger_provider(&mut self, provider: Arc<dyn MessengerProvider>)

pub fn add_messenger_provider_to_context( &mut self, context: &str, provider: Arc<dyn MessengerProvider>, )

pub fn add_provider(&mut self, provider: Arc<dyn Provider>)

pub fn add_provider_to_context( &mut self, context: &str, provider: Arc<dyn Provider>, )

Add a provider under a named context.

pub fn ensure_context(&mut self, context: &str)

Ensure a named context exists, even if it has no providers.

pub fn set_active_context(&self, context: &str) -> Result<()>

pub fn active_context_name(&self) -> String

Get active context name.

pub fn context_names(&self) -> Vec<String>

List all context names.

pub fn active_providers(&self) -> Vec<Arc<dyn Provider>>

Get providers in active context.

pub fn active_knowledge_base_providers( &self, ) -> Vec<Arc<dyn KnowledgeBaseProvider>>

Get knowledge base providers in active context.

pub fn active_messenger_providers(&self) -> Vec<Arc<dyn MessengerProvider>>

Get messenger providers in active context.

pub fn providers(&self) -> &[Arc<dyn Provider>]

Get providers in the default context.

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

Run the MCP server main loop.

pub async fn handle_request(&mut self, req: JsonRpcRequest) -> JsonRpcResponse

Handle a JSON-RPC request.

pub fn handle_tools_list(&self, id: RequestId) -> JsonRpcResponse

Handle tools/list request.

Returns the list of available tools filtered by configured providers. This method is public to allow integration testing.

pub async fn execute_for_prefetch( &self, name: &str, arguments: Option<Value>, ) -> ToolCallResult

Paper 3 — execute a tool out-of-band for the speculative pre-fetch dispatcher.

Goes through the same routing engine as the main flow so that transparent-proxy prefixes / fallbacks / mock providers all work identically. Differences from handle_tools_call:

• No JsonRpcResponse wrapping — returns the raw ToolCallResult.
• No telemetry write here — the synthetic PipelineEvent is emitted later by SessionPipeline::write_prefetch_to_cache with enricher_prefetched = true.
• No mutation invalidation — the planner’s is_speculatable() filter blocks MutatesLocal / MutatesExternal upstream, so we never reach this method for a write.
• No dedup post-pass — the prefetched body is written into the dedup cache afterward by SessionPipeline, not here.

Internal-context tools (use_context, list_contexts, …) are not eligible for speculation by design, so they short-circuit to an error result rather than mutating server state.

Trait Implementations

impl Default for McpServer

fn default() -> Self

Returns the “default value” for a type.