File tree 3 files changed +9
-3
lines changed
3 files changed +9
-3
lines changed Original file line number Diff line number Diff line change @@ -194,7 +194,7 @@ impl RelayStats {
194
194
195
195
metric ! (
196
196
gauge( RelayGauges :: AsyncPoolQueueSize ) = metrics. queue_size( ) ,
197
- pool_name = async_pool. name( )
197
+ pool = async_pool. name( )
198
198
) ;
199
199
metric ! (
200
200
gauge( RelayGauges :: AsyncPoolUtilization ) = metrics. utilization( ) as f64 ,
Original file line number Diff line number Diff line change @@ -7,11 +7,17 @@ pub enum RelayGauges {
7
7
/// Tracks the number of futures waiting to be executed in the pool's queue.
8
8
///
9
9
/// Useful for understanding the backlog of work and identifying potential bottlenecks.
10
+ ///
11
+ /// This metric is tagged with:
12
+ /// - `pool`: the name of the pool.
10
13
AsyncPoolQueueSize ,
11
14
/// Tracks the utilization of the async pool.
12
15
///
13
- /// The utilization is a value between 0.0 and 1 .0 which determines how busy is the pool
16
+ /// The utilization is a value between 0.0 and 100 .0 which determines how busy is the pool
14
17
/// w.r.t. to its provisioned capacity.
18
+ ///
19
+ /// This metric is tagged with:
20
+ /// - `pool`: the name of the pool.
15
21
AsyncPoolUtilization ,
16
22
/// The state of Relay with respect to the upstream connection.
17
23
/// Possible values are `0` for normal operations and `1` for a network outage.
Original file line number Diff line number Diff line change @@ -33,6 +33,6 @@ impl AsyncPoolMetrics<'_> {
33
33
. map ( |m| m. active_tasks . load ( Ordering :: Relaxed ) )
34
34
. sum ( ) ;
35
35
36
- ( total_polled_futures as f32 / self . max_tasks as f32 ) . clamp ( 0.0 , 1.0 )
36
+ ( total_polled_futures as f32 / self . max_tasks as f32 ) . clamp ( 0.0 , 1.0 ) * 100.0
37
37
}
38
38
}
You can’t perform that action at this time.
0 commit comments