refactor: remove open metrics parser (#8905)

src/frontend/src/instance/prom_store.rs

@@ -47,7 +47,7 @@ use servers::http::header::{CONTENT_ENCODING_SNAPPY, CONTENT_TYPE_PROTOBUF, coll
 use servers::http::prom_store::PHYSICAL_TABLE_PARAM;
 use servers::interceptor::{PromStoreProtocolInterceptor, PromStoreProtocolInterceptorRef};
 use servers::pending_rows_batcher::PendingRowsSchemaAlterer;
-use servers::prom_store::{self, Metrics};
+use servers::prom_store;
 use servers::query_handler::{
     PromStoreProtocolHandler, PromStoreProtocolHandlerRef, PromStoreResponse,
 };
@@ -648,10 +648,6 @@ impl PromStoreProtocolHandler for Instance {
             .fail(),
         }
     }
-
-    async fn ingest_metrics(&self, _metrics: Metrics) -> ServerResult<()> {
-        todo!();
-    }
 }
 
 impl Instance {
@@ -791,10 +787,6 @@ impl PromStoreProtocolHandler for ExportMetricHandler {
     ) -> ServerResult<PromStoreResponse> {
         unreachable!();
     }
-
-    async fn ingest_metrics(&self, _metrics: Metrics) -> ServerResult<()> {
-        unreachable!();
-    }
 }
 
 #[cfg(test)]

src/servers/Cargo.toml

@@ -87,7 +87,6 @@ mysql_common = "0.38"
 notify.workspace = true
 object-pool = "0.5"
 once_cell.workspace = true
-openmetrics-parser = "0.4"
 # Wait for https://github.com/databendlabs/opensrv/pull/81
 opensrv-mysql = { git = "https://github.com/GreptimeTeam/opensrv", rev = "6c5a451544194b7bb60a8318d155d4f892b49f2c" }
 opentelemetry-proto.workspace = true

src/servers/src/http/prom_store.rs

@@ -770,7 +770,6 @@ mod tests {
 
     use super::*;
     use crate::prom_remote_write::validation::PromValidationMode;
-    use crate::prom_store::Metrics;
     use crate::query_handler::PromStoreProtocolHandler;
 
     #[test]
@@ -966,10 +965,6 @@ mod tests {
         ) -> Result<PromStoreResponse> {
             unimplemented!()
         }
-
-        async fn ingest_metrics(&self, _metrics: Metrics) -> Result<()> {
-            unimplemented!()
-        }
     }
 
     #[tokio::test]
@@ -1067,9 +1062,5 @@ mod tests {
         ) -> Result<PromStoreResponse> {
             unimplemented!()
         }
-
-        async fn ingest_metrics(&self, _metrics: Metrics) -> Result<()> {
-            unimplemented!()
-        }
     }
 }

src/servers/src/prom_store.rs

@@ -34,7 +34,6 @@ use datafusion::dataframe::DataFrame;
 use datafusion::prelude::{Expr, col, lit, regexp_match};
 use datafusion_common::ScalarValue;
 use datafusion_expr::LogicalPlan;
-use openmetrics_parser::{MetricsExposition, PrometheusType, PrometheusValue};
 use snafu::{OptionExt, ResultExt, ensure};
 use snap::raw::{Decoder, Encoder};
 
@@ -95,11 +94,6 @@ pub fn is_physical_table_selection_label(label: &str) -> bool {
     label == PHYSICAL_TABLE_LABEL || label == PHYSICAL_TABLE_LABEL_ALT
 }
 
-/// Metrics for push gateway protocol
-pub struct Metrics {
-    pub exposition: MetricsExposition<PrometheusType, PrometheusValue>,
-}
-
 /// Get table name from remote query
 pub fn table_name(q: &Query) -> Result<String> {
     let mut matchers = q

src/servers/src/query_handler.rs

@@ -54,7 +54,6 @@ use crate::error::Result;
 use crate::http::jaeger::QueryTraceParams;
 use crate::influxdb::InfluxdbRequest;
 use crate::opentsdb::codec::DataPoint;
-use crate::prom_store::Metrics;
 pub type OpentsdbProtocolHandlerRef = Arc<dyn OpentsdbProtocolHandler + Send + Sync>;
 pub type InfluxdbLineProtocolHandlerRef = Arc<dyn InfluxdbLineProtocolHandler + Send + Sync>;
 pub type PromStoreProtocolHandlerRef = Arc<dyn PromStoreProtocolHandler + Send + Sync>;
@@ -125,8 +124,6 @@ pub trait PromStoreProtocolHandler {
 
     /// Handling prometheus remote read requests
     async fn read(&self, request: ReadRequest, ctx: QueryContextRef) -> Result<PromStoreResponse>;
-    /// Handling push gateway requests
-    async fn ingest_metrics(&self, metrics: Metrics) -> Result<()>;
 }
 
 #[async_trait]

src/servers/tests/http/prom_store_test.rs

@@ -44,7 +44,7 @@ use servers::http::{HttpOptions, HttpServerBuilder};
 use servers::prom_remote_write::v2::test_util as remote_write_v2;
 use servers::prom_remote_write::validation::PromValidationMode;
 use servers::prom_store;
-use servers::prom_store::{Metrics, snappy_compress};
+use servers::prom_store::snappy_compress;
 use servers::query_handler::sql::SqlQueryHandler;
 use servers::query_handler::{PromStoreProtocolHandler, PromStoreResponse};
 use session::context::QueryContextRef;
@@ -146,10 +146,6 @@ impl PromStoreProtocolHandler for DummyInstance {
             body: response.encode_to_vec(),
         })
     }
-
-    async fn ingest_metrics(&self, _metrics: Metrics) -> Result<()> {
-        unimplemented!();
-    }
 }
 
 #[async_trait]