Added metric for task queue total size.

This commit is contained in:
DanasFi 2025-04-14 03:35:33 -04:00 committed by Tamo
parent c413855156
commit f607449cb7
3 changed files with 6 additions and 0 deletions

View file

@ -169,6 +169,7 @@ pub async fn get_metrics(
.map(|task| (OffsetDateTime::now_utc() - task.enqueued_at).as_seconds_f64())
.unwrap_or(0.0);
crate::metrics::MEILISEARCH_TASK_QUEUE_LATENCY_SECONDS.set(task_queue_latency_seconds);
crate::metrics::MEILISEARCH_TASK_QUEUE_TOTAL_SIZE.set(index_scheduler.size()? as i64);
let encoder = TextEncoder::new();
let mut buffer = vec![];