apollo_dashboard: simpler new fn for Panel

Author: matanl-starkware

crates/apollo_dashboard/src/dashboard.rs

@@ -138,7 +138,7 @@ pub(crate) struct Panel {
 }
 
 impl Panel {
-    pub(crate) fn new(
+    pub(crate) fn new_multi_expr(
         name: impl ToString,
         description: impl ToString,
         exprs: Vec<String>,
@@ -156,6 +156,16 @@ impl Panel {
         );
         Self { name, description, exprs, panel_type, extra: ExtraParams::default() }
     }
+
+    pub(crate) fn new(
+        name: impl ToString,
+        description: impl ToString,
+        expr: String,
+        panel_type: PanelType,
+    ) -> Self {
+        Self::new_multi_expr(name, description, vec![expr], panel_type)
+    }
+
     pub fn with_unit(mut self, unit: Unit) -> Self {
         self.extra.unit = Some(unit);
         self
@@ -288,14 +298,14 @@ impl Panel {
 
         let expr = format!("({numerator_expr} / ({denominator_expr}))");
 
-        Self::new(name, description, vec![expr], PanelType::TimeSeries).with_unit(Unit::PercentUnit)
+        Self::new(name, description, expr, PanelType::TimeSeries).with_unit(Unit::PercentUnit)
     }
 
     pub(crate) fn from_counter(metric: &MetricCounter, panel_type: PanelType) -> Self {
         Self::new(
             metric.get_name(),
             metric.get_description(),
-            vec![metric.get_name_with_filter().to_string()],
+            metric.get_name_with_filter().to_string(),
             panel_type,
         )
     }
@@ -304,7 +314,7 @@ impl Panel {
         Self::new(
             metric.get_name(),
             metric.get_description(),
-            vec![metric.get_name_with_filter().to_string()],
+            metric.get_name_with_filter().to_string(),
             panel_type,
         )
     }
@@ -315,7 +325,7 @@ impl Panel {
         description: impl ToString,
         sum_by: impl AsRef<str>,
     ) -> Self {
-        Self::new(
+        Self::new_multi_expr(
             name.to_string(),
             description.to_string(),
             HISTOGRAM_QUANTILES
@@ -395,7 +405,7 @@ impl From<&LocalServerMetrics> for UnlabeledPanels {
             Panel::from_counter(metrics.get_received_metric(), PanelType::TimeSeries);
         let processed_msgs_panel =
             Panel::from_counter(metrics.get_processed_metric(), PanelType::TimeSeries);
-        let queue_depth_panel = Panel::new(
+        let queue_depth_panel = Panel::new_multi_expr(
             "local_queue_depth",
             "The depth of the local priority queues",
             vec![
@@ -472,7 +482,7 @@ fn get_multi_metric_panel(
             )
         }))
     }
-    Panel::new(panel_name, panel_description, exprs, panel_type)
+    Panel::new_multi_expr(panel_name, panel_description, exprs, panel_type)
 }
 
 // Custom Serialize implementation for Panel.

crates/apollo_dashboard/src/dashboard_test.rs

@@ -91,7 +91,7 @@ fn test_ratio_time_series() {
 
 #[test]
 fn test_extra_params() {
-    let panel_with_extra_params = Panel::new("x", "x", vec!["y".to_string()], PanelType::Stat)
+    let panel_with_extra_params = Panel::new("x", "x", "y".to_string(), PanelType::Stat)
         .with_unit(Unit::Bytes)
         .show_percent_change()
         .with_log_query("Query")
@@ -118,7 +118,7 @@ fn test_extra_params() {
     );
     assert_eq!(panel_with_extra_params.extra.legends, Some(vec!["a".to_string()]));
 
-    let panel_without_extra_params = Panel::new("x", "x", vec!["y".to_string()], PanelType::Stat);
+    let panel_without_extra_params = Panel::new("x", "x", "y".to_string(), PanelType::Stat);
     assert!(panel_without_extra_params.extra.unit.is_none());
     assert!(panel_without_extra_params.extra.show_percent_change.is_none());
     assert!(panel_without_extra_params.extra.log_query.is_none());
@@ -129,7 +129,7 @@ fn test_extra_params() {
 #[test]
 #[should_panic]
 fn thresholds_first_step_must_be_none() {
-    let _ = Panel::new("x", "x", vec!["y".into()], PanelType::Stat).with_absolute_thresholds(vec![
+    let _ = Panel::new("x", "x", "y".into(), PanelType::Stat).with_absolute_thresholds(vec![
         ("green", Some(0.0)), // illegal: first step must be None
         ("red", Some(80.0)),
     ]);
@@ -138,7 +138,7 @@ fn thresholds_first_step_must_be_none() {
 #[test]
 #[should_panic]
 fn thresholds_must_be_strictly_increasing() {
-    let _ = Panel::new("x", "x", vec!["y".into()], PanelType::Stat).with_absolute_thresholds(vec![
+    let _ = Panel::new("x", "x", "y".into(), PanelType::Stat).with_absolute_thresholds(vec![
         ("green", None),
         ("red", Some(90.0)),
         ("yellow", Some(80.0)), // illegal: not increasing
@@ -148,5 +148,5 @@ fn thresholds_must_be_strictly_increasing() {
 #[test]
 #[should_panic]
 fn amount_of_legends_must_match_amount_of_exprs() {
-    let _ = Panel::new("x", "x", vec!["y".into()], PanelType::Stat).with_legends(vec!["a", "b"]);
+    let _ = Panel::new("x", "x", "y".into(), PanelType::Stat).with_legends(vec!["a", "b"]);
 }

crates/apollo_dashboard/src/panels/batcher.rs

@@ -19,7 +19,7 @@ fn get_panel_validator_wasted_txs() -> Panel {
     Panel::new(
         "Proposal Validation: Wasted TXs",
         "Number of txs executed by the validator but excluded from the block (10m window)",
-        vec![format!("increase({}[10m])", VALIDATOR_WASTED_TXS.get_name_with_filter())],
+        format!("increase({}[10m])", VALIDATOR_WASTED_TXS.get_name_with_filter()),
         PanelType::TimeSeries,
     )
     .with_log_query("Finished building block as validator. Started executing")
@@ -29,7 +29,7 @@ fn get_panel_proposer_deferred_txs() -> Panel {
     Panel::new(
         "Proposal Build: Deferred TXs",
         "Number of txs started execution by the proposer but excluded from the block (10m window)",
-        vec![format!("increase({}[10m])", PROPOSER_DEFERRED_TXS.get_name_with_filter())],
+        format!("increase({}[10m])", PROPOSER_DEFERRED_TXS.get_name_with_filter()),
         PanelType::TimeSeries,
     )
     .with_log_query("Finished building block as proposer. Started executing")
@@ -39,7 +39,7 @@ fn get_panel_storage_height() -> Panel {
     Panel::new(
         "Storage Height",
         "The height of the batcher's storage",
-        vec![STORAGE_HEIGHT.get_name_with_filter().to_string()],
+        STORAGE_HEIGHT.get_name_with_filter().to_string(),
         PanelType::Stat,
     )
     .with_log_query("Committing block at height")
@@ -52,7 +52,7 @@ fn get_panel_rejection_reverted_ratio() -> Panel {
         REVERTED_TRANSACTIONS.get_name_with_filter(),
         BATCHED_TRANSACTIONS.get_name_with_filter(),
     );
-    Panel::new(
+    Panel::new_multi_expr(
         "Rejected / Reverted TXs Ratio",
         "Ratio of rejected / reverted transactions out of all processed txs (10m window)",
         vec![
@@ -75,7 +75,7 @@ pub(crate) fn get_panel_batched_transactions_rate() -> Panel {
     Panel::new(
         "Batched Transactions Rate (TPS)",
         "The rate of transactions batched by the Batcher (1m window)",
-        vec![format!("rate({}[1m])", BATCHED_TRANSACTIONS.get_name_with_filter())],
+        format!("rate({}[1m])", BATCHED_TRANSACTIONS.get_name_with_filter()),
         PanelType::TimeSeries,
     )
     .with_log_query("BATCHER_FIN_VALIDATOR")
@@ -85,11 +85,11 @@ fn get_panel_block_close_reasons() -> Panel {
     Panel::new(
         "Block Close Reasons",
         "Number of blocks closed by reason (10m window)",
-        vec![format!(
+        format!(
             "sum by ({}) (increase({}[10m]))",
             LABEL_NAME_BLOCK_CLOSE_REASON,
             BLOCK_CLOSE_REASON.get_name_with_filter()
-        )],
+        ),
         PanelType::Stat,
     )
     .with_log_query("\"Block builder deadline reached.\" OR \"Block is full.\"")
@@ -99,7 +99,7 @@ fn get_panel_num_batches_in_proposal() -> Panel {
     Panel::new(
         "Number of Chunks in Proposal",
         "The number of transaction batches received in a valid proposal",
-        vec![CONSENSUS_NUM_BATCHES_IN_PROPOSAL.get_name_with_filter().to_string()],
+        CONSENSUS_NUM_BATCHES_IN_PROPOSAL.get_name_with_filter().to_string(),
         PanelType::TimeSeries,
     )
 }
@@ -108,7 +108,7 @@ fn get_panel_num_txs_in_proposal() -> Panel {
     Panel::new(
         "Number of Transactions in Proposal",
         "The total number of individual transactions in a valid proposal received",
-        vec![CONSENSUS_NUM_TXS_IN_PROPOSAL.get_name_with_filter().to_string()],
+        CONSENSUS_NUM_TXS_IN_PROPOSAL.get_name_with_filter().to_string(),
         PanelType::TimeSeries,
     )
     .with_log_query("BATCHER_FIN_PROPOSER")

crates/apollo_dashboard/src/panels/blockifier.rs

@@ -66,11 +66,11 @@ fn get_panel_sierra_gas_in_last_block() -> Panel {
     Panel::new(
         "Average Sierra Gas Usage in Block",
         "The average sierra gas usage in block (10m window)",
-        vec![format!(
+        format!(
             "avg_over_time({}[10m])/{}",
             SIERRA_GAS_IN_LAST_BLOCK.get_name_with_filter(),
             DENOMINATOR_DIVISOR_FOR_READABILITY
-        )],
+        ),
         PanelType::TimeSeries,
     )
 }
@@ -79,11 +79,11 @@ fn get_panel_proving_gas_in_last_block() -> Panel {
     Panel::new(
         "Average Proving Gas Usage in Block",
         "The average proving gas usage in block (10m window)",
-        vec![format!(
+        format!(
             "avg_over_time({}[10m])/{}",
             PROVING_GAS_IN_LAST_BLOCK.get_name_with_filter(),
             DENOMINATOR_DIVISOR_FOR_READABILITY
-        )],
+        ),
         PanelType::TimeSeries,
     )
 }