aboutsummaryrefslogtreecommitdiff
path: root/weed/server/filer_server_handlers.go
diff options
context:
space:
mode:
authorsteve.wei <coderushing@gmail.com>2024-10-15 03:10:05 +0800
committerGitHub <noreply@github.com>2024-10-14 12:10:05 -0700
commitcfbe45c7658350e2b8f636d093a2bbe2028f8521 (patch)
treea7e636b3e61fa1e8b204fa687bc613aaa62046ab /weed/server/filer_server_handlers.go
parenta1f06c391cbea9b61f6cff8c3db224e466c06351 (diff)
downloadseaweedfs-cfbe45c7658350e2b8f636d093a2bbe2028f8521.tar.xz
seaweedfs-cfbe45c7658350e2b8f636d093a2bbe2028f8521.zip
feat: add in-flight metric for s3/file/volume-server (#6120)
Diffstat (limited to 'weed/server/filer_server_handlers.go')
-rw-r--r--weed/server/filer_server_handlers.go5
1 files changed, 5 insertions, 0 deletions
diff --git a/weed/server/filer_server_handlers.go b/weed/server/filer_server_handlers.go
index 69774ce27..1c5c89dcf 100644
--- a/weed/server/filer_server_handlers.go
+++ b/weed/server/filer_server_handlers.go
@@ -21,6 +21,11 @@ import (
func (fs *FilerServer) filerHandler(w http.ResponseWriter, r *http.Request) {
start := time.Now()
+
+ inFlightGauge := stats.FilerInFlightRequestsGauge.WithLabelValues(r.Method)
+ inFlightGauge.Inc()
+ defer inFlightGauge.Dec()
+
statusRecorder := stats.NewStatusResponseWriter(w)
w = statusRecorder
origin := r.Header.Get("Origin")