diff options
| author | Konstantin Lebedev <9497591+kmlebedev@users.noreply.github.com> | 2022-10-06 19:10:41 +0500 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-10-06 07:10:41 -0700 |
| commit | 36daa7709d52e368ee4efc9a05a4e9dece321dc0 (patch) | |
| tree | d0bead92e3bf40b7ef91b6fa774d7105e0d8bf1e /weed/server/master_grpc_server_raft.go | |
| parent | 0f522da367b85820aa0fb1e8b2efb769cecff7af (diff) | |
| download | seaweedfs-36daa7709d52e368ee4efc9a05a4e9dece321dc0.tar.xz seaweedfs-36daa7709d52e368ee4efc9a05a4e9dece321dc0.zip | |
show raft leader via shell (#3796)
Diffstat (limited to 'weed/server/master_grpc_server_raft.go')
| -rw-r--r-- | weed/server/master_grpc_server_raft.go | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/weed/server/master_grpc_server_raft.go b/weed/server/master_grpc_server_raft.go index 7f8ad70df..e6454704e 100644 --- a/weed/server/master_grpc_server_raft.go +++ b/weed/server/master_grpc_server_raft.go @@ -20,6 +20,7 @@ func (ms *MasterServer) RaftListClusterServers(ctx context.Context, req *master_ } servers := ms.Topo.HashicorpRaft.GetConfiguration().Configuration().Servers + _, leaderId := ms.Topo.HashicorpRaft.LeaderWithID() ms.Topo.RaftServerAccessLock.RUnlock() for _, server := range servers { @@ -27,6 +28,7 @@ func (ms *MasterServer) RaftListClusterServers(ctx context.Context, req *master_ Id: string(server.ID), Address: string(server.Address), Suffrage: server.Suffrage.String(), + IsLeader: server.ID == leaderId, }) } return resp, nil |