feat: 📽️ Prometheus XOR streaming

Cargo.toml

@@ -61,11 +61,11 @@ prost = "0.13"
 snap = "1.1"
 hex = "0.4"
 blake3 = "1.5"
-regex = "1.10"
+regex = "1.11"
 influxdb-line-protocol = "2.0"
 flate2 = "1.0"
 smallvec = "1.13.2"
-once_cell = "1.19"
+once_cell = "1.20"
 urlencoding = "2.1"
 hybridmap = "0.1"
 clap = { version = "4.5", features = ["derive"] }
@@ -103,3 +103,5 @@ time = "0.3"
 zstd = "0.13"
 prometheus-parser = "0.4"
 rusty-chunkenc = "0.1.1"
+async-stream = "0.3"
+itertools = "0.13"

src/ingestors/http/app_error.rs

@@ -3,6 +3,7 @@ use axum::response::IntoResponse;
 use axum::response::Response;
 use axum::Json;
 use serde_json::json;
+use std::fmt;
 
 // Anyhow error handling with axum
 // https://github.com/tokio-rs/axum/blob/d3112a40d55f123bc5e65f995e2068e245f12055/examples/anyhow-error-response/src/main.rs
@@ -38,3 +39,13 @@ where
         Self::InternalServerError(err.into())
     }
 }
+
+impl fmt::Display for AppError {
+    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
+        match self {
+            AppError::InternalServerError(error) => write!(f, "Internal Server Error: {}", error),
+            AppError::NotFound(error) => write!(f, "Not Found: {}", error),
+            AppError::BadRequest(error) => write!(f, "Bad Request: {}", error),
+        }
+    }
+}