Skip to content

Commit 1b40c54

Browse files
committed
Refactor request_size and response_size for grpc requester
1 parent 85e4b59 commit 1b40c54

File tree

1 file changed

+3
-8
lines changed

1 file changed

+3
-8
lines changed

src/requester/grpc_requester.rs

Lines changed: 3 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -178,16 +178,11 @@ impl<'a> Requester for GrpcRequester<'a> {
178178

179179
let req_duration = start.elapsed();
180180

181-
// calculate request size
182-
let encoded = req_msg.encode_to_vec();
183-
let request_size = encoded.len();
184-
185-
// calculate response size
186-
let encoded_resp = response.get_ref().encode_to_vec();
187-
let response_size = encoded_resp.len();
181+
let request_size = req_msg.encode_to_vec().len();
182+
self.metrics.add_bytes_sent(request_size as u64).await;
188183

184+
let response_size = response.get_ref().encode_to_vec().len();
189185
self.metrics.add_bytes_received(response_size as u64).await;
190-
self.metrics.add_bytes_sent(request_size as u64).await;
191186

192187
self.metrics
193188
.record_latency(req_duration.as_micros().try_into().unwrap_or(0))

0 commit comments

Comments
 (0)