use more sugar

Signed-off-by: Bugen Zhao <[email protected]>

Author: BugenZhao

grafana/risingwave-dev-dashboard.dashboard.py

@@ -1122,6 +1122,8 @@ def section_streaming_cdc(outer_panels):
 
 
 def section_streaming_actors(outer_panels: Panels):
+    # The actor_id can be masked due to metrics level settings.
+    # We use this filter to suppress the actor-level panels if applicable.
     actor_level_filter = "actor_id!=''"
     panels = outer_panels.sub_panel()
     return [

src/stream/src/executor/monitor/streaming_stats.rs

@@ -397,27 +397,17 @@ impl StreamingMetrics {
             &["actor_id", "fragment_id", "upstream_fragment_id"],
             registry
         )
-        .unwrap();
-        let actor_in_record_cnt = RelabeledGuardedIntCounterVec::with_metric_level_relabel_n(
-            MetricLevel::Debug,
-            actor_in_record_cnt,
-            level,
-            1,
-        );
+        .unwrap()
+        .relabel_debug_1(level);
 
         let actor_out_record_cnt = register_guarded_int_counter_vec_with_registry!(
             "stream_actor_out_record_cnt",
             "Total number of rows actor sent",
             &["actor_id", "fragment_id"],
             registry
         )
-        .unwrap();
-        let actor_out_record_cnt = RelabeledGuardedIntCounterVec::with_metric_level_relabel_n(
-            MetricLevel::Debug,
-            actor_out_record_cnt,
-            level,
-            1,
-        );
+        .unwrap()
+        .relabel_debug_1(level);
 
         let actor_count = register_guarded_int_gauge_vec_with_registry!(
             "stream_actor_count",