feat(health): Add NVOS Streaming telemetry

crates/health/Cargo.toml

@@ -37,13 +37,17 @@ http = { workspace = true }
 humantime = { workspace = true }
 humantime-serde = { workspace = true }
 hyper = { workspace = true }
+hyper-rustls = { workspace = true, features = ["http2"] }
 hyper-util = { workspace = true }
 mac_address = { workspace = true }
 prometheus = { workspace = true }
 reqwest = { workspace = true, features = ["query", "json"] }
+rustls = { workspace = true }
+rustls-pki-types = { workspace = true }
 serde = { features = ["derive"], workspace = true }
 serde_json = { workspace = true }
 serde_with = { workspace = true }
+tokio-stream = { workspace = true }
 tokio-util = { workspace = true }
 tracing = { workspace = true }
 tracing-subscriber = { features = [

crates/health/build.rs

@@ -20,17 +20,42 @@ use std::path::PathBuf;
 fn main() -> Result<(), Box<dyn std::error::Error>> {
     carbide_version::build();
 
-    // vendored from opentelemetry-proto v1.5.0
     let proto_dir = PathBuf::from("proto");
 
     println!("cargo:rerun-if-changed=proto/");
 
+    // vendored from opentelemetry-proto v1.5.0
+    tonic_prost_build::configure()
+        .build_server(false)
+        .build_client(true)
+        .compile_protos(
+            &[
+                proto_dir.join("opentelemetry/proto/collector/logs/v1/logs_service.proto"),
+                proto_dir.join("opentelemetry/proto/collector/metrics/v1/metrics_service.proto"),
+            ],
+            std::slice::from_ref(&proto_dir),
+        )?;
+
+    // vendored from openconfig/gnmi v0.11.0
+    // gnmi_ext compiled separately so gnmi.proto can extern_path it and reuse the types
     tonic_prost_build::configure()
+        .build_client(true)
         .build_server(false)
+        .compile_protos(
+            &[proto_dir.join("github.com/openconfig/gnmi/proto/gnmi_ext/gnmi_ext.proto")],
+            std::slice::from_ref(&proto_dir),
+        )?;
+
+    tonic_prost_build::configure()
         .build_client(true)
+        .build_server(false)
+        .extern_path(
+            ".gnmi_ext",
+            "crate::collectors::nvue::gnmi::proto::gnmi_ext",
+        )
         .compile_protos(
-            &[proto_dir.join("opentelemetry/proto/collector/logs/v1/logs_service.proto")],
-            &[proto_dir],
+            &[proto_dir.join("github.com/openconfig/gnmi/proto/gnmi/gnmi.proto")],
+            std::slice::from_ref(&proto_dir),
         )?;
 
     Ok(())

crates/health/example/config.example.toml

@@ -168,6 +168,22 @@ cluster_apps_enabled = true
 sdn_partitions_enabled = true
 interfaces_enabled = true
 
+# NVUE gNMI streaming collector (switches only, disabled by default).
+# Subscribes to gNMI SAMPLE paths and pushes metrics through the DataSink
+# pipeline. PrometheusSink serves the /metrics endpoint; OtlpSink (when
+# configured separately) pushes to an OTel Collector.
+[collectors.nvue.gnmi]
+gnmi_port = 9339
+sample_interval = "5m"
+request_timeout = "30s"
+# gNMI ON_CHANGE subscription for system events
+system_events_enabled = true
+
+[collectors.nvue.gnmi.paths]
+components_enabled = true
+interfaces_enabled = true
+leak_sensors_enabled = true
+
 # ==============================================================================
 # Processors
 # ==============================================================================