From 0859aa898ce50def1038944871e14ed35673d96c Mon Sep 17 00:00:00 2001
From: Shichao Nie <niesc@automq.com>
Date: Thu, 16 May 2024 14:34:03 +0800
Subject: [PATCH] fix(s3stream): add missing metrics record

Signed-off-by: Shichao Nie <niesc@automq.com>
---
 s3stream/src/main/java/com/automq/stream/s3/S3Stream.java | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/s3stream/src/main/java/com/automq/stream/s3/S3Stream.java b/s3stream/src/main/java/com/automq/stream/s3/S3Stream.java
index e1eb0835e0..3094263bbc 100644
--- a/s3stream/src/main/java/com/automq/stream/s3/S3Stream.java
+++ b/s3stream/src/main/java/com/automq/stream/s3/S3Stream.java
@@ -218,7 +218,10 @@ public CompletableFuture<FetchResult> fetch(FetchContext context,
                         networkOutboundLimiter.forceConsume(totalSize);
                         NetworkStats.getInstance().fastReadBytesStats(streamId).ifPresent(counter -> counter.inc(finalSize));
                     } else {
+                        TimerUtil consumeTimer = new TimerUtil();
                         return networkOutboundLimiter.consume(ThrottleStrategy.CATCH_UP, totalSize).thenApply(nil -> {
+                            NetworkStats.getInstance().networkLimiterQueueTimeStats(AsyncNetworkBandwidthLimiter.Type.OUTBOUND, ThrottleStrategy.CATCH_UP)
+                                    .record(consumeTimer.elapsedAs(TimeUnit.NANOSECONDS));
                             NetworkStats.getInstance().slowReadBytesStats(streamId).ifPresent(counter -> counter.inc(finalSize));
                             return rs;
                         });