diff --git a/crates/index-scheduler/src/lib.rs b/crates/index-scheduler/src/lib.rs index b4cda9bea..7b1eea021 100644 --- a/crates/index-scheduler/src/lib.rs +++ b/crates/index-scheduler/src/lib.rs @@ -427,6 +427,11 @@ impl IndexScheduler { Ok(self.env.non_free_pages_size()?) } + /// Return the maximum possible database size + pub fn max_size(&self) -> Result { + Ok(self.env.info().map_size as u64) + } + /// Return the max size of task allowed until the task queue stop receiving. pub fn remaining_size_until_task_queu_stop(&self) -> Result { Ok((self.env.info().map_size as u64 * TASK_SCHEDULER_SIZE_THRESHOLD_PERCENT_INT / 100) diff --git a/crates/meilisearch/src/metrics.rs b/crates/meilisearch/src/metrics.rs index 4ef7803e5..29c1aeae8 100644 --- a/crates/meilisearch/src/metrics.rs +++ b/crates/meilisearch/src/metrics.rs @@ -68,9 +68,9 @@ lazy_static! { "Meilisearch Task Queue Latency in Seconds", ) .expect("Can't create a metric"); - pub static ref MEILISEARCH_TASK_QUEUE_TOTAL_SIZE: IntGauge = register_int_gauge!(opts!( - "meilisearch_task_queue_total_size", - "Meilisearch Task Queue Total Size", + pub static ref MEILISEARCH_TASK_QUEUE_MAX_SIZE: IntGauge = register_int_gauge!(opts!( + "meilisearch_task_queue_max_size", + "Meilisearch Task Queue Max Size", )) .expect("Can't create a metric"); pub static ref MEILISEARCH_TASK_QUEUE_USED_SIZE: IntGauge = register_int_gauge!(opts!( diff --git a/crates/meilisearch/src/routes/metrics.rs b/crates/meilisearch/src/routes/metrics.rs index 9bb1e3df9..250363ac3 100644 --- a/crates/meilisearch/src/routes/metrics.rs +++ b/crates/meilisearch/src/routes/metrics.rs @@ -169,7 +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); + crate::metrics::MEILISEARCH_TASK_QUEUE_MAX_SIZE.set(index_scheduler.max_size()? as i64); crate::metrics::MEILISEARCH_TASK_QUEUE_USED_SIZE.set(index_scheduler.used_size()? as i64); crate::metrics::MEILISEARCH_TASK_QUEUE_SIZE_UNTIL_STOP_REGISTERING