feat: add UDP shredstream provider for raw shred-level benchmarking

Cargo.toml

@@ -19,6 +19,20 @@ bytes = "1.10.0"
 bincode = "1.3.3"
 solana-entry = "2"
 solana-pubkey = "2"
+solana-sdk = "=2.2.1"
+
+# UDP shred reconstruction dependencies
+solana-ledger = { git = "https://github.com/jito-foundation/jito-solana.git", branch = "eric/v2.2-merkle-recovery" }
+solana-perf = "=2.2.1"
+solana-streamer = "=2.2.1"
+solana-net-utils = "=2.2.1"
+solana-metrics = "=2.2.1"
+ahash = "0.8"
+itertools = "0.14.0"
+crossbeam-channel = "0.5.8"
+rand = "0.8"
+socket2 = "0.5"
+tikv-jemallocator = "0.6"
 lazy_static = "1.5.0"
 dashmap = "6"
 comfy-table = "7.1.0"
@@ -37,3 +51,9 @@ thorstreamer-grpc-client = "0.1.3"
 [build-dependencies]
 tonic-prost-build = "0.14"
 protoc-bin-vendored = "3"
+
+[profile.release]
+opt-level = 3
+lto = "fat"
+codegen-units = 1
+strip = true

src/backend.rs

@@ -558,10 +558,17 @@ impl BackendConfigPayload {
 
 impl BackendEndpointPayload {
     fn from_endpoint(endpoint: &Endpoint, provided_ip: Option<String>) -> Self {
+        let (kind_str, url) = match endpoint.kind {
+            // Backend doesn't know UDP variant: map kind and wrap bare socket addr as URL
+            crate::config::EndpointKind::UdpShredstream => {
+                ("shredstream", format!("udp://{}", endpoint.url))
+            }
+            _ => (endpoint.kind.as_str(), endpoint.url.clone()),
+        };
         Self {
             name: endpoint.name.clone(),
-            url: endpoint.url.clone(),
-            kind: Some(endpoint.kind.as_str().to_string()),
+            url,
+            kind: Some(kind_str.to_string()),
             resolved_ip: provided_ip,
         }
     }
@@ -577,6 +584,13 @@ async fn build_endpoint_payloads(endpoints: &[Endpoint]) -> Vec<BackendEndpointP
 }
 
 async fn resolve_endpoint_ip(endpoint: &Endpoint) -> Option<String> {
+    // UDP endpoints use bare socket addresses (e.g. "127.0.0.1:8001"), not URLs
+    if matches!(endpoint.kind, crate::config::EndpointKind::UdpShredstream) {
+        return endpoint.url.parse::<std::net::SocketAddr>()
+            .ok()
+            .map(|addr| addr.ip().to_string());
+    }
+
     let parsed = match Url::parse(&endpoint.url) {
         Ok(url) => url,
         Err(err) => {

src/config.rs

@@ -48,6 +48,8 @@ pub enum EndpointKind {
     Shredstream,
     Shreder,
     Jetstream,
+    #[serde(alias = "udpshredstream")]
+    UdpShredstream,
 }
 
 #[derive(Debug, Clone, Copy, Default, Deserialize, Serialize)]
@@ -88,6 +90,7 @@ impl EndpointKind {
             EndpointKind::Shredstream => "shredstream",
             EndpointKind::Shreder => "shreder",
             EndpointKind::Jetstream => "jetstream",
+            EndpointKind::UdpShredstream => "udpshredstream",
         }
     }
 }