@@ -35,11 +35,11 @@ public async Task Metrics_Rejected()
35
35
36
36
var context = new DefaultHttpContext ( ) ;
37
37
38
- using var leaseRequestDurationRecorder = new InstrumentRecorder < double > ( meterRegistry , RateLimitingMetrics . MeterName , "leased-request-duration" ) ;
39
- using var currentLeaseRequestsRecorder = new InstrumentRecorder < long > ( meterRegistry , RateLimitingMetrics . MeterName , "current-leased-requests" ) ;
40
- using var currentRequestsQueuedRecorder = new InstrumentRecorder < long > ( meterRegistry , RateLimitingMetrics . MeterName , "current-queued-requests" ) ;
41
- using var queuedRequestDurationRecorder = new InstrumentRecorder < double > ( meterRegistry , RateLimitingMetrics . MeterName , "queued-request-duration" ) ;
42
- using var leaseFailedRequestsRecorder = new InstrumentRecorder < long > ( meterRegistry , RateLimitingMetrics . MeterName , "lease-failed-requests" ) ;
38
+ using var leaseRequestDurationRecorder = new InstrumentRecorder < double > ( meterRegistry , RateLimitingMetrics . MeterName , "rate-limiting- leased-request-duration" ) ;
39
+ using var currentLeaseRequestsRecorder = new InstrumentRecorder < long > ( meterRegistry , RateLimitingMetrics . MeterName , "rate-limiting- current-leased-requests" ) ;
40
+ using var currentRequestsQueuedRecorder = new InstrumentRecorder < long > ( meterRegistry , RateLimitingMetrics . MeterName , "rate-limiting- current-queued-requests" ) ;
41
+ using var queuedRequestDurationRecorder = new InstrumentRecorder < double > ( meterRegistry , RateLimitingMetrics . MeterName , "rate-limiting- queued-request-duration" ) ;
42
+ using var leaseFailedRequestsRecorder = new InstrumentRecorder < long > ( meterRegistry , RateLimitingMetrics . MeterName , "rate-limiting- lease-failed-requests" ) ;
43
43
44
44
// Act
45
45
await middleware . Invoke ( context ) . DefaultTimeout ( ) ;
@@ -83,11 +83,11 @@ public async Task Metrics_Success()
83
83
var context = new DefaultHttpContext ( ) ;
84
84
context . Request . Method = "GET" ;
85
85
86
- using var leaseRequestDurationRecorder = new InstrumentRecorder < double > ( meterRegistry , RateLimitingMetrics . MeterName , "leased-request-duration" ) ;
87
- using var currentLeaseRequestsRecorder = new InstrumentRecorder < long > ( meterRegistry , RateLimitingMetrics . MeterName , "current-leased-requests" ) ;
88
- using var currentRequestsQueuedRecorder = new InstrumentRecorder < long > ( meterRegistry , RateLimitingMetrics . MeterName , "current-queued-requests" ) ;
89
- using var queuedRequestDurationRecorder = new InstrumentRecorder < double > ( meterRegistry , RateLimitingMetrics . MeterName , "queued-request-duration" ) ;
90
- using var leaseFailedRequestsRecorder = new InstrumentRecorder < long > ( meterRegistry , RateLimitingMetrics . MeterName , "lease-failed-requests" ) ;
86
+ using var leaseRequestDurationRecorder = new InstrumentRecorder < double > ( meterRegistry , RateLimitingMetrics . MeterName , "rate-limiting- leased-request-duration" ) ;
87
+ using var currentLeaseRequestsRecorder = new InstrumentRecorder < long > ( meterRegistry , RateLimitingMetrics . MeterName , "rate-limiting- current-leased-requests" ) ;
88
+ using var currentRequestsQueuedRecorder = new InstrumentRecorder < long > ( meterRegistry , RateLimitingMetrics . MeterName , "rate-limiting- current-queued-requests" ) ;
89
+ using var queuedRequestDurationRecorder = new InstrumentRecorder < double > ( meterRegistry , RateLimitingMetrics . MeterName , "rate-limiting- queued-request-duration" ) ;
90
+ using var leaseFailedRequestsRecorder = new InstrumentRecorder < long > ( meterRegistry , RateLimitingMetrics . MeterName , "rate-limiting- lease-failed-requests" ) ;
91
91
92
92
// Act
93
93
var middlewareTask = middleware . Invoke ( context ) ;
@@ -144,11 +144,11 @@ public async Task Metrics_ListenInMiddleOfRequest_CurrentLeasesNotDecreased()
144
144
145
145
await syncPoint . WaitForSyncPoint ( ) . DefaultTimeout ( ) ;
146
146
147
- using var leaseRequestDurationRecorder = new InstrumentRecorder < double > ( meterRegistry , RateLimitingMetrics . MeterName , "leased-request-duration" ) ;
148
- using var currentLeaseRequestsRecorder = new InstrumentRecorder < long > ( meterRegistry , RateLimitingMetrics . MeterName , "current-leased-requests" ) ;
149
- using var currentRequestsQueuedRecorder = new InstrumentRecorder < long > ( meterRegistry , RateLimitingMetrics . MeterName , "current-queued-requests" ) ;
150
- using var queuedRequestDurationRecorder = new InstrumentRecorder < double > ( meterRegistry , RateLimitingMetrics . MeterName , "queued-request-duration" ) ;
151
- using var leaseFailedRequestsRecorder = new InstrumentRecorder < long > ( meterRegistry , RateLimitingMetrics . MeterName , "lease-failed-requests" ) ;
147
+ using var leaseRequestDurationRecorder = new InstrumentRecorder < double > ( meterRegistry , RateLimitingMetrics . MeterName , "rate-limiting- leased-request-duration" ) ;
148
+ using var currentLeaseRequestsRecorder = new InstrumentRecorder < long > ( meterRegistry , RateLimitingMetrics . MeterName , "rate-limiting- current-leased-requests" ) ;
149
+ using var currentRequestsQueuedRecorder = new InstrumentRecorder < long > ( meterRegistry , RateLimitingMetrics . MeterName , "rate-limiting- current-queued-requests" ) ;
150
+ using var queuedRequestDurationRecorder = new InstrumentRecorder < double > ( meterRegistry , RateLimitingMetrics . MeterName , "rate-limiting- queued-request-duration" ) ;
151
+ using var leaseFailedRequestsRecorder = new InstrumentRecorder < long > ( meterRegistry , RateLimitingMetrics . MeterName , "rate-limiting- lease-failed-requests" ) ;
152
152
153
153
syncPoint . Continue ( ) ;
154
154
@@ -196,11 +196,11 @@ public async Task Metrics_Queued()
196
196
routeEndpointBuilder . Metadata . Add ( new EnableRateLimitingAttribute ( "concurrencyPolicy" ) ) ;
197
197
var endpoint = routeEndpointBuilder . Build ( ) ;
198
198
199
- using var leaseRequestDurationRecorder = new InstrumentRecorder < double > ( meterRegistry , RateLimitingMetrics . MeterName , "leased-request-duration" ) ;
200
- using var currentLeaseRequestsRecorder = new InstrumentRecorder < long > ( meterRegistry , RateLimitingMetrics . MeterName , "current-leased-requests" ) ;
201
- using var currentRequestsQueuedRecorder = new InstrumentRecorder < long > ( meterRegistry , RateLimitingMetrics . MeterName , "current-queued-requests" ) ;
202
- using var queuedRequestDurationRecorder = new InstrumentRecorder < double > ( meterRegistry , RateLimitingMetrics . MeterName , "queued-request-duration" ) ;
203
- using var leaseFailedRequestsRecorder = new InstrumentRecorder < long > ( meterRegistry , RateLimitingMetrics . MeterName , "lease-failed-requests" ) ;
199
+ using var leaseRequestDurationRecorder = new InstrumentRecorder < double > ( meterRegistry , RateLimitingMetrics . MeterName , "rate-limiting- leased-request-duration" ) ;
200
+ using var currentLeaseRequestsRecorder = new InstrumentRecorder < long > ( meterRegistry , RateLimitingMetrics . MeterName , "rate-limiting- current-leased-requests" ) ;
201
+ using var currentRequestsQueuedRecorder = new InstrumentRecorder < long > ( meterRegistry , RateLimitingMetrics . MeterName , "rate-limiting- current-queued-requests" ) ;
202
+ using var queuedRequestDurationRecorder = new InstrumentRecorder < double > ( meterRegistry , RateLimitingMetrics . MeterName , "rate-limiting- queued-request-duration" ) ;
203
+ using var leaseFailedRequestsRecorder = new InstrumentRecorder < long > ( meterRegistry , RateLimitingMetrics . MeterName , "rate-limiting- lease-failed-requests" ) ;
204
204
205
205
// Act
206
206
var context1 = new DefaultHttpContext ( ) ;
@@ -284,11 +284,11 @@ public async Task Metrics_ListenInMiddleOfQueued_CurrentQueueNotDecreased()
284
284
285
285
// Start listening while the second request is queued.
286
286
287
- using var leaseRequestDurationRecorder = new InstrumentRecorder < double > ( meterRegistry , RateLimitingMetrics . MeterName , "leased-request-duration" ) ;
288
- using var currentLeaseRequestsRecorder = new InstrumentRecorder < long > ( meterRegistry , RateLimitingMetrics . MeterName , "current-leased-requests" ) ;
289
- using var currentRequestsQueuedRecorder = new InstrumentRecorder < long > ( meterRegistry , RateLimitingMetrics . MeterName , "current-queued-requests" ) ;
290
- using var queuedRequestDurationRecorder = new InstrumentRecorder < double > ( meterRegistry , RateLimitingMetrics . MeterName , "queued-request-duration" ) ;
291
- using var leaseFailedRequestsRecorder = new InstrumentRecorder < long > ( meterRegistry , RateLimitingMetrics . MeterName , "lease-failed-requests" ) ;
287
+ using var leaseRequestDurationRecorder = new InstrumentRecorder < double > ( meterRegistry , RateLimitingMetrics . MeterName , "rate-limiting- leased-request-duration" ) ;
288
+ using var currentLeaseRequestsRecorder = new InstrumentRecorder < long > ( meterRegistry , RateLimitingMetrics . MeterName , "rate-limiting- current-leased-requests" ) ;
289
+ using var currentRequestsQueuedRecorder = new InstrumentRecorder < long > ( meterRegistry , RateLimitingMetrics . MeterName , "rate-limiting- current-queued-requests" ) ;
290
+ using var queuedRequestDurationRecorder = new InstrumentRecorder < double > ( meterRegistry , RateLimitingMetrics . MeterName , "rate-limiting- queued-request-duration" ) ;
291
+ using var leaseFailedRequestsRecorder = new InstrumentRecorder < long > ( meterRegistry , RateLimitingMetrics . MeterName , "rate-limiting- lease-failed-requests" ) ;
292
292
293
293
Assert . Empty ( currentRequestsQueuedRecorder . GetMeasurements ( ) ) ;
294
294
Assert . Empty ( queuedRequestDurationRecorder . GetMeasurements ( ) ) ;
0 commit comments