diff options
| author | zhihao.qu <zhihao.qu@ly.com> | 2022-06-15 11:33:18 +0800 |
|---|---|---|
| committer | zhihao.qu <zhihao.qu@ly.com> | 2022-06-15 11:33:18 +0800 |
| commit | 42d04c581b174d21ecbd137bac87256adeaa9fd3 (patch) | |
| tree | f6d247b8381d21d7af706776b15904e1471720dc /weed/server/filer_grpc_server_sub_meta.go | |
| parent | d4ef06cdcf320f8b8b17279586e0738894869eff (diff) | |
| download | seaweedfs-42d04c581b174d21ecbd137bac87256adeaa9fd3.tar.xz seaweedfs-42d04c581b174d21ecbd137bac87256adeaa9fd3.zip | |
feat(filer.sync): add metricsServer in filer.sync.
Metrics include:
(1) the offset of the filer.sync
(2) the last send timestamp of the filer subscription
Diffstat (limited to 'weed/server/filer_grpc_server_sub_meta.go')
| -rw-r--r-- | weed/server/filer_grpc_server_sub_meta.go | 4 |
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, |