aboutsummaryrefslogtreecommitdiff
path: root/weed/server/master_server.go
diff options
context:
space:
mode:
authorKonstantin Lebedev <9497591+kmlebedev@users.noreply.github.com>2022-01-24 19:09:43 +0500
committerKonstantin Lebedev <9497591+kmlebedev@users.noreply.github.com>2022-01-24 19:09:43 +0500
commit28efe3152459b9be946ca1b05e940d7392e33126 (patch)
tree52812d6de4d008f75f6805d6e4c92bd285fb0758 /weed/server/master_server.go
parent3bba2124ef346e90f6f2b5378ad6ce63c7f2226e (diff)
downloadseaweedfs-28efe3152459b9be946ca1b05e940d7392e33126.tar.xz
seaweedfs-28efe3152459b9be946ca1b05e940d7392e33126.zip
new master metrics
Diffstat (limited to 'weed/server/master_server.go')
-rw-r--r--weed/server/master_server.go2
1 files changed, 2 insertions, 0 deletions
diff --git a/weed/server/master_server.go b/weed/server/master_server.go
index 3851c4d2a..671432d5c 100644
--- a/weed/server/master_server.go
+++ b/weed/server/master_server.go
@@ -2,6 +2,7 @@ package weed_server
import (
"fmt"
+ "github.com/chrislusf/seaweedfs/weed/stats"
"net/http"
"net/http/httputil"
"net/url"
@@ -162,6 +163,7 @@ func (ms *MasterServer) SetRaftServer(raftServer *RaftServer) {
ms.Topo.RaftServer = raftServer.raftServer
ms.Topo.RaftServer.AddEventListener(raft.LeaderChangeEventType, func(e raft.Event) {
glog.V(0).Infof("leader change event: %+v => %+v", e.PrevValue(), e.Value())
+ stats.MasterLeaderChangeCounter.WithLabelValues(fmt.Sprintf("%+v", e.Value())).Inc()
if ms.Topo.RaftServer.Leader() != "" {
glog.V(0).Infoln("[", ms.Topo.RaftServer.Name(), "]", ms.Topo.RaftServer.Leader(), "becomes leader.")
}