This is an automated email from the ASF dual-hosted git repository.
laiyingchun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
The following commit(s) were added to refs/heads/master by this push:
new f61bb0f66 fix(collector): fix the parsing way of metrics returned by
the server (#1855)
f61bb0f66 is described below
commit f61bb0f667c3cd398f65651d6902671a7bd94975
Author: Wang Guangshuo <[email protected]>
AuthorDate: Wed Jan 17 11:12:46 2024 +0800
fix(collector): fix the parsing way of metrics returned by the server
(#1855)
---
collector/metrics/metric_collector.go | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/collector/metrics/metric_collector.go
b/collector/metrics/metric_collector.go
index 0c3d1de0b..f3c47785e 100644
--- a/collector/metrics/metric_collector.go
+++ b/collector/metrics/metric_collector.go
@@ -73,8 +73,8 @@ func NewMetricCollector(
SummaryMetricsMap = make(map[string]prometheus.Summary, 128)
RoleByDataSource = make(map[int]string, 128)
TableNameByID = make(map[string]string, 128)
- RoleByDataSource[0] = "meta_server"
- RoleByDataSource[1] = "replica_server"
+ RoleByDataSource[0] = "meta"
+ RoleByDataSource[1] = "replica"
initMetrics()
return &Collector{detectInterval: detectInterval, detectTimeout:
detectTimeout}
@@ -143,7 +143,7 @@ func initMetrics() {
return
}
jsonData := gjson.Parse(data)
- for _, entity := range jsonData.Array() {
+ for _, entity := range jsonData.Get("entities").Array() {
for _, metric := range entity.Get("metrics").Array() {
var name string = metric.Get("name").String()
var mtype string = metric.Get("type").String()
@@ -211,7 +211,7 @@ func processAllServerMetrics() {
return
}
jsonData := gjson.Parse(data)
- for _, entity := range jsonData.Array() {
+ for _, entity := range jsonData.Get("entities").Array() {
etype := entity.Get("type").String()
switch etype {
case "replica":
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
