aboutsummaryrefslogtreecommitdiff
path: root/weed/shell
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2022-10-09 18:58:14 -0700
committerchrislu <chris.lu@gmail.com>2022-10-09 18:58:14 -0700
commit1e27d36576afd1d2525e1146b7994cd3d7ef51c5 (patch)
tree81a9ef90764dd4c50d9adafe3d547d12fab0ea6d /weed/shell
parentf9383aa726771b9bd9027cf5e9d62fcaecad9cee (diff)
parentb7de4a967e14f4d7419378e1daf590d3ef8c3c82 (diff)
downloadseaweedfs-1e27d36576afd1d2525e1146b7994cd3d7ef51c5.tar.xz
seaweedfs-1e27d36576afd1d2525e1146b7994cd3d7ef51c5.zip
Merge branch 'master' of https://github.com/seaweedfs/seaweedfs
Diffstat (limited to 'weed/shell')
-rw-r--r--weed/shell/command_cluster_raft_ps.go6
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