fix(metrics): fix method name (#1129)

Signed-off-by: Shichao Nie <[email protected]>
AutoMQ · Apr 17, 2024 · c3463b4 · c3463b4
1 parent 20e630a
commit c3463b4
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/s3stream/src/main/java/com/automq/stream/s3/S3Stream.java b/s3stream/src/main/java/com/automq/stream/s3/S3Stream.java
@@ -347,8 +347,8 @@ public CompletableFuture<Void> close() {
                     LOGGER.info("{} closed", logIdent);
                     StreamOperationStats.getInstance().closeStreamStats(true).record(timerUtil.elapsedAs(TimeUnit.NANOSECONDS));
                 }
-                S3StreamMetricsManager.removePendingStreamAppendNumSupplier(streamId);
-                S3StreamMetricsManager.removePendingStreamFetchNumSupplier(streamId);
+                S3StreamMetricsManager.removePendingStreamAppendLatencySupplier(streamId);
+                S3StreamMetricsManager.removePendingStreamFetchLatencySupplier(streamId);
             });
 
             return closeCf;

diff --git a/s3stream/src/main/java/com/automq/stream/s3/metrics/S3StreamMetricsManager.java b/s3stream/src/main/java/com/automq/stream/s3/metrics/S3StreamMetricsManager.java
@@ -586,11 +586,11 @@ public static void registerPendingStreamFetchLatencySupplier(long streamId, Supp
         S3StreamMetricsManager.pendingStreamFetchLatencySupplier.put(streamId, pendingStreamFetchLatencySupplier);
     }
 
-    public static void removePendingStreamAppendNumSupplier(long streamId) {
+    public static void removePendingStreamAppendLatencySupplier(long streamId) {
         S3StreamMetricsManager.pendingStreamAppendLatencySupplier.remove(streamId);
     }
 
-    public static void removePendingStreamFetchNumSupplier(long streamId) {
+    public static void removePendingStreamFetchLatencySupplier(long streamId) {
         S3StreamMetricsManager.pendingStreamFetchLatencySupplier.remove(streamId);
     }