MCP Server

CHANGELOG.md

@@ -7,6 +7,7 @@ All notable changes to this project will be documented in this file.
 - New Experimental feature: `weaver serve` command to serve a REST API and web UI. ([#1076](https://github.com/open-telemetry/weaver/pull/1076) by @jerbly)
 - Add support for diff schemas in `registry json-schema`([#1105](https://github.com/open-telemetry/weaver/pull/1105) by @lmolkova)
 - 💥 BREAKING CHANGE 💥 Upgraded JSON schema generation to [2020-12 version of JSON Schema.](https://json-schema.org/draft/2020-12/schema) ([#1125](https://github.com/open-telemetry/weaver/pull/1125) by @jerbly)
+- New Experimental feature: `weaver registry mcp` MCP server for a registry with search, get and live_check tools. ([#1113](https://github.com/open-telemetry/weaver/pull/1113) by @jerbly)
 
 # [0.20.0] - 2025-12-11
 

Cargo.toml

@@ -89,6 +89,7 @@ weaver_checker = { path = "crates/weaver_checker" }
 weaver_emit = { path = "crates/weaver_emit" }
 weaver_live_check = { path = "crates/weaver_live_check" }
 weaver_search = { path = "crates/weaver_search" }
+weaver_mcp = { path = "crates/weaver_mcp" }
 weaver_version = { path = "crates/weaver_version" }
 
 clap = { version = "4.5.41", features = ["derive"] }

README.md

@@ -99,6 +99,7 @@ Further reading:
 | [weaver registry update-markdown](docs/usage.md#registry-update-markdown) | Update markdown files that contain markers indicating the templates used to update the specified sections |
 | [weaver registry live-check](docs/usage.md#registry-live-check)           | Check the conformance level of an OTLP stream against a semantic convention registry |
 | [weaver registry emit](docs/usage.md#registry-emit)                       | Emits a semantic convention registry as example signals to your OTLP receiver |
+| [weaver registry mcp](docs/mcp-server.md)                                 | Run an MCP server for LLM integration |
 | [weaver completion](docs/usage.md#completion)                             | Generate shell completions |
 
 

crates/weaver_live_check/src/live_checker.rs

@@ -5,6 +5,7 @@
 use serde::Serialize;
 use std::collections::HashMap;
 use std::rc::Rc;
+use std::sync::Arc;
 use weaver_semconv::{attribute::AttributeType, group::GroupType};
 
 use crate::{
@@ -19,7 +20,7 @@ use crate::CumulativeStatistics;
 #[derive(Serialize)]
 pub struct LiveChecker {
     /// The resolved registry
-    pub registry: VersionedRegistry,
+    pub registry: Arc<VersionedRegistry>,
     semconv_attributes: HashMap<String, Rc<VersionedAttribute>>,
     semconv_templates: HashMap<String, Rc<VersionedAttribute>>,
     semconv_metrics: HashMap<String, Rc<VersionedSignal>>,
@@ -37,7 +38,7 @@ pub struct LiveChecker {
 impl LiveChecker {
     #[must_use]
     /// Create a new LiveChecker
-    pub fn new(registry: VersionedRegistry, advisors: Vec<Box<dyn Advisor>>) -> Self {
+    pub fn new(registry: Arc<VersionedRegistry>, advisors: Vec<Box<dyn Advisor>>) -> Self {
         // Create a hashmap of attributes for quick lookup
         let mut semconv_attributes = HashMap::new();
         let mut semconv_templates = HashMap::new();
@@ -47,7 +48,7 @@ impl LiveChecker {
         // Hashmap of events by name
         let mut semconv_events = HashMap::new();
 
-        match &registry {
+        match registry.as_ref() {
             VersionedRegistry::V1(registry) => {
                 for group in &registry.groups {
                     if group.r#type == GroupType::Metric {
@@ -243,7 +244,7 @@ mod tests {
             Box::new(EnumAdvisor),
         ];
 
-        let mut live_checker = LiveChecker::new(registry, advisors);
+        let mut live_checker = LiveChecker::new(Arc::new(registry), advisors);
         let rego_advisor =
             RegoAdvisor::new(&live_checker, &None, &None).expect("Failed to create Rego advisor");
         live_checker.add_advisor(Box::new(rego_advisor));
@@ -1108,7 +1109,7 @@ mod tests {
 
         let advisors: Vec<Box<dyn Advisor>> = vec![];
 
-        let mut live_checker = LiveChecker::new(registry, advisors);
+        let mut live_checker = LiveChecker::new(Arc::new(registry), advisors);
         let rego_advisor = RegoAdvisor::new(
             &live_checker,
             &Some("data/policies/live_check_advice/".into()),
@@ -1197,7 +1198,7 @@ mod tests {
             Box::new(EnumAdvisor),
         ];
 
-        let mut live_checker = LiveChecker::new(registry, advisors);
+        let mut live_checker = LiveChecker::new(Arc::new(registry), advisors);
         let rego_advisor =
             RegoAdvisor::new(&live_checker, &None, &None).expect("Failed to create Rego advisor");
         live_checker.add_advisor(Box::new(rego_advisor));
@@ -1259,7 +1260,7 @@ mod tests {
             serde_json::from_reader(File::open(path).expect("Unable to open file"))
                 .expect("Unable to parse JSON");
 
-        let mut live_checker = LiveChecker::new(registry, vec![]);
+        let mut live_checker = LiveChecker::new(Arc::new(registry), vec![]);
         let rego_advisor = RegoAdvisor::new(
             &live_checker,
             &Some("data/policies/live_check_advice/".into()),
@@ -1316,7 +1317,7 @@ mod tests {
             Box::new(EnumAdvisor),
         ];
 
-        let mut live_checker = LiveChecker::new(registry, advisors);
+        let mut live_checker = LiveChecker::new(Arc::new(registry), advisors);
         let rego_advisor =
             RegoAdvisor::new(&live_checker, &None, &None).expect("Failed to create Rego advisor");
         live_checker.add_advisor(Box::new(rego_advisor));
@@ -1398,7 +1399,7 @@ mod tests {
             serde_json::from_reader(File::open(path).expect("Unable to open file"))
                 .expect("Unable to parse JSON");
 
-        let mut live_checker = LiveChecker::new(registry, vec![]);
+        let mut live_checker = LiveChecker::new(Arc::new(registry), vec![]);
         let rego_advisor = RegoAdvisor::new(
             &live_checker,
             &Some("data/policies/live_check_advice/".into()),
@@ -1447,7 +1448,7 @@ mod tests {
             serde_json::from_reader(File::open(path).expect("Unable to open file"))
                 .expect("Unable to parse JSON");
 
-        let mut live_checker = LiveChecker::new(registry, vec![]);
+        let mut live_checker = LiveChecker::new(Arc::new(registry), vec![]);
         let rego_advisor = RegoAdvisor::new(
             &live_checker,
             &Some("data/policies/live_check_advice/".into()),
@@ -1733,7 +1734,7 @@ mod tests {
             Box::new(EnumAdvisor),
         ];
 
-        let mut live_checker = LiveChecker::new(registry, advisors);
+        let mut live_checker = LiveChecker::new(Arc::new(registry), advisors);
         let rego_advisor =
             RegoAdvisor::new(&live_checker, &None, &None).expect("Failed to create Rego advisor");
         live_checker.add_advisor(Box::new(rego_advisor));
@@ -1814,7 +1815,7 @@ mod tests {
 
         let advisors: Vec<Box<dyn Advisor>> = vec![];
 
-        let mut live_checker = LiveChecker::new(registry, advisors);
+        let mut live_checker = LiveChecker::new(Arc::new(registry), advisors);
         let rego_advisor = RegoAdvisor::new(
             &live_checker,
             &Some("data/policies/bad_advice/".into()),
@@ -1877,7 +1878,7 @@ mod tests {
         });
         let mut samples = vec![sample];
         let advisors: Vec<Box<dyn Advisor>> = vec![Box::new(TypeAdvisor)];
-        let mut live_checker = LiveChecker::new(registry, advisors);
+        let mut live_checker = LiveChecker::new(Arc::new(registry), advisors);
 
         let mut stats =
             LiveCheckStatistics::Cumulative(CumulativeStatistics::new(&live_checker.registry));
@@ -1952,7 +1953,7 @@ mod tests {
             live_check_result: None,
         });
         let advisors: Vec<Box<dyn Advisor>> = vec![Box::new(TypeAdvisor)];
-        let mut live_checker = LiveChecker::new(registry, advisors);
+        let mut live_checker = LiveChecker::new(Arc::new(registry), advisors);
 
         let rego_advisor = RegoAdvisor::new(
             &live_checker,
@@ -2008,7 +2009,7 @@ mod tests {
             }),
         ];
         let advisors: Vec<Box<dyn Advisor>> = vec![Box::new(TypeAdvisor)];
-        let mut live_checker = LiveChecker::new(registry, advisors);
+        let mut live_checker = LiveChecker::new(Arc::new(registry), advisors);
 
         let mut stats =
             LiveCheckStatistics::Cumulative(CumulativeStatistics::new(&live_checker.registry));

crates/weaver_mcp/Cargo.toml

@@ -0,0 +1,27 @@
+[package]
+name = "weaver_mcp"
+version.workspace = true
+authors.workspace = true
+repository.workspace = true
+license.workspace = true
+publish.workspace = true
+edition.workspace = true
+rust-version.workspace = true
+description = "MCP (Model Context Protocol) server for semantic convention registry"
+
+[lints]
+workspace = true
+
+[dependencies]
+weaver_search = { path = "../weaver_search" }
+weaver_forge = { path = "../weaver_forge", features = ["openapi"] }
+weaver_semconv = { path = "../weaver_semconv", features = ["openapi"] }
+weaver_live_check = { path = "../weaver_live_check" }
+
+rmcp = { version = "0.12", features = ["server", "transport-io"] }
+schemars = "1"  # Must match rmcp's schemars version (not workspace 0.8.x)
+tokio.workspace = true
+serde.workspace = true
+serde_json.workspace = true
+miette.workspace = true
+log.workspace = true