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/shell/command_cluster_raft_ps.go | |
| parent | 0f522da367b85820aa0fb1e8b2efb769cecff7af (diff) | |
| download | seaweedfs-36daa7709d52e368ee4efc9a05a4e9dece321dc0.tar.xz seaweedfs-36daa7709d52e368ee4efc9a05a4e9dece321dc0.zip | |
show raft leader via shell (#3796)
Diffstat (limited to 'weed/shell/command_cluster_raft_ps.go')
| -rw-r--r-- | weed/shell/command_cluster_raft_ps.go | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/weed/shell/command_cluster_raft_ps.go b/weed/shell/command_cluster_raft_ps.go index 6e58b461c..58e7d7585 100644 --- a/weed/shell/command_cluster_raft_ps.go +++ b/weed/shell/command_cluster_raft_ps.go @@ -40,7 +40,11 @@ func (c *commandRaftClusterPs) Do(args []string, commandEnv *CommandEnv, writer } fmt.Fprintf(writer, "the raft cluster has %d servers\n", len(resp.ClusterServers)) for _, server := range resp.ClusterServers { - fmt.Fprintf(writer, " * %s %s (%s)\n", server.Id, server.Address, server.Suffrage) + suffrage := server.Suffrage + if server.IsLeader { + suffrage = "Leader" + } + fmt.Fprintf(writer, " * %s %s (%s)\n", server.Id, server.Address, suffrage) } return nil |