File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -163,12 +163,12 @@ metrics_group!(
163163
164164 #[ name = spacetime_subscription_lock_num_waiters]
165165 #[ help = "The number of clients waiting to acquire the subscription lock" ]
166- #[ labels( db: Identity ) ]
166+ #[ labels( db: Identity , workload : WorkloadType ) ]
167167 pub subscription_lock_waiters: IntGaugeVec ,
168168
169169 #[ name = spacetime_subscription_lock_wait_time_sec]
170170 #[ help = "How much time (in seconds) do we spend waiting to acquire the subscription lock" ]
171- #[ labels( db: Identity ) ]
171+ #[ labels( db: Identity , workload : WorkloadType ) ]
172172 pub subscription_lock_wait_time: HistogramVec ,
173173
174174 #[ name = spacetime_num_queries_subscribed]
Original file line number Diff line number Diff line change @@ -113,8 +113,8 @@ pub struct SubscriptionMetrics {
113113impl SubscriptionMetrics {
114114 pub fn new ( db : & Identity , workload : & WorkloadType ) -> Self {
115115 Self {
116- lock_waiters : DB_METRICS . subscription_lock_waiters . with_label_values ( db) ,
117- lock_wait_time : DB_METRICS . subscription_lock_wait_time . with_label_values ( db) ,
116+ lock_waiters : DB_METRICS . subscription_lock_waiters . with_label_values ( db, workload ) ,
117+ lock_wait_time : DB_METRICS . subscription_lock_wait_time . with_label_values ( db, workload ) ,
118118 compilation_time : DB_METRICS . subscription_compile_time . with_label_values ( db, workload) ,
119119 num_queries_subscribed : DB_METRICS . num_queries_subscribed . with_label_values ( db) ,
120120 num_new_queries_subscribed : DB_METRICS . num_new_queries_subscribed . with_label_values ( db) ,
You can’t perform that action at this time.
0 commit comments