From 76c744df122aa7b418b02d2be52be7277d3b87c6 Mon Sep 17 00:00:00 2001
From: YangKian <45479280+YangKian@users.noreply.github.com>
Date: Tue, 9 Jul 2024 17:52:23 +0800
Subject: [PATCH] fix: fix append latency command (#36)

---
 collector/stream.go | 2 +-
 scraper/scraper.go  | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/collector/stream.go b/collector/stream.go
index b2fd69d..3aa1dc7 100644
--- a/collector/stream.go
+++ b/collector/stream.go
@@ -50,7 +50,7 @@ func NewStreamMetrics() *StreamMetrics {
 		Type: scraper.StreamAppendLatency,
 		Metric: prometheus.NewDesc(
 			prometheus.BuildFQName(namespace, streamSubsystem, scraper.StreamAppendLatency.String()),
-			"Append request latency.",
+			"Append stream latency.",
 			[]string{"server_host"}, nil,
 		),
 	}
diff --git a/scraper/scraper.go b/scraper/scraper.go
index 66b8d25..85e7e71 100644
--- a/scraper/scraper.go
+++ b/scraper/scraper.go
@@ -159,7 +159,7 @@ func (s *Scraper) scrapeSummary(wg *sync.WaitGroup, target string, metrics map[S
 func getSummaryStatsCmd(stat StatType) string {
 	switch stat {
 	case StreamAppendLatency:
-		return fmt.Sprintf(getStatsCmd, "server_histogram", "append_request_latency", summaryStatInterval)
+		return fmt.Sprintf(getStatsCmd, "server_histogram", "append_latency", summaryStatInterval)
 	case StreamReadLatency:
 		return fmt.Sprintf(getStatsCmd, "server_histogram", "read_latency", summaryStatInterval)
 	case CacheStoreAppendLatency: