Skip to content

Commit 7f3e752

Browse files
refactor
1 parent d572881 commit 7f3e752

File tree

2 files changed

+5
-10
lines changed

2 files changed

+5
-10
lines changed

src/handlers/http/modal/query/querier_logstream.rs

Lines changed: 2 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@ use crate::{
4444
},
4545
hottier::HotTierManager,
4646
parseable::{StreamNotFound, PARSEABLE},
47-
stats::{self, Stats},
47+
stats,
4848
storage::{ObjectStoreFormat, StreamType, STREAM_ROOT_DIRECTORY},
4949
};
5050

@@ -178,12 +178,7 @@ pub async fn get_stats(
178178

179179
let stats = fetch_daily_stats(date_value, &stream_jsons)?;
180180

181-
let total_stats = Stats {
182-
events: stats.events,
183-
ingestion: stats.ingestion,
184-
storage: stats.storage,
185-
};
186-
let stats = serde_json::to_value(total_stats)?;
181+
let stats = serde_json::to_value(stats)?;
187182

188183
return Ok((web::Json(stats), StatusCode::OK));
189184
}

src/prism/home/mod.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -220,7 +220,7 @@ async fn stats_for_date(
220220
// Process each stream concurrently
221221
let stream_stats_futures = stream_wise_meta
222222
.values()
223-
.map(|meta| get_stream_stats_for_date(date.clone(), meta.clone()));
223+
.map(|meta| get_stream_stats_for_date(date.clone(), meta));
224224

225225
let stream_stats_results = futures::future::join_all(stream_stats_futures).await;
226226

@@ -244,9 +244,9 @@ async fn stats_for_date(
244244

245245
async fn get_stream_stats_for_date(
246246
date: String,
247-
meta: Vec<ObjectStoreFormat>,
247+
meta: &[ObjectStoreFormat],
248248
) -> Result<(u64, u64, u64), PrismHomeError> {
249-
let stats = fetch_daily_stats(&date, &meta)?;
249+
let stats = fetch_daily_stats(&date, meta)?;
250250

251251
Ok((stats.events, stats.ingestion, stats.storage))
252252
}

0 commit comments

Comments
 (0)