fix: typos

parseablehq · Mar 27, 2024 · 1ba68ae · 1ba68ae
1 parent 83ffe27
commit 1ba68ae
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 6 deletions.
diff --git a/server/src/handlers/http/logstream.rs b/server/src/handlers/http/logstream.rs
@@ -284,7 +284,7 @@ pub async fn get_stats(req: HttpRequest) -> Result<impl Responder, StreamError>
     let stats = stats::get_current_stats(&stream_name, "json")
         .ok_or(StreamError::StreamNotFound(stream_name.clone()))?;
 
-    let ingestor_stats = if CONFIG.parseable.mode == Mode::Query {
+    let ingester_stats = if CONFIG.parseable.mode == Mode::Query {
         Some(query_server::QueryServer::fetch_stats_from_ingesters(&stream_name).await?)
     } else {
         None
@@ -336,9 +336,9 @@ pub async fn get_stats(req: HttpRequest) -> Result<impl Responder, StreamError>
         }
     };
 
-    let stats = if let Some(mut ingestor_stats) = ingestor_stats {
-        ingestor_stats.push(stats);
-        QueryServer::merge_quried_stats(ingestor_stats)
+    let stats = if let Some(mut ingester_stats) = ingester_stats {
+        ingester_stats.push(stats);
+        QueryServer::merge_quried_stats(ingester_stats)
     } else {
         stats
     };

diff --git a/server/src/handlers/http/modal/query_server.rs b/server/src/handlers/http/modal/query_server.rs
@@ -166,8 +166,6 @@ impl QueryServer {
             .map(|x| serde_json::from_slice::<IngesterMetadata>(x).unwrap_or_default())
             .collect_vec();
 
-        // TODO: add validation logic here
-        // validate the ingester metadata
         Ok(arr)
     }