@@ -306,7 +306,7 @@ where
306306 connection_id = %info. conn_id,
307307 worker_id = %this. id,
308308 latency_total = ( UtcDateTime :: now( ) - timestamp) . as_seconds_f64( ) ,
309- "Receiving an http request..." ,
309+ "Receiving http request..." ,
310310 ) ;
311311
312312 let metrics = this. shared . metrics . clone ( ) ;
@@ -374,7 +374,7 @@ where
374374 worker_id = %this. id,
375375 backend_url = %this. backend. url,
376376 latency_total = ( UtcDateTime :: now( ) - timestamp) . as_seconds_f64( ) ,
377- "Streaming an http request to the backend..." ,
377+ "Streaming http request to backend..." ,
378378 ) ;
379379
380380 let bknd_res = match bknd_req. send_stream ( bknd_req_body) . await {
@@ -439,7 +439,7 @@ where
439439 connection_id = %info. conn_id,
440440 worker_id = %this. id,
441441 latency_total = ( UtcDateTime :: now( ) - timestamp) . as_seconds_f64( ) ,
442- "Sending to an http request to the backend..." ,
442+ "Sending http request to backend..." ,
443443 ) ;
444444
445445 let body =
@@ -496,7 +496,7 @@ where
496496 connection_id = %info. conn_id,
497497 worker_id = %this. id,
498498 latency_total = ( UtcDateTime :: now( ) - timestamp) . as_seconds_f64( ) ,
499- "Got http response from the backend" ,
499+ "Got http response from backend" ,
500500 ) ;
501501
502502 let ( decompressed_body, decompressed_size) =
@@ -627,6 +627,15 @@ where
627627 timestamp,
628628 ) ;
629629
630+ debug ! (
631+ proxy = P :: name( ) ,
632+ request_id = %req_id,
633+ connection_id = %conn_id,
634+ worker_id = %bknd_res_body. proxy. id,
635+ latency_total = ( UtcDateTime :: now( ) - timestamp) . as_seconds_f64( ) ,
636+ "Sending http response to client..." ,
637+ ) ;
638+
630639 Ok ( clnt_res. streaming ( bknd_res_body) )
631640 }
632641
0 commit comments