@@ -34,11 +34,11 @@ public async Task Metrics_Rejected()
34
34
35
35
var context = new DefaultHttpContext ( ) ;
36
36
37
- using var leaseRequestDurationRecorder = new InstrumentRecorder < double > ( meterFactory , RateLimitingMetrics . MeterName , "leased-request-duration" ) ;
38
- using var currentLeaseRequestsRecorder = new InstrumentRecorder < long > ( meterFactory , RateLimitingMetrics . MeterName , "current-leased-requests" ) ;
39
- using var currentRequestsQueuedRecorder = new InstrumentRecorder < long > ( meterFactory , RateLimitingMetrics . MeterName , "current-queued-requests" ) ;
40
- using var queuedRequestDurationRecorder = new InstrumentRecorder < double > ( meterFactory , RateLimitingMetrics . MeterName , "queued-request-duration" ) ;
41
- using var leaseFailedRequestsRecorder = new InstrumentRecorder < long > ( meterFactory , RateLimitingMetrics . MeterName , "lease-failed-requests" ) ;
37
+ using var leaseRequestDurationRecorder = new InstrumentRecorder < double > ( meterFactory , RateLimitingMetrics . MeterName , "rate-limiting- leased-request-duration" ) ;
38
+ using var currentLeaseRequestsRecorder = new InstrumentRecorder < long > ( meterFactory , RateLimitingMetrics . MeterName , "rate-limiting- current-leased-requests" ) ;
39
+ using var currentRequestsQueuedRecorder = new InstrumentRecorder < long > ( meterFactory , RateLimitingMetrics . MeterName , "rate-limiting- current-queued-requests" ) ;
40
+ using var queuedRequestDurationRecorder = new InstrumentRecorder < double > ( meterFactory , RateLimitingMetrics . MeterName , "rate-limiting- queued-request-duration" ) ;
41
+ using var leaseFailedRequestsRecorder = new InstrumentRecorder < long > ( meterFactory , RateLimitingMetrics . MeterName , "rate-limiting- lease-failed-requests" ) ;
42
42
43
43
// Act
44
44
await middleware . Invoke ( context ) . DefaultTimeout ( ) ;
@@ -81,11 +81,11 @@ public async Task Metrics_Success()
81
81
var context = new DefaultHttpContext ( ) ;
82
82
context . Request . Method = "GET" ;
83
83
84
- using var leaseRequestDurationRecorder = new InstrumentRecorder < double > ( meterFactory , RateLimitingMetrics . MeterName , "leased-request-duration" ) ;
85
- using var currentLeaseRequestsRecorder = new InstrumentRecorder < long > ( meterFactory , RateLimitingMetrics . MeterName , "current-leased-requests" ) ;
86
- using var currentRequestsQueuedRecorder = new InstrumentRecorder < long > ( meterFactory , RateLimitingMetrics . MeterName , "current-queued-requests" ) ;
87
- using var queuedRequestDurationRecorder = new InstrumentRecorder < double > ( meterFactory , RateLimitingMetrics . MeterName , "queued-request-duration" ) ;
88
- using var leaseFailedRequestsRecorder = new InstrumentRecorder < long > ( meterFactory , RateLimitingMetrics . MeterName , "lease-failed-requests" ) ;
84
+ using var leaseRequestDurationRecorder = new InstrumentRecorder < double > ( meterFactory , RateLimitingMetrics . MeterName , "rate-limiting- leased-request-duration" ) ;
85
+ using var currentLeaseRequestsRecorder = new InstrumentRecorder < long > ( meterFactory , RateLimitingMetrics . MeterName , "rate-limiting- current-leased-requests" ) ;
86
+ using var currentRequestsQueuedRecorder = new InstrumentRecorder < long > ( meterFactory , RateLimitingMetrics . MeterName , "rate-limiting- current-queued-requests" ) ;
87
+ using var queuedRequestDurationRecorder = new InstrumentRecorder < double > ( meterFactory , RateLimitingMetrics . MeterName , "rate-limiting- queued-request-duration" ) ;
88
+ using var leaseFailedRequestsRecorder = new InstrumentRecorder < long > ( meterFactory , RateLimitingMetrics . MeterName , "rate-limiting- lease-failed-requests" ) ;
89
89
90
90
// Act
91
91
var middlewareTask = middleware . Invoke ( context ) ;
@@ -141,11 +141,11 @@ public async Task Metrics_ListenInMiddleOfRequest_CurrentLeasesNotDecreased()
141
141
142
142
await syncPoint . WaitForSyncPoint ( ) . DefaultTimeout ( ) ;
143
143
144
- using var leaseRequestDurationRecorder = new InstrumentRecorder < double > ( meterFactory , RateLimitingMetrics . MeterName , "leased-request-duration" ) ;
145
- using var currentLeaseRequestsRecorder = new InstrumentRecorder < long > ( meterFactory , RateLimitingMetrics . MeterName , "current-leased-requests" ) ;
146
- using var currentRequestsQueuedRecorder = new InstrumentRecorder < long > ( meterFactory , RateLimitingMetrics . MeterName , "current-queued-requests" ) ;
147
- using var queuedRequestDurationRecorder = new InstrumentRecorder < double > ( meterFactory , RateLimitingMetrics . MeterName , "queued-request-duration" ) ;
148
- using var leaseFailedRequestsRecorder = new InstrumentRecorder < long > ( meterFactory , RateLimitingMetrics . MeterName , "lease-failed-requests" ) ;
144
+ using var leaseRequestDurationRecorder = new InstrumentRecorder < double > ( meterFactory , RateLimitingMetrics . MeterName , "rate-limiting- leased-request-duration" ) ;
145
+ using var currentLeaseRequestsRecorder = new InstrumentRecorder < long > ( meterFactory , RateLimitingMetrics . MeterName , "rate-limiting- current-leased-requests" ) ;
146
+ using var currentRequestsQueuedRecorder = new InstrumentRecorder < long > ( meterFactory , RateLimitingMetrics . MeterName , "rate-limiting- current-queued-requests" ) ;
147
+ using var queuedRequestDurationRecorder = new InstrumentRecorder < double > ( meterFactory , RateLimitingMetrics . MeterName , "rate-limiting- queued-request-duration" ) ;
148
+ using var leaseFailedRequestsRecorder = new InstrumentRecorder < long > ( meterFactory , RateLimitingMetrics . MeterName , "rate-limiting- lease-failed-requests" ) ;
149
149
150
150
syncPoint . Continue ( ) ;
151
151
@@ -192,11 +192,11 @@ public async Task Metrics_Queued()
192
192
routeEndpointBuilder . Metadata . Add ( new EnableRateLimitingAttribute ( "concurrencyPolicy" ) ) ;
193
193
var endpoint = routeEndpointBuilder . Build ( ) ;
194
194
195
- using var leaseRequestDurationRecorder = new InstrumentRecorder < double > ( meterFactory , RateLimitingMetrics . MeterName , "leased-request-duration" ) ;
196
- using var currentLeaseRequestsRecorder = new InstrumentRecorder < long > ( meterFactory , RateLimitingMetrics . MeterName , "current-leased-requests" ) ;
197
- using var currentRequestsQueuedRecorder = new InstrumentRecorder < long > ( meterFactory , RateLimitingMetrics . MeterName , "current-queued-requests" ) ;
198
- using var queuedRequestDurationRecorder = new InstrumentRecorder < double > ( meterFactory , RateLimitingMetrics . MeterName , "queued-request-duration" ) ;
199
- using var leaseFailedRequestsRecorder = new InstrumentRecorder < long > ( meterFactory , RateLimitingMetrics . MeterName , "lease-failed-requests" ) ;
195
+ using var leaseRequestDurationRecorder = new InstrumentRecorder < double > ( meterFactory , RateLimitingMetrics . MeterName , "rate-limiting- leased-request-duration" ) ;
196
+ using var currentLeaseRequestsRecorder = new InstrumentRecorder < long > ( meterFactory , RateLimitingMetrics . MeterName , "rate-limiting- current-leased-requests" ) ;
197
+ using var currentRequestsQueuedRecorder = new InstrumentRecorder < long > ( meterFactory , RateLimitingMetrics . MeterName , "rate-limiting- current-queued-requests" ) ;
198
+ using var queuedRequestDurationRecorder = new InstrumentRecorder < double > ( meterFactory , RateLimitingMetrics . MeterName , "rate-limiting- queued-request-duration" ) ;
199
+ using var leaseFailedRequestsRecorder = new InstrumentRecorder < long > ( meterFactory , RateLimitingMetrics . MeterName , "rate-limiting- lease-failed-requests" ) ;
200
200
201
201
// Act
202
202
var context1 = new DefaultHttpContext ( ) ;
@@ -279,11 +279,11 @@ public async Task Metrics_ListenInMiddleOfQueued_CurrentQueueNotDecreased()
279
279
280
280
// Start listening while the second request is queued.
281
281
282
- using var leaseRequestDurationRecorder = new InstrumentRecorder < double > ( meterFactory , RateLimitingMetrics . MeterName , "leased-request-duration" ) ;
283
- using var currentLeaseRequestsRecorder = new InstrumentRecorder < long > ( meterFactory , RateLimitingMetrics . MeterName , "current-leased-requests" ) ;
284
- using var currentRequestsQueuedRecorder = new InstrumentRecorder < long > ( meterFactory , RateLimitingMetrics . MeterName , "current-queued-requests" ) ;
285
- using var queuedRequestDurationRecorder = new InstrumentRecorder < double > ( meterFactory , RateLimitingMetrics . MeterName , "queued-request-duration" ) ;
286
- using var leaseFailedRequestsRecorder = new InstrumentRecorder < long > ( meterFactory , RateLimitingMetrics . MeterName , "lease-failed-requests" ) ;
282
+ using var leaseRequestDurationRecorder = new InstrumentRecorder < double > ( meterFactory , RateLimitingMetrics . MeterName , "rate-limiting- leased-request-duration" ) ;
283
+ using var currentLeaseRequestsRecorder = new InstrumentRecorder < long > ( meterFactory , RateLimitingMetrics . MeterName , "rate-limiting- current-leased-requests" ) ;
284
+ using var currentRequestsQueuedRecorder = new InstrumentRecorder < long > ( meterFactory , RateLimitingMetrics . MeterName , "rate-limiting- current-queued-requests" ) ;
285
+ using var queuedRequestDurationRecorder = new InstrumentRecorder < double > ( meterFactory , RateLimitingMetrics . MeterName , "rate-limiting- queued-request-duration" ) ;
286
+ using var leaseFailedRequestsRecorder = new InstrumentRecorder < long > ( meterFactory , RateLimitingMetrics . MeterName , "rate-limiting- lease-failed-requests" ) ;
287
287
288
288
Assert . Empty ( currentRequestsQueuedRecorder . GetMeasurements ( ) ) ;
289
289
Assert . Empty ( queuedRequestDurationRecorder . GetMeasurements ( ) ) ;
0 commit comments