aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorsteve.wei <coderushing@gmail.com>2024-04-17 19:49:50 +0800
committerGitHub <noreply@github.com>2024-04-17 04:49:50 -0700
commit0bdf121e519534cbf4af64bb3423eb3bdb858ad0 (patch)
tree57457b1e479fde25ad3115aba879b4b916fb6ea9
parent37019477bc68f0f3ed83e39034b455622b35b383 (diff)
downloadseaweedfs-0bdf121e519534cbf4af64bb3423eb3bdb858ad0.tar.xz
seaweedfs-0bdf121e519534cbf4af64bb3423eb3bdb858ad0.zip
rename VolumeServerVolumeGauge (#5504)
-rw-r--r--weed/stats/metrics.go6
-rw-r--r--weed/storage/erasure_coding/ec_shard.go4
-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, 8 insertions, 8 deletions
diff --git a/weed/stats/metrics.go b/weed/stats/metrics.go
index 83391f047..4393c280c 100644
--- a/weed/stats/metrics.go
+++ b/weed/stats/metrics.go
@@ -194,7 +194,7 @@ var (
Buckets: prometheus.ExponentialBuckets(0.0001, 2, 24),
}, []string{"type"})
- VolumeServerVolumeCounter = prometheus.NewGaugeVec(
+ VolumeServerVolumeGauge = prometheus.NewGaugeVec(
prometheus.GaugeOpts{
Namespace: Namespace,
Subsystem: "volumeServer",
@@ -291,7 +291,7 @@ func init() {
Gather.MustRegister(VolumeServerVacuumingCompactCounter)
Gather.MustRegister(VolumeServerVacuumingCommitCounter)
Gather.MustRegister(VolumeServerVacuumingHistogram)
- Gather.MustRegister(VolumeServerVolumeCounter)
+ Gather.MustRegister(VolumeServerVolumeGauge)
Gather.MustRegister(VolumeServerMaxVolumeCounter)
Gather.MustRegister(VolumeServerReadOnlyVolumeGauge)
Gather.MustRegister(VolumeServerDiskSizeGauge)
@@ -354,5 +354,5 @@ func DeleteCollectionMetrics(collection string) {
for _, volume_type := range readOnlyVolumeTypes {
VolumeServerReadOnlyVolumeGauge.DeleteLabelValues(collection, volume_type)
}
- VolumeServerVolumeCounter.DeleteLabelValues(collection, "volume")
+ VolumeServerVolumeGauge.DeleteLabelValues(collection, "volume")
}
diff --git a/weed/storage/erasure_coding/ec_shard.go b/weed/storage/erasure_coding/ec_shard.go
index 19ee17636..9fcb11525 100644
--- a/weed/storage/erasure_coding/ec_shard.go
+++ b/weed/storage/erasure_coding/ec_shard.go
@@ -44,7 +44,7 @@ func NewEcVolumeShard(diskType types.DiskType, dirname string, collection string
}
v.ecdFileSize = ecdFi.Size()
- stats.VolumeServerVolumeCounter.WithLabelValues(v.Collection, "ec_shards").Inc()
+ stats.VolumeServerVolumeGauge.WithLabelValues(v.Collection, "ec_shards").Inc()
return
}
@@ -88,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").Dec()
+ stats.VolumeServerVolumeGauge.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 232930b80..94d1f9a4e 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").Dec()
+ stats.VolumeServerVolumeGauge.WithLabelValues(v.Collection, "volume").Dec()
}
}
diff --git a/weed/storage/volume_loading.go b/weed/storage/volume_loading.go
index 78dfa6901..6e9b2f623 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").Inc()
+ stats.VolumeServerVolumeGauge.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 b070fa901..c8098493d 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").Dec()
+ stats.VolumeServerVolumeGauge.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 {