aboutsummaryrefslogtreecommitdiff
path: root/weed/server/master_grpc_server_raft.go
diff options
context:
space:
mode:
Diffstat (limited to 'weed/server/master_grpc_server_raft.go')
-rw-r--r--weed/server/master_grpc_server_raft.go2
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