feat: cache metrics (OpenAtomFoundation#2318)

* cache metrics

tools/pika_exporter/config/info.toml

@@ -5,6 +5,7 @@ stats = true
 cpu = true
 replication = true
 keyspace = true
+cache = true
 
 execcount = false
 commandstats = false

tools/pika_exporter/exporter/conf.go

@@ -22,6 +22,7 @@ type InfoConfig struct {
 	Execcount    bool `toml:"execcount"`
 	Commandstats bool `toml:"commandstats"`
 	Rocksdb      bool `toml:"rocksdb"`
+	Cache        bool `toml:"cache"`
 
 	Info    bool
 	InfoAll bool
@@ -70,6 +71,7 @@ func (c *InfoConfig) Display() {
 	log.Println("Execcount:", c.Execcount)
 	log.Println("Commandstats:", c.Commandstats)
 	log.Println("Rocksdb:", c.Rocksdb)
+	log.Println("Cache:", c.Cache)
 	log.Println("Info:", c.Info)
 	log.Println("InfoAll:", c.InfoAll)
 }
@@ -80,7 +82,7 @@ func (c *InfoConfig) CheckInfo() {
 
 	if c.Server && c.Data && c.Clients && c.Stats && c.CPU && c.Replication && c.Keyspace {
 		c.Info = true
-		if c.Execcount && c.Commandstats && c.Rocksdb {
+		if c.Execcount && c.Commandstats && c.Rocksdb && c.Cache {
 			c.InfoAll = true
 		}
 	}

tools/pika_exporter/exporter/metrics/cache.go

@@ -0,0 +1,87 @@
+// Copyright (c) 2015-present, Qihoo, Inc.  All rights reserved.
+// This source code is licensed under the BSD-style license found in the
+// LICENSE file in the root directory of this source tree. An additional grant
+// of patent rights can be found in the PATENTS file in the same directory.
+
+package metrics
+
+import (
+	"regexp"
+)
+
+func RegisterCache() {
+	Register(collectCacheMetrics)
+}
+
+var collectCacheMetrics = map[string]MetricConfig{
+	"cache_status": {
+		Parser: &normalParser{},
+		MetricMeta: &MetaData{
+			Name:      "cache_status",
+			Help:      "pika serve instance cache status",
+			Type:      metricTypeGauge,
+			Labels:    []string{LabelNameAddr, LabelNameAlias},
+			ValueName: "cache_status",
+		},
+	},
+	"cache_db_num": {
+		Parser: &normalParser{},
+		MetricMeta: &MetaData{
+			Name:      "cache_db_num",
+			Help:      "pika serve instance cache number",
+			Type:      metricTypeGauge,
+			Labels:    []string{LabelNameAddr, LabelNameAlias},
+			ValueName: "cache_db_num",
+		},
+	},
+	"cache_memory": {
+		Parser: &normalParser{},
+		MetricMeta: &MetaData{
+			Name:      "cache_memory",
+			Help:      "pika serve instance cache memory usage",
+			Type:      metricTypeGauge,
+			Labels:    []string{LabelNameAddr, LabelNameAlias},
+			ValueName: "cache_memory",
+		},
+	},
+	"hits_per_sec": {
+		Parser: &normalParser{},
+		MetricMeta: &MetaData{
+			Name:      "hits_per_sec",
+			Help:      "pika serve instance cache hit count per second ",
+			Type:      metricTypeGauge,
+			Labels:    []string{LabelNameAddr, LabelNameAlias},
+			ValueName: "hits_per_sec",
+		},
+	},
+	"hitratio_per_second": {
+		Parser: &regexParser{
+			name:   "hitratio_per_sec",
+			reg:    regexp.MustCompile(`^(?P<hitratio_per_sec>\d+)%$`),
+			Parser: &normalParser{},
+			source: "hitratio_per_sec",
+		},
+		MetricMeta: &MetaData{
+			Name:      "hitratio_per_sec",
+			Help:      "pika serve instance cache hit rate per second",
+			Type:      metricTypeGauge,
+			Labels:    []string{LabelNameAddr, LabelNameAlias},
+			ValueName: "hitratio_per_sec",
+		},
+	},
+	"hitratio": {
+		Parser: &regexParser{
+			name:   "hitratio_per_sec",
+			reg:    regexp.MustCompile(`^(?P<hitratio_all>\d+)%$`),
+			Parser: &normalParser{},
+			source: "hitratio_all",
+		},
+		MetricMeta: &MetaData{
+			Name:      "hitratio_all",
+			Help:      "pika serve instance cache hit rate",
+			Type:      metricTypeGauge,
+			Labels:    []string{LabelNameAddr, LabelNameAlias},
+			ValueName: "hitratio_all",
+		},
+	},
+}

tools/pika_exporter/exporter/metrics/parser.go

@@ -243,7 +243,7 @@ func convertToFloat64(s string) float64 {
 	s = strings.ToLower(s)
 
 	switch s {
-	case "yes", "up", "online", "true":
+	case "yes", "up", "online", "true", "ok":
 		return 1
 	case "no", "down", "offline", "null", "false":
 		return 0

tools/pika_exporter/exporter/pika.go

@@ -8,11 +8,10 @@ import (
 	"sync"
 	"time"
 
-	"github.com/OpenAtomFoundation/pika/tools/pika_exporter/discovery"
-
 	"github.com/prometheus/client_golang/prometheus"
 	log "github.com/sirupsen/logrus"
 
+	"github.com/OpenAtomFoundation/pika/tools/pika_exporter/discovery"
 	"github.com/OpenAtomFoundation/pika/tools/pika_exporter/exporter/metrics"
 )
 
@@ -241,7 +240,6 @@ func (e *exporter) collectInfo(c *client, ch chan<- prometheus.Metric) error {
 	if err != nil {
 		return err
 	}
-
 	collector := metrics.CollectFunc(func(m metrics.Metric) error {
 		promMetric, err := prometheus.NewConstMetric(
 			prometheus.NewDesc(prometheus.BuildFQName(e.namespace, "", m.Name), m.Help, m.Labels, nil),
@@ -328,6 +326,9 @@ func (e *exporter) registerMetrics() {
 	if config.Rocksdb {
 		metrics.RegisterRocksDB()
 	}
+	if config.Cache {
+		metrics.RegisterCache()
+	}
 	metrics.RegisterBinlog()
 }