aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chrislusf@users.noreply.github.com>2023-08-21 11:38:12 -0700
committerGitHub <noreply@github.com>2023-08-21 11:38:12 -0700
commit9215ba24be0aec0c5804927cc73613560e57cbc0 (patch)
tree719054e0f8f757fe2c3fc2f63fb5978ba7c813c6
parent9956d93a4023874505eb6e531f930199fa7f3820 (diff)
downloadseaweedfs-9215ba24be0aec0c5804927cc73613560e57cbc0.tar.xz
seaweedfs-9215ba24be0aec0c5804927cc73613560e57cbc0.zip
Revert "Add disk type to prometheus metrics" (#4777)
Revert "Add disk type to prometheus metrics (#4736)" This reverts commit 9956d93a4023874505eb6e531f930199fa7f3820.
-rw-r--r--weed/stats/metrics.go8
-rw-r--r--weed/storage/erasure_coding/ec_shard.go6
-rw-r--r--weed/storage/volume.go2
-rw-r--r--weed/storage/volume_loading.go2
-rw-r--r--weed/storage/volume_vacuum.go2
5 files changed, 10 insertions, 10 deletions
diff --git a/weed/stats/metrics.go b/weed/stats/metrics.go
index af4f26e4c..dda4d95e5 100644
--- a/weed/stats/metrics.go
+++ b/weed/stats/metrics.go
@@ -176,7 +176,7 @@ var (
Subsystem: "volumeServer",
Name: "volumes",
Help: "Number of volumes or shards.",
- }, []string{"collection", "type", "disk"})
+ }, []string{"collection", "type"})
VolumeServerReadOnlyVolumeGauge = prometheus.NewGaugeVec(
prometheus.GaugeOpts{
@@ -299,6 +299,7 @@ func JoinHostPort(host string, port int) string {
return net.JoinHostPort(host, portStr)
}
+
func StartMetricsServer(ip string, port int) {
if port == 0 {
return
@@ -315,10 +316,11 @@ func SourceName(port uint32) string {
return net.JoinHostPort(hostname, strconv.Itoa(int(port)))
}
+// todo - can be changed to DeletePartialMatch when https://github.com/prometheus/client_golang/pull/1013 gets released
func DeleteCollectionMetrics(collection string) {
VolumeServerDiskSizeGauge.DeleteLabelValues(collection, "normal")
for _, volume_type := range readOnlyVolumeTypes {
- VolumeServerReadOnlyVolumeGauge.DeletePartialMatch(prometheus.Labels{"collection": collection, "type": volume_type})
+ VolumeServerReadOnlyVolumeGauge.DeleteLabelValues(collection, volume_type)
}
- VolumeServerVolumeCounter.DeletePartialMatch(prometheus.Labels{"collection": collection, "type": "volume"})
+ VolumeServerVolumeCounter.DeleteLabelValues(collection, "volume")
}
diff --git a/weed/storage/erasure_coding/ec_shard.go b/weed/storage/erasure_coding/ec_shard.go
index 85694e63b..19ee17636 100644
--- a/weed/storage/erasure_coding/ec_shard.go
+++ b/weed/storage/erasure_coding/ec_shard.go
@@ -7,8 +7,6 @@ import (
"strconv"
"strings"
- "github.com/seaweedfs/seaweedfs/weed/storage/types"
-
"github.com/seaweedfs/seaweedfs/weed/stats"
"github.com/seaweedfs/seaweedfs/weed/storage/needle"
"github.com/seaweedfs/seaweedfs/weed/storage/types"
@@ -46,7 +44,7 @@ func NewEcVolumeShard(diskType types.DiskType, dirname string, collection string
}
v.ecdFileSize = ecdFi.Size()
- stats.VolumeServerVolumeCounter.WithLabelValues(v.Collection, "ec_shards", string(v.DiskType)).Inc()
+ stats.VolumeServerVolumeCounter.WithLabelValues(v.Collection, "ec_shards").Inc()
return
}
@@ -90,7 +88,7 @@ func (shard *EcVolumeShard) Close() {
func (shard *EcVolumeShard) Destroy() {
os.Remove(shard.FileName() + ToExt(int(shard.ShardId)))
- stats.VolumeServerVolumeCounter.WithLabelValues(shard.Collection, "ec_shards", string(shard.DiskType)).Dec()
+ stats.VolumeServerVolumeCounter.WithLabelValues(shard.Collection, "ec_shards").Dec()
}
func (shard *EcVolumeShard) ReadAt(buf []byte, offset int64) (int, error) {
diff --git a/weed/storage/volume.go b/weed/storage/volume.go
index 8530bc2e7..232930b80 100644
--- a/weed/storage/volume.go
+++ b/weed/storage/volume.go
@@ -246,7 +246,7 @@ func (v *Volume) doClose() {
glog.Warningf("Volume Close fail to sync volume %d", v.Id)
}
v.DataBackend = nil
- stats.VolumeServerVolumeCounter.WithLabelValues(v.Collection, "volume", v.DiskType().ReadableString()).Dec()
+ stats.VolumeServerVolumeCounter.WithLabelValues(v.Collection, "volume").Dec()
}
}
diff --git a/weed/storage/volume_loading.go b/weed/storage/volume_loading.go
index e7018d52c..78dfa6901 100644
--- a/weed/storage/volume_loading.go
+++ b/weed/storage/volume_loading.go
@@ -201,7 +201,7 @@ func (v *Volume) load(alsoLoadIndex bool, createDatIfMissing bool, needleMapKind
}
}
- stats.VolumeServerVolumeCounter.WithLabelValues(v.Collection, "volume", v.DiskType().ReadableString()).Inc()
+ stats.VolumeServerVolumeCounter.WithLabelValues(v.Collection, "volume").Inc()
if err == nil {
hasLoadedVolume = true
diff --git a/weed/storage/volume_vacuum.go b/weed/storage/volume_vacuum.go
index 9e5993a82..0eaca5ff4 100644
--- a/weed/storage/volume_vacuum.go
+++ b/weed/storage/volume_vacuum.go
@@ -124,7 +124,7 @@ func (v *Volume) CommitCompact() error {
}
}
v.DataBackend = nil
- stats.VolumeServerVolumeCounter.WithLabelValues(v.Collection, "volume", v.DiskType().ReadableString()).Dec()
+ stats.VolumeServerVolumeCounter.WithLabelValues(v.Collection, "volume").Dec()
var e error
if e = v.makeupDiff(v.FileName(".cpd"), v.FileName(".cpx"), v.FileName(".dat"), v.FileName(".idx")); e != nil {