aboutsummaryrefslogtreecommitdiff
path: root/weed/server
diff options
context:
space:
mode:
authorGuo Lei <snipergg@163.com>2022-06-15 15:28:40 +0800
committerGitHub <noreply@github.com>2022-06-15 15:28:40 +0800
commit3df84cabf67918beb4bb4f56c4250e57c0f219c5 (patch)
treee9d76793170ee607e915f7679bb35a667ace397e /weed/server
parent695e8c75551b7de9f47723b682f0cb0ab4b74002 (diff)
parentb8ce05c9047cc95d76b57116affeb4ca7385c34a (diff)
downloadseaweedfs-3df84cabf67918beb4bb4f56c4250e57c0f219c5.tar.xz
seaweedfs-3df84cabf67918beb4bb4f56c4250e57c0f219c5.zip
Merge branch 'chrislusf:master' into weed_update
Diffstat (limited to 'weed/server')
-rw-r--r--weed/server/filer_grpc_server_sub_meta.go4
1 files changed, 4 insertions, 0 deletions
diff --git a/weed/server/filer_grpc_server_sub_meta.go b/weed/server/filer_grpc_server_sub_meta.go
index 0540400a3..da710234b 100644
--- a/weed/server/filer_grpc_server_sub_meta.go
+++ b/weed/server/filer_grpc_server_sub_meta.go
@@ -2,6 +2,7 @@ package weed_server
import (
"fmt"
+ "github.com/chrislusf/seaweedfs/weed/stats"
"strings"
"time"
@@ -229,6 +230,9 @@ func (fs *FilerServer) eachEventNotificationFn(req *filer_pb.SubscribeMetadataRe
}
}
+ // collect timestamps for path
+ stats.FilerServerLastSendTsOfSubscribeGauge.WithLabelValues(fs.option.Host.String(), req.ClientName, req.PathPrefix).Set(float64(tsNs))
+
message := &filer_pb.SubscribeMetadataResponse{
Directory: dirPath,
EventNotification: eventNotification,