@@ -120,7 +120,7 @@ mod handlers {
120
120
metrics_service : Arc < MetricsService > ,
121
121
) -> Result < impl warp:: Reply , Infallible > {
122
122
metrics_service
123
- . get_cardano_database_immutable_files_restored ( )
123
+ . get_cardano_database_immutable_files_restored_since_startup ( )
124
124
. increment_by ( message. nb_immutable_files ) ;
125
125
126
126
Ok ( reply:: empty ( StatusCode :: CREATED ) )
@@ -131,7 +131,7 @@ mod handlers {
131
131
metrics_service : Arc < MetricsService > ,
132
132
) -> Result < impl warp:: Reply , Infallible > {
133
133
metrics_service
134
- . get_cardano_database_ancillary_files_restored ( )
134
+ . get_cardano_database_ancillary_files_restored_since_startup ( )
135
135
. increment ( ) ;
136
136
137
137
Ok ( reply:: empty ( StatusCode :: CREATED ) )
@@ -143,14 +143,14 @@ mod handlers {
143
143
metrics_service : Arc < MetricsService > ,
144
144
) -> Result < impl warp:: Reply , Infallible > {
145
145
metrics_service
146
- . get_cardano_database_complete_restoration ( )
146
+ . get_cardano_database_complete_restoration_since_startup ( )
147
147
. increment ( ) ;
148
148
149
149
let headers: Vec < ( & str , & str ) > = Vec :: new ( ) ;
150
150
let message = EventMessage :: new (
151
151
"HTTP::statistics" ,
152
152
"cardano_database_restoration" ,
153
- & "full " . to_string ( ) ,
153
+ & "complete " . to_string ( ) ,
154
154
headers,
155
155
) ;
156
156
@@ -168,7 +168,7 @@ mod handlers {
168
168
metrics_service : Arc < MetricsService > ,
169
169
) -> Result < impl warp:: Reply , Infallible > {
170
170
metrics_service
171
- . get_cardano_database_partial_restoration ( )
171
+ . get_cardano_database_partial_restoration_since_startup ( )
172
172
. increment ( ) ;
173
173
174
174
let headers: Vec < ( & str , & str ) > = Vec :: new ( ) ;
@@ -323,7 +323,7 @@ mod tests {
323
323
let dependency_manager = Arc :: new ( initialize_dependencies ( ) . await ) ;
324
324
let metric_counter = dependency_manager
325
325
. metrics_service
326
- . get_cardano_database_immutable_files_restored ( ) ;
326
+ . get_cardano_database_immutable_files_restored_since_startup ( ) ;
327
327
let message = CardanoDatabaseImmutableFilesRestoredMessage {
328
328
nb_immutable_files : 3 ,
329
329
} ;
@@ -379,7 +379,7 @@ mod tests {
379
379
let dependency_manager = Arc :: new ( initialize_dependencies ( ) . await ) ;
380
380
let metric_counter = dependency_manager
381
381
. metrics_service
382
- . get_cardano_database_ancillary_files_restored ( ) ;
382
+ . get_cardano_database_ancillary_files_restored_since_startup ( ) ;
383
383
384
384
let initial_counter_value = metric_counter. get ( ) ;
385
385
@@ -478,15 +478,15 @@ mod tests {
478
478
let message = rx. try_recv ( ) . unwrap ( ) ;
479
479
assert_eq ! ( "HTTP::statistics" , message. source) ;
480
480
assert_eq ! ( "cardano_database_restoration" , message. action) ;
481
- assert_eq ! ( "full " , message. content) ;
481
+ assert_eq ! ( "complete " , message. content) ;
482
482
}
483
483
484
484
#[ tokio:: test]
485
485
async fn increments_metric ( ) {
486
486
let ( dependency_manager, _rx) = setup_dependencies ( ) . await ;
487
487
let metric_counter = dependency_manager
488
488
. metrics_service
489
- . get_cardano_database_complete_restoration ( ) ;
489
+ . get_cardano_database_complete_restoration_since_startup ( ) ;
490
490
491
491
let initial_counter_value = metric_counter. get ( ) ;
492
492
@@ -584,7 +584,7 @@ mod tests {
584
584
let ( dependency_manager, _rx) = setup_dependencies ( ) . await ;
585
585
let metric_counter = dependency_manager
586
586
. metrics_service
587
- . get_cardano_database_partial_restoration ( ) ;
587
+ . get_cardano_database_partial_restoration_since_startup ( ) ;
588
588
589
589
let initial_counter_value = metric_counter. get ( ) ;
590
590
0 commit comments